springboot集成socket.io

Spring Boot 集成 Socket.IO 是将实时通信功能融入到 Spring Boot 应用程序中的一种常见做法，通常用于构建WebSocket应用，如聊天系统、在线协作工具等。以下是一般的步骤：

1. 添加依赖：首先，在你的`pom.xml`或`build.gradle`文件中添加Socket.IO客户端库（例如`socket.io-client-java`）和相关的Spring WebFlux依赖。

<!-- Maven -->
<dependency>
    <groupId>io.socket</groupId>
    <artifactId>socket.io-client-java</artifactId>
    <version>1.4.0</version>
</dependency>

<!-- Gradle (example) -->
implementation 'io.socket:socket.io-client-java:1.4.0'

2. 创建WebSocket服务：在Spring Boot应用中，创建一个WebSocketHandler，它会负责处理来自客户端的消息和连接管理。

import io.socket.IOAcknowledge;
import io.socket.SocketIOClient;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

@Component
public class SocketIoHandler {

    @MessageMapping("/message")
    @SendTo("/topic/messages")
    public String handleMessage(String message, IOAcknowledge acknowledge) {
        // ...处理消息逻辑...
        return "Message received";
    }
}

3. 启动WebSocket服务器：在Spring Boot配置类中启用WebSocket支持，并绑定Socket.IO服务到特定端口。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/socket.io").withSockJS();
    }
}

4. 客户端连接：使用JavaScript的Socket.IO库连接到服务器提供的URL，比如`ws://localhost:8080/socket.io`，并开始发送和接收消息。

var socket = io('ws://localhost:8080/socket.io');
socket.emit('message', 'Hello from client');
socket.on('message', function(data) {
    console.log('Received:', data);
});