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(); } } }