Java的NIO之并发环境下非阻塞IO技术详解

// 示例代码
import java.nio.Buffer;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
public class NIOExample {
    public static void main(String[] args) {
        try {
            // 打开文件通道
            Path path = Paths.get("example.txt");
            FileChannel channel = FileChannel.open(path, StandardOpenOption.READ);
            // 创建缓冲区
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            // 从通道读取数据到缓冲区
            int bytesRead = channel.read(buffer);
            // 重置缓冲区的位置和限制
            buffer.flip();
            // 从缓冲区读取数据
            while (buffer.hasRemaining()) {
                System.out.print((char) buffer.get());
            }
            // 关闭通道
            channel.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

// 创建直接缓冲区
ByteBuffer buffer = ByteBuffer.allocateDirect(1024);

// 创建堆缓冲区
ByteBuffer buffer = ByteBuffer.allocate(1024);

// 打开文件通道
Path path = Paths.get("example.txt");
FileChannel channel = FileChannel.open(path, StandardOpenOption.READ);
// 创建缓冲区
ByteBuffer buffer = ByteBuffer.allocate(1024);
// 从通道读取数据到缓冲区
int bytesRead = channel.read(buffer);
// 重置缓冲区的位置和限制
buffer.flip();
// 从缓冲区读取数据
while (buffer.hasRemaining()) {
    System.out.print((char) buffer.get());
}
// 关闭通道
channel.close();

// 打开SocketChannel
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("example.com", 8080));
// 创建缓冲区
ByteBuffer buffer = ByteBuffer.allocate(1024);
// 从SocketChannel读取数据到缓冲区
int bytesRead = socketChannel.read(buffer);
// 重置缓冲区的位置和限制
buffer.flip();
// 从缓冲区读取数据
while (buffer.hasRemaining()) {
    System.out.print((char) buffer.get());
}
// 关闭SocketChannel
socketChannel.close();

// 打开选择器
Selector selector = Selector.open();
// 将通道注册到选择器上
channel.register(selector, SelectionKey.OP_READ);
// 循环处理选择器上的事件
while (true) {
    // 选择器等待事件
    int readyChannels = selector.select();
    // 处理选择器上的事件
    if (readyChannels > 0) {
        Set<SelectionKey> selectedKeys = selector.selectedKeys();
        for (SelectionKey key : selectedKeys) {
            if (key.isReadable()) {
                // 处理读事件
            } else if (key.isWritable()) {
                // 处理写事件
            }
        }
        selectedKeys.clear();
    }
}
// 关闭选择器
selector.close();

// 打开SocketChannel并设置为非阻塞模式
SocketChannel socketChannel = SocketChannel.open();
socketChannel.configureBlocking(false);
// 连接服务器
socketChannel.connect(new InetSocketAddress("example.com", 8080));
// 循环等待连接完成
while (!socketChannel.finishConnect()) {
    // 连接未完成，继续执行其他任务
}
// 连接完成后进行数据读写操作
if (socketChannel.isConnected()) {
    ByteBuffer buffer = ByteBuffer.allocate(1024);
    // 从SocketChannel读取数据
    int bytesRead = socketChannel.read(buffer);
    // 从缓冲区读取数据
    buffer.flip();
    while (buffer.hasRemaining()) {
        System.out.print((char) buffer.get());
    }
    // 写入数据到SocketChannel
    String message = "Hello, Server!";
    buffer.clear();
    buffer.put(message.getBytes());
    buffer.flip();
    while (buffer.hasRemaining()) {
        socketChannel.write(buffer);
    }
    // 关闭SocketChannel
    socketChannel.close();
}

// 创建事件监听器接口
interface EventListener {
    void onEvent(Event event);
}
// 创建事件处理器类
class EventHandler implements EventListener {
    @Override
    public void onEvent(Event event) {
        // 处理事件的逻辑
        System.out.println("处理事件：" + event);
    }
}
// 创建事件类
class Event {
    private String name;
    public Event(String name) {
        this.name = name;
    }
    @Override
    public String toString() {
        return "Event{" +
                "name='" + name + '\'' +
                '}';
    }
}
// 创建事件源类
class EventSource {
    private EventListener listener;
    public void setEventListener(EventListener listener) {
        this.listener = listener;
    }
    public void fireEvent(Event event) {
        // 触发事件
        if (listener != null) {
            listener.onEvent(event);
        }
    }
}
// 使用事件监听器和处理器
public class Main {
    public static void main(String[] args) {
        // 创建事件处理器
        EventHandler eventHandler = new EventHandler();
        // 创建事件源
        EventSource eventSource = new EventSource();
        eventSource.setEventListener(eventHandler);
        // 创建事件
        Event event = new Event("点击事件");
        // 触发事件
        eventSource.fireEvent(event);
    }
}