Java NIO的SocketChannel如何使用

Java NIO（New I/O）提供了非阻塞I/O操作，使得程序可以在等待数据时执行其他任务。SocketChannel是Java NIO中的一个关键组件，用于实现非阻塞的套接字通信。以下是如何使用SocketChannel的基本步骤：

1. 导入必要的包：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

2. 创建一个SocketChannel实例：

SocketChannel socketChannel = null;
try {
    socketChannel = SocketChannel.open();
} catch (IOException e) {
    e.printStackTrace();
}

3. 配置SocketChannel为非阻塞模式：

if (socketChannel != null) {
    try {
        socketChannel.configureBlocking(false);
    } catch (IOException e) {
        e.printStackTrace();
    }
}

4. 连接到远程服务器：

InetSocketAddress remoteAddress = new InetSocketAddress("localhost", 8080);
try {
    while (!socketChannel.finishConnect(remoteAddress)) {
        // 等待连接完成，可以在此期间执行其他任务
    }
} catch (IOException e) {
    e.printStackTrace();
}

5. 向服务器发送数据：

String message = "Hello, Server!";
ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
try {
    while (buffer.hasRemaining()) {
        socketChannel.write(buffer);
    }
} catch (IOException e) {
    e.printStackTrace();
}

6. 从服务器接收数据：

ByteBuffer receiveBuffer = ByteBuffer.allocate(1024);
try {
    int bytesRead = socketChannel.read(receiveBuffer);
    while (bytesRead != -1) {
        receiveBuffer.flip(); // 切换为读模式
        byte[] data = new byte[receiveBuffer.remaining()];
        receiveBuffer.get(data);
        String receivedMessage = new String(data);
        System.out.println("Received: " + receivedMessage);
        receiveBuffer.clear(); // 清空缓冲区，准备下一次读取
        bytesRead = socketChannel.read(receiveBuffer);
    }
} catch (IOException e) {
    e.printStackTrace();
}

7. 关闭SocketChannel：

if (socketChannel != null) {
    try {
        socketChannel.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

以上示例展示了如何使用SocketChannel进行非阻塞的套接字通信。在实际应用中，你可能需要根据具体需求对这些步骤进行调整。