小明：最近我们学院的系统有点分散，学生和老师的消息通知也不太统一，你有什么建议吗？

小李：我觉得可以考虑引入一个“综合信息门户”，把各个系统的消息整合起来，形成“统一消息”平台。

小明：那具体怎么实现呢？有没有技术方案？

小李：我们可以用Spring Boot搭建后端服务，结合WebSocket实现实时推送。前端可以用Vue.js来展示消息。

小明：能给我看看代码吗？

小李：当然可以。这是后端的WebSocket配置类：

package com.example.portal.config;

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.handler.TextWebSocketHandler;

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

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

小李：这是消息处理器类：

package com.example.portal.handler;

import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;

import java.util.concurrent.CopyOnWriteArrayList;

public class MessageWebSocketHandler extends TextWebSocketHandler {

    private final CopyOnWriteArrayList sessions = new CopyOnWriteArrayList<>();

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

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) {
        String content = message.getPayload();
        for (WebSocketSession s : sessions) {
            try {
                s.sendMessage(new TextMessage(content));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

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

小明：明白了，这样就能在综合信息门户中统一接收学院系统的消息了。

小李：没错，这就是“统一消息”的核心思想。