贵州城乡建设厅城乡建设网站,做平台的网站,陌陌网站开发成本,网站做seo一、NIO
NIO是new IO#xff0c;也是非阻塞IO。有Channel、Selector、Buffer、Pipe、FileLock等类。
Buffer在java.nio包
Channel、Selector、Pipe、FileLock等在java.nio.channels包 二、Channel通道
设置非阻塞configureBlocking(false);
注册选择器register(selector,…一、NIO
NIO是new IO也是非阻塞IO。有Channel、Selector、Buffer、Pipe、FileLock等类。
Buffer在java.nio包
Channel、Selector、Pipe、FileLock等在java.nio.channels包 二、Channel通道
设置非阻塞configureBlocking(false);
注册选择器register(selector,SelectionKey.OP_XXX)
使用方法read(Buffer) ,write(Buffer)
使用方法open()获取Channel
FileChannel 使用FileInputStreamFileOutputStreamRandomAccessFile或者open(Path path, OpenOption... options)可以获取channel对象ServerSocketChannelSocketChannelDatagramChannelPipe.SinkChannel 使用pipe.sink()Pipe.SourceChannel 使用pipe.source() 三、Buffer缓冲
除了boolean类型没有Buffer类其他七种基本数据类型都有Buffer缓冲。而byte有两个Buffer缓冲一个是在堆一个在文件的内存映射区.
方法clear() 清空Buffer
方法compact()移动Buffer数据到起始位置设置为position在数据末尾
方法flip() 反转Buffer将写模式转成读模式
方法rewind() 从0开始读数据
方法hasRemaining()判断是否还有剩余数据
ByteBuffer
ShortBuffer
IntBuffer
LongBuffer
FloatBuffer
DoubleBuffer
CharBuffer
MappedByteBuffer 通过FileChannel.map方法产生 四、Selector 选择器 Selector selector Selector.open();
channel.configureBlocking(false);
SelectionKey key channel.register(selector,Selectionkey.OP_READ); select方法 int select()
int select(long timeout)
int selectNow() select()阻塞到至少有一个通道在你注册的事件上就绪了。
select(long timeout)和select()一样除了最长会阻塞timeout毫秒(参数)。
selectNow()不会阻塞不管什么通道就绪都立刻返回 调用Selector.wakeup()方法阻塞在select()方法上的线程会立马返回。
用完Selector后调用其close()方法会关闭该Selector且使注册到该Selector上的所有SelectionKey实例无效。通道本身并不会关闭。 五、SelectionKey
Selector四种事件用SelectionKey的四个常量来表示
SelectionKey.OP_CONNECT
SelectionKey.OP_ACCEPT
SelectionKey.OP_READ
SelectionKey.OP_WRITE 在Selector的select方法返回不为0时获取SelectionKey SetSelectionKey selectedKeys selector.selectedKeys();
Iterator keyIterator selectedKeys.iterator();
while(keyIterator.hasNext()) {SelectionKey key keyIterator.next();if(key.isAcceptable()) {// a connection was accepted by a ServerSocketChannel.} else if (key.isConnectable()) {// a connection was established with a remote server.} else if (key.isReadable()) {// a channel is ready for reading} else if (key.isWritable()) {// a channel is ready for writing}keyIterator.remove(); //必须移除掉否则下一次channel还留在selectionkeySet中。
} 六、Pipe 管道 (1)SinkChannel Pipe pipe Pipe.open();
Pipe.SinkChannel sinkChannel pipe.sink();
String data a sink pipe channel;
ByteBuffer buf ByteBuffer.allocate(50);
buf.clear();
buf.put(data.getBytes());
buf.flip();while(buf.hasRemaining()) {sinkChannel.write(buf);
} (2)SourceChannel Pipe.SourceChannel sourceChannel pipe.source();
ByteBuffer buf ByteBuffer.allocate(50);
int length sourceChannel.read(buf); 七、FileLock
FileLock与Lock接口相似但没有实现Lock接口
1概念
共享锁: 共享读操作但只能一个写读可以同时但写不能独占锁: 只有一个读或一个写读和写都不能同时
2FileLock FileChannel.lock(long position, long size, boolean shared)
shared的含义:是否使用共享锁,一些不支持共享锁的操作系统,将自动将共享锁改成排它锁。可以通过调用isShared()方法来检测获得的是什么类型的锁。
3 lock()和tryLock()的区别
lock()阻塞的方法锁定范围可以随着文件的增大而增加。无参lock()默认为独占锁有参lock(0L, Long.MAX_VALUE, true)为共享锁。
tryLock()非阻塞,当未获得锁时,返回null.
4FileLock的生命周期在调用FileLock.release(),或者Channel.close(),或者JVM关闭
5FileLock是线程安全的
6同一进程内在文件锁没有被释放之前不可以再次获取。即在release()方法调用前,只能lock()或者tryLock()一次。 FileChannel channel null;FileLock locknull;try {RandomAccessFile raf new RandomAccessFile(data.txt, rw);channel raf.getChannel();//获得锁方法一lock()阻塞的方法当文件锁不可用时当前进程会被挂起 lock channel.lock();//无参lock()为独占锁 //lock channel.lock(0L, Long.MAX_VALUE, true);//有参lock()为共享锁有写操作会报异常 //获得锁方法二trylock()非阻塞的方法当文件锁不可用时tryLock()会得到null值 //do { // lock channel.tryLock(); //} while (null lock); } catch (Exception e) {}finally{if (lock!null) {lock.release();}if (channel!null) {channel.close();}} 八、ServerSocketChannel 服务器通道 package cn.edu.scau.mk;import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;/**** author MK*/
public class Test {volatile static boolean isFinished false;public static void main(String[] args) throws IOException {ServerSocketChannel serverSocketChannel ServerSocketChannel.open();serverSocketChannel.socket().bind(new InetSocketAddress(888));while (!isFinished) {SocketChannel socketChannel serverSocketChannel.accept();//1.阻塞模式//线程处理socketChannel...//2.非阻塞模式if (socketChannel ! null) {//处理socketChannel...}}serverSocketChannel.close();}
} 九、SocketChannel TCP通道 package cn.edu.scau.mk;import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;/**** author MK*/
public class Test {volatile static boolean isFinished false;public static void main(String[] args) throws IOException {SocketChannel socketChannel SocketChannel.open();socketChannel.configureBlocking(false);//设置为非阻塞socketChannel.connect(new InetSocketAddress(https://www.baidu.com, 80));String data a socket channel connect;ByteBuffer buf ByteBuffer.allocate(48);buf.clear();buf.put(data.getBytes());buf.flip();while (!socketChannel.finishConnect()) {//等待连接成功或者做其他的事}//非阻塞状态有可能没有写入数据就返回了while (buf.hasRemaining()) {socketChannel.write(buf);}socketChannel.close();}
} 十、DatagramChannel UDP通道 package cn.edu.scau.mk;import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SocketChannel;/**** author MK*/
public class Test {volatile static boolean isFinished false;public static void main(String[] args) throws IOException {DatagramChannel channel DatagramChannel.open();channel.socket().bind(new InetSocketAddress(888));//channel.connect(new InetSocketAddress(www.baidu.com, 80));ByteBuffer buf ByteBuffer.allocate(48);buf.clear();//接收SocketAddress sachannel.receive(buf);//connect通道可以使用read//int bytesRead channel.read(buf);
buf.clear();buf.put(datagram channel.getBytes());buf.flip();//发送int length channel.send(buf, new InetSocketAddress(www.baidu.com, 80));//connect通道可以使用write//channel.write(buf);channel.close();}
}
