springboot整合netty-socketio

Spring Boot是一个非常流行的Java开发框架，而Netty-socketio是一个基于Netty框架的WebSocket实现，提供了方便的实时通信解决方案。将它们结合起来，可以实现高效的WebSocket通信服务。

下面是整合的步骤：

1. 添加依赖

在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>com.corundumstudio.socketio</groupId>
    <artifactId>netty-socketio</artifactId>
    <version>1.7.16</version>
</dependency>

2. 编写Netty-socketio服务

创建一个类，继承自SpringBoot的ApplicationListener接口，用于启动Netty-socketio服务。

import com.corundumstudio.socketio.Configuration;
import com.corundumstudio.socketio.SocketIOServer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

@Component
public class NettySocketIoServer implements ApplicationListener<ApplicationReadyEvent> {

    @Value("${socketio.host}")
    private String host;

    @Value("${socketio.port}")
    private Integer port;

    private SocketIOServer server;

    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
        Configuration config = new Configuration();
        config.setHostname(host);
        config.setPort(port);

        server = new SocketIOServer(config);
        server.start();
    }
}

其中，@Value注解用于从配置文件中读取host和port的值，SocketIOServer是Netty-socketio提供的服务类，用于启动和管理WebSocket服务。

3. 配置WebSocket处理器

创建一个类，继承自Spring Boot的WebSocketHandler接口，用于处理WebSocket连接和消息。

import com.corundumstudio.socketio.SocketIOClient;
import com.corundumstudio.socketio.SocketIOServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;

@Component
public class SocketIoHandler extends TextWebSocketHandler {

    @Autowired
    private SocketIOServer server;

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        super.afterConnectionEstablished(session);

        SocketIOClient client = server.getClient(session.getId());
        if (client == null) {
            client = server.addClient(session);
        }
    }

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        super.handleTextMessage(session, message);

        SocketIOClient client = server.getClient(session.getId());
        if (client != null) {
            client.sendEvent("message", message.getPayload());
        }
    }
}

其中，@Autowired注解用于从Spring容器中获取SocketIOServer实例，afterConnectionEstablished方法用于处理WebSocket连接建立时的逻辑，handleTextMessage方法用于处理WebSocket消息。

4. 配置WebSocket处理器映射

创建一个WebSocketHandlerRegistry类，用于配置WebSocket处理器的映射关系。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Autowired
    private SocketIoHandler socketIoHandler;

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(socketIoHandler, "/ws").setAllowedOrigins("*");
    }
}

其中，@EnableWebSocket注解用于开启WebSocket支持，registerWebSocketHandlers方法用于配置WebSocket处理器映射关系。

5. 配置application.yml

在application.yml文件中添加以下配置：

socketio:
  host: localhost
  port: 8080

其中，host和port的值应与Netty-socketio服务的配置一致。

6. 运行程序

现在，可以运行程序，并访问http://localhost:8080/ws，即可建立WebSocket连接。发送消息时，可以使用socket.emit()方法，接收消息时，可以使用socket.on()方法。