Agent/tr-agent-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加nett传输日志

Browse Source
This commit is contained in:
gaoyutao
2025-12-26 18:31:27 +08:00
parent 5fd0e913ae
commit 8950c0ce3c
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
+3
View File
@@ -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<String> {
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);
}