优化带啊

wuxw

2023-11-23 9b30285de6191e5fb2df447684ba2ed2c28d9db3

 service-api/src/main/java/com/java110/api/websocket/ParkingBoxWebsocket.java

@@ -101,7 +101,7 @@
     */
    @OnMessage
    public void onMessage(String message, Session session) throws Exception {
        logger.info("用户消息:" + boxId + ",客户端：" + clientId + ",报文:" + message);
        //logger.info("用户消息:" + boxId + ",客户端：" + clientId + ",报文:" + message);
        //可以群发消息
        //消息保存到数据库、redis
        if (StringUtil.isEmpty(message)) {
@@ -139,7 +139,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        //this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
    }