大屏展示，消息推送部分优化

liurunyu

2025-03-03 584989385e05b8ad887431da2ab7da1e93e1ffaa

大屏展示，消息推送部分优化

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/largeScreen/WebSocketHeartBeat.java

@@ -18,7 +18,7 @@
    // 设置定时十秒一次
    @Scheduled(cron = "0/10 * * * * ?")
    public void WsHeartBeat() throws Exception {
        WebSocketServer.sendAllMessage(getHeartBeatMessage());
        WebSocketServer.sendMessage2AllClient(getHeartBeatMessage());
    }

    public static String getHeartBeatMessage() {

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/largeScreen/WebSocketServer.java

@@ -103,7 +103,7 @@
    /**
     * 服务器主动群推送消息
     */
    public static void sendAllMessage(String message) throws IOException {
    public static void sendMessage2AllClient(String message) throws IOException {
        ConcurrentHashMap.KeySetView<String, WebSocketServer> ids = webSocketMap.keySet();
        for (String id : ids) {
            WebSocketServer webSocketServer = webSocketMap.get(id);
@@ -114,7 +114,7 @@
    /**
     * 服务器指定客户端推送消息
     */
    public static void sendOneMessage(String message, String id) throws IOException {
    public static void sendMessage2OneClient(String message, String id) throws IOException {
        if (message != null && message.length() != 0 && webSocketMap.containsKey(id)) {
            webSocketMap.get(id).sendMessage(message);
        } else {

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/msCenter/CenterMsReceiveCtrl.java

@@ -83,7 +83,7 @@
        vo.type = WebSocketMessage.TYPE_JSON ;
        vo.content = list ;
        try {
            WebSocketServer.sendAllMessage(JSON.toJSONString(vo));
            WebSocketServer.sendMessage2AllClient(JSON.toJSONString(vo));
        }catch (Exception e){
            log.error("推送消息失败", e) ;
        }