NIO в Java использует неблокирующий ввод-вывод. Вы можете использовать поток для обработки нескольких клиентских подключений, и вы будете использовать Selector (селектор)
Selector может определять, происходит ли событие на нескольких зарегистрированных каналах (примечание: несколько каналов могут быть зарегистрированы в одном и том же Selector в виде событий), если событие происходит, он получает событие и затем соответствующим образом обрабатывает каждое событие. Таким образом, только один поток может использоваться для управления несколькими каналами, то есть для управления несколькими соединениями и запросами.
Только когда соединение/канал действительно имеет события чтения и записи, чтение и запись будут выполняться, что значительно снижает нагрузку на систему, и нет необходимости создавать поток для каждого соединения, и нет необходимости поддерживать несколько потоков.
Избегает накладных расходов, вызванных переключением контекста между несколькими потоками.
API, связанный с селектором
Класс Selector является абстрактным классом. Общие методы и описания следующие:
public abstract class Selector implements Closeable {
public static Selector open();//得到一个选择器对象
public int select(long timeout);//监控所有注册的通道，当其中有 IO 操作可以进行时，将
对应的 SelectionKey 加入到内部集合中并返回，参数用来设置超时时间
public Set<SelectionKey> selectedKeys();//从内部集合中得到所有的 SelectionKey
}
Вы можете увидеть коллекцию selectionKeys внутри.
Пока в канале (канале) происходит событие, будет взят selectionKey, и тогда сбор selectionKey может быть облегчен, а канал, где произошло событие, может быть получен в обратном порядке через selectionKey.
Можно просто понять, что селекторная клавиша связана с каналом.
Меры предосторожности
public abstract class SelectionKey {
public abstract Selector selector();//得到与之关联的 Selector 对象
public abstract SelectableChannel channel();//得到与之关联的通道
public final Object attachment();//得到与之关联的共享数据
public abstract SelectionKey interestOps(int ops);//设置或改变监听事件
public final boolean isAcceptable();//是否可以 accept
public final boolean isReadable();//是否可以读
public final boolean isWritable();//是否可以写
}
Диаграмма анализа принципа неблокирующего сетевого программирования NIO
Пояснение к картинке выше:
Когда клиент подключается, он получает SocketChannel через ServerSocketChannel.
Селектор слушает метод выбора и возвращает количество каналов, на которых произошли события.
Зарегистрируйте socketChannel в селекторе, зарегистрируйте (Selector sel, int ops), несколько SocketChannels могут быть зарегистрированы в одном селекторе
После регистрации возвращается SelectionKey, который будет связан с Selector (коллекцией), и далее получаем каждый SelectionKey (происходят события)
После получения SocketChannel в обратном направлении через SelectionKey метод channel() может завершить бизнес-обработку через полученный канал.
package netty.nio;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
public class NIOClient {
public static void main(String[] args) throws Exception{
//得到一个网络通道
SocketChannel socketChannel = SocketChannel.open();
//设置非阻塞
socketChannel.configureBlocking(false);
//提供服务器端的ip 和 端口
InetSocketAddress inetSocketAddress = new InetSocketAddress("127.0.0.1", 6666);
//连接服务器
if (!socketChannel.connect(inetSocketAddress)) {
while (!socketChannel.finishConnect()) {
System.out.println("因为连接需要时间，客户端不会阻塞，可以做其它工作..");
}
}
//...如果连接成功，就发送数据
String str = "hello, 尚硅谷~";
//Wraps a byte array into a buffer
ByteBuffer buffer = ByteBuffer.wrap(str.getBytes());
//发送数据，将 buffer 数据写入 channel
socketChannel.write(buffer);
System.in.read();
}
}
SocketChannel и ServerSocketChannel
SocketChannel
Канал сетевого ввода-вывода, отвечающий за операции чтения и записи. NIO записывает данные из буфера в канал или считывает данные из канала в буфер.
public abstract class SocketChannel extends AbstractSelectableChannel implements ByteChannel, ScatteringByteChannel, GatheringByteChannel, NetworkChannel{
public static SocketChannel open();//得到一个 SocketChannel 通道
public final SelectableChannel configureBlocking(boolean block);//设置阻塞或非阻塞模式，取值 false 表示采用非阻塞模式
public boolean connect(SocketAddress remote);//连接服务器
public boolean finishConnect();//如果上面的方法连接失败，接下来就要通过该方法完成连接操作
public int write(ByteBuffer src);//往通道里写数据
public int read(ByteBuffer dst);//从通道里读数据
public final SelectionKey register(Selector sel, int ops, Object att);//注册一个选择器并设置监听事件，最后一个参数可以设置共享数据
public final void close();//关闭通道
}
ServerSocketChannel прослушивает новые клиентские сокет-соединения на стороне сервера.
public abstract class ServerSocketChannel extends AbstractSelectableChannel implements NetworkChannel{
public static ServerSocketChannel open()，得到一个 ServerSocketChannel 通道
public final ServerSocketChannel bind(SocketAddress local)，设置服务器端端口号
public final SelectableChannel configureBlocking(boolean block)，设置阻塞或非阻塞模式，取值 false 表示采用非阻塞模式
public SocketChannel accept()，接受一个连接，返回代表这个连接的通道对象
public final SelectionKey register(Selector sel, int ops)，注册一个选择器并设置监听事件
}
Обсуждайте друг с другом и добивайтесь прогресса вместе
Если в примечаниях к статье есть ошибки, укажите, пожалуйста.