Instancia del servidor

Creando un servidor

Para iniciar un servidor Socket.IO, crea un Configuración, establece la dirección de enlace y el puerto, y luego inicia el servidor.

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

SocketIOServer server = new SocketIOServer(config);

Al usar frameworks como Spring Boot, asegúrate de importar com.socketio4j.socketio.Configuration y no clases del framework con el mismo nombre (por ejemplo, org.springframework.context.annotation.Configuration), para evitar conflictos de importación.

Iniciando el servidor

Sincrónico

server.start()

Asincrónico

Deteniendo el servidor

Siempre detén el servidor de forma ordenada durante el apagado.

server.stop();

socketio4j agrega un hook de apagado después de que el servidor se inicia; detiene el servidor de forma ordenada en ciertos escenarios, no en todos. Siempre se recomienda detener el servidor explícitamente.

Ejemplo completo

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 {
        // Crear configuración
        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(9092);

        // Crear servidor
        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) -> {
            //escuchar "reply" en el cliente
            log.info("received data : " + data);
            client.sendEvent("reply", "hello");
        });
        // Iniciar servidor
        server.start();
        log.info("Socket.IO server started on port 9092");

        // Mantener la JVM viva
        Thread.currentThread().join();
    }
}

Comprobar Eventos para la documentación relacionada con el manejo de eventos

Notas

• hostname es opcional. Si no se establece, el servidor se enlaza a todas las interfaces (0.0.0.0 / ::0).

• puerto debe establecerse antes de iniciar el servidor.

• El subproceso, los transportes y otras opciones avanzadas pueden personalizarse mediante Configuración antes de llamar a start().