Quarkus

application.properties

netty-socket-io.hostname=localhost
netty-socket-io.port=9092
netty-socket-io.ping-timeout=60000
netty-socket-io.ping-interval=25000

application.yml

Hauptanwendung

@ApplicationScoped
public class QuarkusMainApplication {
    
    @Inject
    SocketIOServer server;
    
    void onStart(@Observes StartupEvent ev) {
        // Ereignis-Listener hinzufügen
        server.addEventListener("chatevent", ChatMessage.class, (client, data, ackRequest) -> {
            server.getBroadcastOperations().sendEvent("chatevent", data);
        });
        
        server.start();
        log.info("Socket.IO-Server gestartet auf Port {}", server.getConfiguration().getPort());
    }
    
    void onStop(@Observes ShutdownEvent ev) {
        server.stop();
    }
}

Ereignis-Handler

@ApplicationScoped
public class ChatEventHandler {
    
    @Inject
    SocketIOServer server;
    
    @OnConnect
    public void onConnect(SocketIOClient client) {
        log.info("Client verbunden: {}", client.getSessionId());
    }
    
    @OnEvent("chatevent")
    public void onChatEvent(SocketIOClient client, ChatMessage data) {
        server.getBroadcastOperations().sendEvent("chatevent", data);
    }
}

Vollständiges Beispiel

Siehe das komplette Beispiel im netty-socketio-examples-quarkus-base Modul.