监听事件

netty-socketio 提供监听器以对传入事件作出反应。

内置连接事件

连接

server.addConnectListener(client -> {
    log.info("Client connected: {}", client.getSessionId());
});

在客户端每次连接时调用。

断开连接

server.addDisconnectListener(client -> {
    log.info("Client disconnected: {}", client.getSessionId());
});

自定义事件监听器

要监听自定义命名的事件：

server.addEventListener("chat", ChatMessage.class,
    (client, data, ackRequest) -> {
        log.info("Chat received: {}", data.getText());
});

• "chat"：事件名称。

• ChatMessage.class：表示负载的类。

• (client, data, ack)：处理器回调。

如果您不需要类型化的负载，请使用 Object.class 或通用类型。

确认（Acknowledgements）

如果客户端期望响应，您可以处理确认：

server.addEventListener("ask", Request.class, (client, req, ackSender) -> {
    ackSender.sendAckResponse(new Response("done"));
});

Socket.IO 协议支持双方的确认回调。