当前位置：首页 > news >正文

Springboot+Netty+WebSocket搭建简单的消息通知

news 2025/7/3 15:42:55

搭建基于Spring Boot、Netty和WebSocket的简单消息通知系统需要以下步骤：

创建Spring Boot项目： 使用Spring Initializer或手动创建一个Spring Boot项目。

添加依赖： 在 pom.xml中添加WebSocket和Netty的依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
</dependency>

WebSocket配置： 创建一个WebSocket配置类，用于配置WebSocket处理程序。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

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

    @Bean
    public WebSocketHandler myWebSocketHandler() {
        return new MyWebSocketHandler();
    }
}

WebSocket处理程序： 创建一个WebSocket处理程序，处理WebSocket连接和消息。

public class MyWebSocketHandler extends TextWebSocketHandler {

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        // 处理收到的消息
        String payload = message.getPayload();
        // 可以将消息广播给所有连接的客户端
        // 或根据业务逻辑处理消息
    }

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        // 新连接建立时执行
        // 可以在这里保存会话对象以进行后续消息推送
    }
}

Controller： 创建一个Spring MVC控制器，用于处理HTTP请求。

@RestController
public class NotificationController {

    @Autowired
    private MyWebSocketHandler webSocketHandler;

    @RequestMapping("/send")
    public String sendNotification(@RequestParam String message) {
        // 处理HTTP请求，向WebSocket客户端发送消息
        webSocketHandler.sendMessageToAll(message);
        return "Message sent to WebSocket clients: " + message;
    }
}

启动类： 编写Spring Boot启动类，并运行项目。

@SpringBootApplication
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

前端页面： 创建一个前端页面，使用JavaScript或其他前端技术与WebSocket建立连接并处理消息。

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Example</title>
</head>
<body>
    <script>
        var socket = new WebSocket("ws://localhost:8080/websocket");
        socket.onmessage = function(event) {
            // 处理从服务器接收到的消息
            var message = event.data;
            // 在页面上显示消息
            console.log("Received message: " + message);
        };
    </script>
</body>
</html>