From 22e8a676ee42c0d78b3526bcd9a635abbe8dca03 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 28 六月 2022 11:28:21 +0800
Subject: [PATCH] 优化databus bug
---
service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java b/service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java
index 84d7aaf..962e3de 100644
--- a/service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java
+++ b/service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java
@@ -5,7 +5,7 @@
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import com.java110.core.log.LoggerFactory;
import org.springframework.stereotype.Component;
import javax.websocket.*;
@@ -22,7 +22,7 @@
* @Version 1.0
* add by wuxw 2020/5/25
**/
-@ServerEndpoint("/ws/parkingArea/{paId}/{clientId}")
+@ServerEndpoint("/ws/parkingArea/{boxId}/{clientId}")
@Component
public class ParkingAreaWebsocket {
@@ -50,16 +50,16 @@
*/
private String clientId = "";
- private String paId = "";
+ private String boxId = "";
/**
* 杩炴帴寤虹珛鎴愬姛璋冪敤鐨勬柟娉�
*/
@OnOpen
- public void onOpen(Session session, @PathParam("clientId") String clientId, @PathParam("paId") String paId) {
+ public void onOpen(Session session, @PathParam("clientId") String clientId, @PathParam("boxId") String boxId) {
this.session = session;
this.clientId = clientId;
- this.paId = paId;
+ this.boxId = boxId;
if (webSocketMap.containsKey(clientId)) {
webSocketMap.remove(clientId);
webSocketMap.put(clientId, this);
@@ -101,7 +101,7 @@
*/
@OnMessage
public void onMessage(String message, Session session) throws Exception {
- logger.info("鐢ㄦ埛娑堟伅:" + paId + ",瀹㈡埛绔細" + clientId + ",鎶ユ枃:" + message);
+ logger.info("鐢ㄦ埛娑堟伅:" + boxId + ",瀹㈡埛绔細" + clientId + ",鎶ユ枃:" + message);
//鍙互缇ゅ彂娑堟伅
//娑堟伅淇濆瓨鍒版暟鎹簱銆乺edis
if (StringUtil.isEmpty(message)) {
@@ -146,10 +146,10 @@
/**
* 鍙戦�佽澶囩洃鎺т俊鎭�
*/
- public static void sendInfo(String message, String paId) throws IOException {
- logger.info("鍙戦�佹秷鎭埌:" + paId + "锛屾姤鏂�:" + message);
+ public static void sendInfo(String message, String boxId) throws IOException {
+ logger.info("鍙戦�佹秷鎭埌:" + boxId + "锛屾姤鏂�:" + message);
for (ParkingAreaWebsocket server : webSocketMap.values()) {
- if (paId.equals(server.paId)) {
+ if (boxId.equals(server.boxId)) {
webSocketMap.get(server.clientId).sendMessage(message);
}
}
--
Gitblit v1.8.0