修改消息推送时间间隔

zhangf

2024-09-11 d4020168658efdee89a633083cd9c14b06c4d863

 src/main/java/com/gkhy/fourierSpecialGasMonitor/websocket/GasConcentrationExcWebsocketServer.java

@@ -14,9 +14,10 @@
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;

@Slf4j
@ServerEndpoint("/gas/exc/{userId}")
@ServerEndpoint("/ws/gas/exc/{userId}")
@Component
public class GasConcentrationExcWebsocketServer {

@@ -54,10 +55,10 @@
        this.userId = userId;

        webSocketMap.put(userId, this);
        log.info("webSocketMap -> " + JSON.toJSONString(webSocketMap));
        //log.info("webSocketMap -> " + JSON.toJSONString(webSocketMap));

        addOnlineCount(); // 在线数 +1
        log.info("【气体浓度异常】有新窗口开始监听:" + userId + ",当前在线人数为" + getOnlineCount());
        //log.info("【气体浓度异常】有新窗口开始监听:" + userId + ",当前在线人数为" + getOnlineCount());

        try {
            sendMessage(JSON.toJSONString("【气体浓度异常】连接成功"));
@@ -77,7 +78,7 @@
        if (webSocketMap.get(this.userId) != null) {
            webSocketMap.remove(this.userId);
            subOnlineCount(); // 人数 -1
            log.info("【气体浓度异常】有一连接关闭，当前在线人数为：" + getOnlineCount());
            //log.info("【气体浓度异常】有一连接关闭，当前在线人数为：" + getOnlineCount());
        }
    }

@@ -89,7 +90,7 @@
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("收到来自窗口" + userId + "的信息：" + message);
        //log.info("收到来自窗口" + userId + "的信息：" + message);

        if (StringUtils.isNotBlank(message)) {
            try {
@@ -117,8 +118,8 @@
     */
    @OnError
    public void onError(Session session, Throwable error) {
        log.error("用户错误：" + this.userId + "，原因：" + error.getMessage());
        error.printStackTrace();
        //log.error("用户错误：" + this.userId + "，原因：" + error.getMessage());
        //error.printStackTrace();
    }

    /**
@@ -147,10 +148,10 @@

            if (userId == null) {
                webSocketMap.get(entry.getKey()).sendMessage(message);
                log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
                //log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
            } else if (entry.getKey().equals(userId)) {
                webSocketMap.get(entry.getKey()).sendMessage(message);
                log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
                //log.info("【气体浓度异常】发送消息到：" + entry.getKey() + "，消息：" + message);
            }

        }