Spring Boot

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

Das einfache Hinzufügen der properties/yml reicht aus, um den Server mit den Standardeinstellungen auszuführen. Wenn Sie eine SocketIOServer-Bean hinzufügen möchten, schließen Sie den Standardserver aus

Benutzerdefinierte SocketIOServer-Bean

@Configuration
public class SocketIOConfig {
    
    @Bean
    public SocketIOServer socketIOServer() {
        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(9092);
        return new SocketIOServer(config);
    }
}

Hauptanwendung

@SpringBootApplication
public class SpringBootMainApplication implements CommandLineRunner {
    
    private static final Logger log = LoggerFactory.getLogger(SpringBootMainApplication.class);
    
    @Autowired
    private SocketIOServer server;
    
    public static void main(String[] args) {
        SpringApplication.run(SpringBootMainApplication.class, args);
    }
    
    @Override
    public void run(String... args) throws Exception {
        // 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());
    }
}

Ereignis-Handler mit Annotationen

Sie können Annotationen verwenden, um Ereignis-Handler zu definieren:

@Component
public class ChatEventHandler {
    
    @Autowired
    private SocketIOServer server;
    
    @OnConnect
    public void onConnect(SocketIOClient client) {
        log.info("Client verbunden: {}", client.getSessionId());
    }
    
    @OnDisconnect
    public void onDisconnect(SocketIOClient client) {
        log.info("Client getrennt: {}", client.getSessionId());
    }
    
    @OnEvent("chatevent")
    public void onChatEvent(SocketIOClient client, ChatMessage data, AckRequest ackRequest) {
        server.getBroadcastOperations().sendEvent("chatevent", data);
    }
}

Fehlerbehandlung

@Configuration
public class CustomizedSocketIOConfiguration {
    
    @Bean
    public ExceptionListener exceptionListener() {
        return new ExceptionListener() {
            @Override
            public void onEventException(Exception e, List<Object> args, SocketIOClient client) {
                log.error("Ereignis-Ausnahme", e);
            }
            
            @Override
            public void onDisconnectException(Exception e, SocketIOClient client) {
                log.error("Trennungs-Ausnahme", e);
            }
            
            // ... andere Methoden implementieren
        };
    }
}

Vollständiges Beispiel

Siehe das vollständige Beispiel in der netty-socketio-examples-spring-boot-base Modul.