实现消息通知：使用Spring Boot、Netty和WebSocket搭建简单的实时通信系统-连界优站

在现代Web应用程序中，实时消息通知变得越来越重要，因为用户期望能够即时地收到更新和通知。使用Spring Boot、Netty和WebSocket，您可以搭建一个简单而高效的实时通信系统，为您的应用程序添加实时消息功能。本文将介绍如何使用这些技术来实现一个基本的消息通知系统。

1. 环境准备：

确保您已经安装了Java和Maven。在开始之前，您需要创建一个Spring Boot项目并添加必要的依赖。可以使用Spring Initializr来快速生成一个新的Spring Boot项目，然后添加以下依赖：

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

2. 创建WebSocket配置：

在您的Spring Boot应用程序中，创建一个WebSocket配置类，用于配置WebSocket的处理器和端点。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

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

3. 编写WebSocket处理器：

创建一个WebSocket处理器，用于处理WebSocket连接和消息。

@Component
public class WebSocketHandler extends TextWebSocketHandler {

    private final Set<WebSocketSession> sessions = Collections.synchronizedSet(new HashSet<>());

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        for (WebSocketSession webSocketSession : sessions) {
            if (webSocketSession.isOpen()) {
                webSocketSession.sendMessage(message);
            }
        }
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session);
    }
}

4. 创建前端页面：

在前端创建一个HTML页面，使用WebSocket来连接服务器并接收消息。

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Chat</title>
</head>
<body>
    <div id="output"></div>

    <script>
        var socket = new WebSocket("ws://localhost:8080/ws");
        socket.onmessage = function(event) {
            var output = document.getElementById("output");
            output.innerHTML += "<p>" + event.data + "</p>";
        };
    </script>
</body>
</html>