服务器实例

创建服务器

要启动 Socket.IO 服务器，请创建一个 配置，设置绑定地址和端口，然后启动服务器。

Configuration config = new Configuration();
config.setHostname("localhost");
config.setPort(9092);

SocketIOServer server = new SocketIOServer(config);

使用诸如此类框架时 Spring Boot，确保你导入 com.socketio4j.socketio.Configuration 而不是具有相同名称的框架类（例如， org.springframework.context.annotation.Configuration），以避免导入冲突。

启动服务器

同步

server.start()

异步

停止服务器

在关闭期间始终优雅地停止服务器。

server.stop();

socketio4j 在服务器启动后添加了关闭钩子，它会在某些场景下优雅地停止服务器，但并非所有情况。始终建议显式停止服务器。

完整示例

Server.java

import com.socketio4j.socketio.Configuration;
import com.socketio4j.socketio.SocketIOServer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SocketIoServerMain {
    
    private static final Logger log = LoggerFactory.getLogger(SocketIoServerMain.class);
    
    public static void main(String[] args) throws Exception {
        // 创建配置
        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(9092);

        // 创建服务器
        SocketIOServer server = new SocketIOServer(config);
        
        server.addConnectListener(client -> {
            log.info("[/] connected -> " + client.getSessionId());
        });
        server.addDisconnectListener(client -> {
            log.info("[/] disconnected -> " + client.getSessionId());
        });
        
        server.addEventListener("hi", String.class, (client, data, ack) -> {
            // 在客户端监听 "reply"
            log.info("received data : " + data);
            client.sendEvent("reply", "hello");
        });
        // 启动服务器
        server.start();
        log.info("Socket.IO server started on port 9092");

        // 保持 JVM 运行
        Thread.currentThread().join();
    }
}

检查 事件 有关事件处理的相关文档

注意

• 主机名 是可选的。如果未设置，服务器将绑定到所有接口（0.0.0.0 / ::0).

• 端口 必须 在启动服务器之前设置。

• 线程、传输和其他高级选项可以通过 配置 在调用之前进行自定义， start().