From 013c5f28422defd9b47abbe17a827be693872a26 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期四, 04 一月 2024 14:39:26 +0800
Subject: [PATCH] 调整优化正来电子粮情协议
---
src/main/java/com/fzzy/protocol/zldz/server/SessionListener.java | 33 +++++++++++++++++++--------------
1 files changed, 19 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/zldz/server/SessionListener.java b/src/main/java/com/fzzy/protocol/zldz/server/SessionListener.java
index edb2881..43d283f 100644
--- a/src/main/java/com/fzzy/protocol/zldz/server/SessionListener.java
+++ b/src/main/java/com/fzzy/protocol/zldz/server/SessionListener.java
@@ -35,21 +35,25 @@
Constant.updateCacheOnline(session.getAddress(), session.getPort());
- /***********************璁惧涓婄嚎鍚庝富鍔ㄨ幏鍙栭厤缃俊鎭�******************/
+ try {
+ /***********************璁惧涓婄嚎鍚庝富鍔ㄨ幏鍙栭厤缃俊鎭�******************/
- BaseRequest request = new BaseRequest();
- request.setIp(session.getAddress());
- request.setPort(session.getPort());
- request.setCompanyId(ZldzServerUtil.DEFAULT_COMPANY);
- // Step1 鐢熸垚鍦ㄧ嚎娴嬭瘯鍛戒护
- Message message = OnLineCommandBuilder.getInstance().buildMessage(request);
- // 鍙戦�佸懡浠�
- InvokeResult result = session.invoke(message.getByteMsg());
- //濡傛灉鍛戒护鍙戦�佸け璐ワ紝鐩存帴韪㈡帀杩炴帴
- if (!InvokeResult.SUCCESS.getCode().equals(result.getCode())) {
- session.destroy();
+ BaseRequest request = new BaseRequest();
+ request.setIp(session.getAddress());
+ request.setPort(session.getPort());
+ request.setCompanyId(ZldzServerUtil.DEFAULT_COMPANY);
+ // Step1 鐢熸垚鍦ㄧ嚎娴嬭瘯鍛戒护
+ Message message = OnLineCommandBuilder.getInstance().buildMessage(request);
+ // 鍙戦�佸懡浠�
+ InvokeResult result = session.invoke(message.getByteMsg());
+ //濡傛灉鍛戒护鍙戦�佸け璐ワ紝鐩存帴韪㈡帀杩炴帴
+ if (!InvokeResult.SUCCESS.getCode().equals(result.getCode())) {
+ session.destroy();
+ }
+ log.info("骞冲彴------->>鍒嗘満---璁惧涓婄嚎锛岃嚜鍔ㄥ彂閫佽澶囬厤缃俊鎭姹傚懡浠�--{}", message);
+ } catch (Exception e) {
+ log.error("骞冲彴------->>鍒嗘満---璁惧涓婄嚎锛岃嚜鍔ㄥ彂閫佽澶囬厤缃俊鎭姹傚懡浠ゅけ璐�--{}", session.getAddress());
}
- log.info("骞冲彴------->>鍒嗘満---璁惧涓婄嚎锛岃嚜鍔ㄥ彂閫佽澶囬厤缃俊鎭姹傚懡浠�--{}",message);
}
/**
@@ -69,8 +73,9 @@
if (null == gatewayDeviceService) {
gatewayDeviceService = SpringUtil.getBean(GatewayDeviceService.class);
}
-
gatewayDeviceService.OfflineByCommonDevice(commonDevice);
+ //韪㈠嚭杩炴帴
+ session.destroy();
}
}
--
Gitblit v1.9.3