NIO 中的 ServerSocketChannel 功能类似 ServerSocket,SocketChannel 功能类似 Socket
image.png

  1. 当客户端连接时,会通过ServerSocketChannel 得到 SocketChannel
  2. Selector 进行监听 select 方法, 返回有事件发生的通道的个数.
  3. 将socketChannel注册到Selector上, register(Selector sel, int ops), 一个selector上可以注册多个SocketChannel
  4. 注册后返回一个 SelectionKey, 会和该Selector关联(集合)
  5. 进一步得到各个 SelectionKey (有事件发生)
  6. 再通过 SelectionKey 反向获取 SocketChannel , 方法 channel()
  7. 可以通过 得到的 channel , 完成业务处理

SelectionKey

表示 Selector 和网络通道的注册关系, 共四种:

  • OP_ACCEPT:有新的网络连接可以 accept,值为 16
  • OP_CONNECT:代表连接已经建立,值为 8
  • OP_READ:代表读操作,值为 1
  • OP_WRITE:代表写操作,值为 4

** :::tips

  • ServerSocketChannel 只关注 accept 事件
  • 服务端的SocketChannel 关注 read 、write 事件
  • 客户端的SocketChannel 关注 connect、read 、write 事件 :::
    1. public abstract class SelectionKey {
    2. public abstract Selector selector();//得到与之关联的 Selector 对象
    3. public abstract SelectableChannel channel();//得到与之关联的通道
    4. public final Object attachment();//得到与之关联的共享数据
    5. public abstract SelectionKey interestOps(int ops);//设置或改变监听事件
    6. public final boolean isAcceptable();//是否可以 accept
    7. public final boolean isReadable();//是否可以读
    8. public final boolean isWritable();//是否可以写
    9. }

ServerSocketChannel

指在服务器端监听新的客户端 Socket 连接

  1. public abstract class ServerSocketChannel extends AbstractSelectableChannel implements NetworkChannel{
  2. public static ServerSocketChannel open(),得到一个 ServerSocketChannel 通道
  3. public final ServerSocketChannel bind(SocketAddress local),设置服务器端端口号
  4. public final SelectableChannel configureBlocking(boolean block),设置阻塞或非阻塞模式,取值 false 表示采用非阻塞模式
  5. public SocketChannel accept(),接受一个连接,返回代表这个连接的通道对象
  6. public final SelectionKey register(Selector sel, int ops),注册一个选择器并设置监听事件
  7. }

SocketChannel

表示网络 IO 通道,具体负责进行读写操作。NIO 把缓冲区的数据写入通道,或者把通道里的数据读到缓冲区。

  1. public abstract class SocketChannel extends AbstractSelectableChannel implements ByteChannel, ScatteringByteChannel, GatheringByteChannel, NetworkChannel{
  2. public static SocketChannel open();//得到一个 SocketChannel 通道
  3. public final SelectableChannel configureBlocking(boolean block);//设置阻塞或非阻塞模式,取值 false 表示采用非阻塞模式
  4. public boolean connect(SocketAddress remote);//连接服务器
  5. public boolean finishConnect();//如果上面的方法连接失败,接下来就要通过该方法完成连接操作
  6. public int write(ByteBuffer src);//往通道里写数据
  7. public int read(ByteBuffer dst);//从通道里读数据
  8. public final SelectionKey register(Selector sel, int ops, Object att);//注册一个选择器并设置监听事件,最后一个参数可以设置共享数据
  9. public final void close();//关闭通道
  10. }