이 글은 NIO 코어, BIO와 NIO의 비교, NIO를 통한 간단한 서버-클라이언트 통신 등 NIO 관련 문제를 주로 소개하는 java에 대한 관련 지식을 제공합니다.
추천 학습: "java 튜토리얼"
데이터를 처리하는 데 사용되는 I/O 모델의 핵심은 무엇인가요? 송수신은 프로그램 통신의 성능을 크게 좌우합니다.
Java는 BIO, NIO, AIO
BIO의 총 세 가지 네트워크 프로그래밍 모델을 지원합니다. 동기화 및 차단, 서비스 구현 모드는 하나의 연결과 하나의 스레드입니다. 즉, 클라이언트가 연결 요청을 하면 서버가 처리를 위해 스레드를 시작해야 합니다.
NIO: 동기식 및 비차단형 서버 구현 모드는 하나의 스레드가 여러 요청 연결을 처리하는 것입니다. 즉, 클라이언트가 보낸 모든 요청은 멀티플렉서에 등록되고 멀티플렉서는 연결이 완료될 때까지 폴링합니다. I/O O 요청이 처리됩니다.
AIO: 비동기 비차단, AIO는 비동기 채널 개념을 도입하고 Proactor 모드를 채택하며 프로그램 작성을 단순화하고 유효한 요청 후에만 스레드를 시작하는 것이 특징입니다. 서버.
BIO 방식은 상대적으로 적고 연결 수가 고정된 아키텍처에 적합합니다. 이 방식은 서버 리소스에 대한 요구 사항이 상대적으로 높으며 동시성은 애플리케이션으로 제한됩니다. JDK1.4 이전에는 유일한 옵션이지만 절차가 간단하고 이해하기 쉽습니다.
NIO 방식은 채팅 서버, 사격 시스템, 서버 간 통신 등과 같이 연결 수가 많고 상대적으로 연결이 짧은(가벼운 작업) 아키텍처에 적합합니다. 프로그래밍은 더욱 복잡해졌으며 JDK1.4에서는 이를 지원하기 시작했습니다.
AIO 방법은 사진 앨범 서버와 같이 연결 수가 많고 연결이 상대적으로 긴 아키텍처에서 사용됩니다. JDK7은 프로그래밍이 더 복잡합니다.
서버는 ServerSocket을 시작합니다.
클라이언트는 서버와 통신하기 위해 소켓을 시작합니다.
클라이언트가 요청을 보낸 후 먼저 서버에 문의하여 스레드 응답이 있는지 확인합니다. 그렇지 않으면 기다리거나 거부됩니다. 클라이언트 스레드는 실행을 계속하기 전에 요청이 끝날 때까지 기다립니다.
5. NIO 코어
6. BIO와 NIO의 비교
BIO는 바이트 스트림과 문자 스트림을 기반으로 작동하는 반면 NIO는 채널 및 버퍼를 기반으로 작동하며 데이터는 항상 채널에서 버퍼로 읽혀집니다. 채널에 대한 버퍼입니다. 선택기는 여러 채널 이벤트(예: 연결 요청, 데이터 도착 등)를 모니터링하는 데 사용되므로 단일 스레드가 여러 클라이언트 채널을 모니터링할 수 있습니다.
7. NIO
흐름도 설명:
이 그림은 다음을 반영합니다. 세 가지 채널이 있습니다. //프로그램에 등록하세요.
각 채널은 버퍼에 해당합니다.
프로그램이 전환되는 채널은 이벤트에 따라 결정되며 이벤트는 중요한 개념입니다. 선택기는 각 채널에서 전환되는 다양한 이벤트에 따라 응답합니다.
버퍼는 메모리 블록이고 맨 아래 레이어에 배열이 있습니다.
데이터는 다음과 같습니다. BIO는 입력 스트림이거나 양방향일 수 없는 출력 스트림이지만 NIO 버퍼는 읽거나 쓸 수 있으며 플립 방법을 사용하여 전환해야 합니다.
채널은 기본 운영 체제의 상태를 반환할 수 있습니다. 예를 들어 Linux의 경우 기본 운영 체제 채널은 양방향입니다.
mark: mark
position: 위치, 버퍼 데이터가 읽힐 때마다 읽거나 쓸 다음 요소의 인덱스 읽기 또는 쓰기 다음 읽기 및 쓰기를 준비하기 위해 값이 매번 변경됩니다.
public final int 용량( )//이 버퍼의 용량을 반환합니다
public final Buffer position (int newPositio)//이 버퍼의 위치를 설정합니다
채널은 비동기적으로 데이터를 읽고 쓸 수 있습니다.
에 기록됩니다.transferFrom, 대상 채널의 데이터를 현재 채널로 복사
ByteBuffer는 입력된 데이터 유형에 관계없이 해당 데이터 유형을 사용하여 꺼내야 합니다. 그렇지 않으면 BufferUnderflowException이 발생할 수 있습니다. 예외.
일반 버퍼를 읽기 전용 버퍼로 변환할 수 있습니다.
NIO는 파일을 메모리(힙 외부 메모리)에서 직접 수정할 수 있도록 하는 MappedByteBuffer도 제공하며, 파일 동기화 방법은 NIO에서 완료합니다.
NIO는 여러 버퍼(예: 버퍼 배열), 즉 분산 및 수집을 통한 읽기 및 쓰기 작업도 지원합니다.
Java의 NIO, Non-Blocking IO 방식. 하나의 스레드를 사용하여 여러 클라이언트 연결을 처리할 수 있으며 선택기를 사용하게 됩니다.
선택기는 등록된 여러 채널에서 이벤트가 발생하는지 감지할 수 있습니다. 이벤트가 발생하면 이벤트를 획득하고 그에 따라 각 이벤트를 처리합니다. 이러한 방식으로 단일 스레드만 사용하여 여러 채널을 관리할 수 있습니다. 즉, 여러 연결과 요청을 관리할 수 있습니다.
연결/채널에 실제로 읽기 또는 쓰기 이벤트가 있는 경우에만 읽기 및 쓰기가 수행되므로 시스템 오버헤드가 크게 줄어들고 연결마다 스레드를 생성하고 여러 스레드를 유지할 필요가 없습니다.
여러 스레드 간 컨텍스트 전환으로 인한 오버헤드를 방지하세요.
open();//선택기 객체 가져오기
select(long timeout);//IO 작업이 있는 경우 등록된 모든 채널을 모니터링합니다. , 해당 SelectionKey를 내부 컬렉션에 추가하고 반환합니다. 매개변수는 시간 제한을 설정하는 데 사용됩니다.
selectedKeys(); //내부 컬렉션에서 모든 SelectionKey를 가져옵니다.
NIO의 ServerSocketChannel 기능은 ServerSocket과 유사하며, SocketChannel 기능은 Socket과 유사합니다.
package com.nezha.guor.nio;import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.*;import java.util.Iterator;public class NioServer {
private Selector selector;
private ServerSocketChannel serverSocketChannel;
private static final int PORT = 8080;
public NioServer() {
try {
//获得选择器
selector = Selector.open();
serverSocketChannel = ServerSocketChannel.open();
//绑定端口
serverSocketChannel.socket().bind(new InetSocketAddress(PORT));
//设置非阻塞模式
serverSocketChannel.configureBlocking(false);
//将该ServerSocketChannel 注册到selector
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
}catch (IOException e) {
System.out.println("NioServer error:"+e.getMessage());
}
}
public void listen() {
System.out.println("监听线程启动: " + Thread.currentThread().getName());
try {
while (true) {
int count = selector.select();
if(count > 0) {
//遍历得到selectionKey集合
Iterator<selectionkey> iterator = selector.selectedKeys().iterator();
while (iterator.hasNext()) {
SelectionKey key = iterator.next();
if(key.isAcceptable()) {
SocketChannel sc = serverSocketChannel.accept();
sc.configureBlocking(false);
sc.register(selector, SelectionKey.OP_READ);
System.out.println(sc.getRemoteAddress() + " 上线 ");
}
//通道发送read事件，即通道是可读的状态
if(key.isReadable()) {
getDataFromChannel(key);
}
//当前的key 删除，防止重复处理
iterator.remove();
}
} else {
System.out.println("等待中");
}
}
}catch (Exception e) {
System.out.println("listen error:"+e.getMessage());
}
}
private void getDataFromChannel(SelectionKey key) {
SocketChannel channel = null;
try {
channel = (SocketChannel) key.channel();
ByteBuffer buffer = ByteBuffer.allocate(1024);
int count = channel.read(buffer);
//根据count的值做处理
if(count > 0) {
String msg = new String(buffer.array());
System.out.println("来自客户端: " + msg);
//向其它的客户端转发消息(排除自己)
sendInfoToOtherClients(msg, channel);
}
}catch (IOException e) {
try {
System.out.println(channel.getRemoteAddress() + " 离线了");
//取消注册
key.cancel();
}catch (IOException ex) {
System.out.println("getDataFromChannel error:"+ex.getMessage());
}
}finally {
try {
channel.close();
}catch (IOException ex) {
System.out.println("channel.close() error:"+ex.getMessage());
}
}
}
//转发消息给其它客户(通道)
private void sendInfoToOtherClients(String msg, SocketChannel self ) throws IOException{
System.out.println("服务器转发消息中...");
System.out.println("服务器转发数据给客户端线程: " + Thread.currentThread().getName());
//遍历 所有注册到selector 上的 SocketChannel,并排除 self
for(SelectionKey key: selector.keys()) {
Channel targetChannel = key.channel();
//排除自己
if(targetChannel instanceof SocketChannel && targetChannel != self) {
SocketChannel dest = (SocketChannel)targetChannel;
//将信息存储到buffer
ByteBuffer buffer = ByteBuffer.wrap(msg.getBytes());
//将buffer数据写入通道
dest.write(buffer);
}
}
}
public static void main(String[] args) {
//创建服务器对象
NioServer nioServer = new NioServer();
nioServer.listen();
}}</selectionkey> "
자바 튜토리얼
"
위 내용은 Java NIO를 완전히 마스터할 수 있도록 안내합니다(요약 공유).의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![JavaScript 핵심 튜토리얼 [JS가 꼭 알아야 할 DOM BOM 연산]](https://img.php.cn/upload/course/000/000/041/61c56ae28d02a390.jpg)
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
