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/BhznGrainV0MessageConsumer.java | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0MessageConsumer.java b/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0MessageConsumer.java
index 84cee99..b359838 100644
--- a/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0MessageConsumer.java
+++ b/src/main/java/com/fzzy/protocol/bhzn/v0/server/BhznGrainV0MessageConsumer.java
@@ -1,6 +1,7 @@
package com.fzzy.protocol.bhzn.v0.server;
import com.fzzy.api.utils.BytesUtil;
+import com.fzzy.api.utils.SpringUtil;
import com.fzzy.protocol.bhzn.v0.analysis.AnalysisService;
import com.fzzy.protocol.bhzn.v0.cmd.ReMessageBuilder;
import com.fzzy.protocol.bhzn.v0.data.IoMessage;
@@ -38,7 +39,7 @@
BhznGrainV0ServerUtils.addHeartBeat(ioSession);
//榛樿璁剧疆涓婚�氳鏈嶅姟
- //BhznGrainV2ServerUtils.addSession(ioSession);
+ BhznGrainV0ServerUtils.addSession(ioSession);
try {
String hexStr = BytesUtil.bytesToString(bytes);
@@ -48,7 +49,7 @@
IoMessage ioMessage = ReMessageBuilder.getInstance().buildMessage(hexStr);
ioMessage.setIp(ioSession.getAddress());
ioMessage.setPort(ioSession.getPort());
-
+ analysisService = SpringUtil.getBean(AnalysisService.class);
analysisService.analysis(ioSession.getBusinessKey(), ioMessage);
} catch (Exception e) {
log.error(e.getMessage(), e);
--
Gitblit v1.9.3