面试题：Java NIO Selector自定义事件处理逻辑与框架整合

定义新事件类型

创建一个新的类来表示自定义事件类型，例如CustomEventType。可以包含与该事件相关的任何属性和方法。

public class CustomEventType {
    // 相关属性
    private String data;

    public CustomEventType(String data) {
        this.data = data;
    }

    public String getData() {
        return data;
    }
}

实现事件处理逻辑

创建一个事件处理器接口，例如CustomEventHandler，并实现其处理方法。

public interface CustomEventHandler {
    void handle(CustomEventType event);
}

然后创建具体的处理器类实现该接口。

public class DefaultCustomEventHandler implements CustomEventHandler {
    @Override
    public void handle(CustomEventType event) {
        System.out.println("Handling custom event with data: " + event.getData());
    }
}

整合到Selector事件处理体系

在现有的Selector事件处理逻辑中，添加对新事件类型的支持。这通常涉及在SelectionKey中附加与新事件相关的信息。
例如，在注册通道到Selector时，可以通过attachment来关联自定义事件处理器。

Selector selector = Selector.open();
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(8080));
serverSocketChannel.configureBlocking(false);
SelectionKey key = serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT, new DefaultCustomEventHandler());

在Selector轮询事件的处理逻辑中，当检测到新事件相关的条件时，触发新事件的处理。

while (selector.select() > 0) {
    Set<SelectionKey> selectedKeys = selector.selectedKeys();
    Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
    while (keyIterator.hasNext()) {
        SelectionKey key = keyIterator.next();
        if (key.isAcceptable()) {
            // 处理新连接
            ServerSocketChannel serverSocketChannel = (ServerSocketChannel) key.channel();
            SocketChannel socketChannel = serverSocketChannel.accept();
            socketChannel.configureBlocking(false);
            // 这里可以根据情况注册新的事件类型相关操作
        } else if (/* 自定义事件触发条件 */) {
            CustomEventHandler handler = (CustomEventHandler) key.attachment();
            CustomEventType event = new CustomEventType("Some custom data");
            handler.handle(event);
        }
        keyIterator.remove();
    }
}

保证线程安全

共享资源同步：如果Selector、通道等资源在多线程中共享，使用synchronized关键字、ReentrantLock或java.util.concurrent包中的其他同步工具来确保同一时间只有一个线程可以访问这些资源。例如，在修改Selector注册信息或访问共享通道时：

private final ReentrantLock selectorLock = new ReentrantLock();
//...
selectorLock.lock();
try {
    SelectionKey key = serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT, new DefaultCustomEventHandler());
} finally {
    selectorLock.unlock();
}

使用线程安全的数据结构：如果在事件处理过程中使用到共享的数据结构，如用于存储连接信息的Map，使用线程安全的实现，如ConcurrentHashMap。

private final Map<SocketChannel, CustomEventType> connectionData = new ConcurrentHashMap<>();

事件队列：可以使用线程安全的队列（如LinkedBlockingQueue）来处理事件，将事件的生成和处理分离到不同线程，保证事件处理顺序和线程安全。

private final BlockingQueue<CustomEventType> eventQueue = new LinkedBlockingQueue<>();
// 生成事件的线程
CustomEventType event = new CustomEventType("Some data");
eventQueue.add(event);
// 处理事件的线程
CustomEventType processedEvent = eventQueue.take();
CustomEventHandler handler = new DefaultCustomEventHandler();
handler.handle(processedEvent);

面试题：Java NIO Selector自定义事件处理逻辑与框架整合

知识考点

面试题答案