修改websocket包位置 增加单兵端-下发给我的任务详情 增加app位置websocket推送按用户频率

‘liusuyi’

2023-07-27 4cc19e25b2a210ba4b5af46f30f28dbe4ca289fe

 ard-work/src/main/java/com/ruoyi/utils/websocket/util/WebSocketUtils.java

ÎļþÃû´Ó ruoyi-common/src/main/java/com/ruoyi/common/websocket/util/WebSocketUtils.java ÐÞ¸Ä
@@ -1,4 +1,4 @@
package com.ruoyi.common.websocket.util;
package com.ruoyi.utils.websocket.util;

import com.alibaba.fastjson2.JSONObject;
import lombok.extern.slf4j.Slf4j;
@@ -6,8 +6,10 @@
import javax.websocket.RemoteEndpoint;
import javax.websocket.Session;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.*;

/**
 * @ClassName WebSocketUtils
@@ -63,6 +65,22 @@
            }
        }
    }
    public static void sendMessage(Session session, List message) {
        if (session == null) {
            return;
        }
        final RemoteEndpoint.Basic basic = session.getBasicRemote();
        if (basic == null) {
            return;
        }
        synchronized(session) {
            try {
                session.getBasicRemote().sendText( String.join(", ", message));
            } catch (IOException e) {
                log.error("sendMessage IOException ",e);
            }
        }
    }
    /**
     * æŽ¨é€æ¶ˆæ¯åˆ°å…¶ä»–客户端
     * @param message