Java Core

Servidor Java

Server.java

//package com.socketio4j.examples.core;

import com.socketio4j.socketio.Configuration;
import com.socketio4j.socketio.SocketIOServer;
import com.socketio4j.socketio.SocketIOClient;

public final class BasicServer {

    private static final Logger log = LoggerFactory.getLogger(BasicServer.class);


    public static void main(String[] args) {

        Configuration config = new Configuration();
        config.setHostname("0.0.0.0");
        config.setPort(9092);
        config.setAckMode(AckMode.MANUAL);

        SocketIOServer server = new SocketIOServer(config);

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

            // Unirse a la sala vía parámetro de consulta: ?room=room1
            String room = client.getHandshakeData()
                    .getSingleUrlParam("room");

            if (room != null) {
                client.joinRoom(room);
                log.info("Unido a la sala: {}", room);
            }
        });

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

        server.addEventListener(
                "message",
                String.class,
                (SocketIOClient client, String data, var ack) -> {

                    log.info("Recibido: {}", data);

                    // Transmitir a todos los clientes
                    server.getBroadcastOperations()
                          .sendEvent("message", data);

                    ack.sendAckData("ok");
                }
        );

        server.start();
        log.info("Servidor SocketIO4J iniciado en :9092");

    }
}

Ejemplos de clientes

Java

Client.java

//package com.socketio4j.examples.core;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.socketio4j.socketio.Configuration;
import com.socketio4j.socketio.SocketIOServer;
import com.socketio4j.socketio.SocketIOClient;

public final class BasicServer {
    
    private static final Logger log = LoggerFactory.getLogger(BasicServer.class);
    
    public static void main(String[] args) {

        Configuration config = new Configuration();
        config.setHostname("0.0.0.0");
        config.setPort(9092);
        config.setAckMode(AckMode.MANUAL);
        
        SocketIOServer server = new SocketIOServer(config);

        server.addConnectListener(client -> {
            log.info("Conectado: " + client.getSessionId());

            // Unirse a la sala vía parámetro de consulta: ?room=room1
            String room = client.getHandshakeData()
                    .getSingleUrlParam("room");

            if (room != null) {
                client.joinRoom(room);
                log.info("Unido a la sala: " + room);
            }
        });

        server.addDisconnectListener(client ->
                log.info("Desconectado: " + client.getSessionId())
        );

        server.addEventListener(
                "message",
                String.class,
                (SocketIOClient client, String data, var ack) -> {

                    log.info("Recibido: " + data);

                    // Transmitir a todos los clientes
                    server.getBroadcastOperations()
                          .sendEvent("message", data);

                    ack.sendAckData("ok");
                }
        );

        server.start();
        log.info("Servidor SocketIO4J iniciado en :9092");
        
        // Mantener la JVM activa
        Thread.currentThread().join();
    }
}

Node.js

Html