From 8950c0ce3ce2c629ae569b95c8c4b17a08d544a5 Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Fri, 26 Dec 2025 18:31:27 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0nett=E4=BC=A0=E8=BE=93?= =?UTF-8?q?=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/rockermq/listener/AgentConsumerDownListener.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java index 3674d32..8df8d8d 100644 --- a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java +++ b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java @@ -2,6 +2,7 @@ package com.tongran.agent.server.rockermq.listener; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson2.JSON; +import com.tongran.agent.server.core.enums.MsgEnum; import com.tongran.agent.server.core.session.SessionManager; import com.tongran.agent.server.netty.annotation.AgentDispatcher; import com.tongran.agent.server.netty.basics.AgentDispatcherManager; @@ -39,6 +40,8 @@ public class AgentConsumerDownListener implements RocketMQListener { if (ObjectUtil.isNotEmpty(msgHandler)) { String msg = msgHandler.downHandle(dto.getData(), dto.getClientId()); Message chargeMessage = Message.builder().clientId(dto.getClientId()).dataType(dto.getDataType()).data(msg).build(); + AssertLog.info("连接是否存在：{},clientId:{},session:{}", + Objects.nonNull(sessionManager.getSessionById(dto.getClientId())), dto.getClientId(), sessionManager.getSessionById(dto.getClientId())); if (Objects.nonNull(sessionManager.getSessionById(dto.getClientId()))) { sessionManager.writeAndFlush(sessionManager.getSessionById(dto.getClientId()).getChannel(), chargeMessage); }