From facc0ea3fa37091a98aa1e0a0d1081fd32fba28e Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期六, 27 一月 2024 11:38:29 +0800
Subject: [PATCH] 优化协议
---
src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0ServerUtils.java | 17 +++++++++++++----
1 files changed, 13 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0ServerUtils.java b/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0ServerUtils.java
index ebd0b3e..ec8341a 100644
--- a/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0ServerUtils.java
+++ b/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0ServerUtils.java
@@ -2,7 +2,7 @@
import com.fzzy.api.utils.BytesUtil;
-import com.fzzy.protocol.bhzn.server.BhznGrainV2ServerUtils;
+import com.fzzy.gateway.entity.GatewayDevice;
import com.ld.io.api.IoSession;
import java.util.HashMap;
@@ -20,15 +20,16 @@
* 璁板綍姣忎釜杩炴帴鐨勬渶鍚庝竴娆′俊鎭椂闂� key = 杩炴帴鐨凨YE锛宒ata =褰撳墠鏃堕棿鎴�
*/
public static Map<String, Long> contextMapHeart = new HashMap<>();
+ public static Map<String, IoSession> contextIoSession = new HashMap<>();
-
+ public static GatewayDevice contextOrder = new GatewayDevice();
public static int HEART_BEAT_TIME = 30;//蹇冭烦闂撮殧鏃堕棿
public static String MSG_START = "3C42485A4E3E";//<BHZN>
public static String MSG_START2 = "AA";
public static String MSG_END = "<END>";//<END>
- public static String MSG_END_16 = "3C454E443E";//<END>
+ public static String MSG_END_16 = "3C454E443E";//<END>3C454E443E
public static final String CHARSET = "UTF-8";
@@ -78,7 +79,7 @@
* @return
*/
public static String getCheck(String content) {
- int start = BhznGrainV2ServerUtils.MSG_START.length() + BhznGrainV2ServerUtils.MSG_START2.length();
+ int start = BhznGrainV0ServerUtils.MSG_START.length() + BhznGrainV0ServerUtils.MSG_START2.length();
content = content.substring(start);
int sum = 0;
String hex;
@@ -91,4 +92,12 @@
return BytesUtil.intToHexStr(256 - check).substring(2);
}
+
+ public static void addSession(IoSession session) {
+ contextIoSession.put(DEFAULT_MAC_ID, session);
+ }
+
+ public static IoSession getSession() {
+ return contextIoSession.get(DEFAULT_MAC_ID);
+ }
}
--
Gitblit v1.9.3