From 5f92b2034f84caeab9cb6efc61ecbe22407935b4 Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期二, 16 一月 2024 12:14:03 +0800
Subject: [PATCH] 优化主库协议，支持路由
---
src/main/java/com/fzzy/protocol/zldz/server/ZldzServerEngine.java | 16 +++++++++++++++-
1 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/zldz/server/ZldzServerEngine.java b/src/main/java/com/fzzy/protocol/zldz/server/ZldzServerEngine.java
index 78e0c88..cbb4f30 100644
--- a/src/main/java/com/fzzy/protocol/zldz/server/ZldzServerEngine.java
+++ b/src/main/java/com/fzzy/protocol/zldz/server/ZldzServerEngine.java
@@ -10,7 +10,6 @@
/**
* 閰嶇疆涓绘湇鍔′俊鎭�
- *
*/
@Slf4j
public class ZldzServerEngine {
@@ -82,4 +81,19 @@
}
return session.invoke(msg);
}
+
+ public static void disconnect(String ip, Integer port) {
+ IoSessionQuery sessionFactory = ioServer.getSessionQuery();
+ List<IoSession> sessions = sessionFactory.getAllSession();
+ IoSession session = null;
+ for (IoSession ioSession : sessions) {
+ if (ServerUtils.getServerKey(ip, port).equals(ioSession.getBusinessKey())) {
+ session = ioSession;
+ break;
+ }
+ }
+ if (null != session) {
+ session.destroy();
+ }
+ }
}
--
Gitblit v1.9.3