【fix】log

This commit is contained in:
wujiawei 2024-09-21 01:45:19 +08:00
parent 37bce25f31
commit b1bd674ada
4 changed files with 10 additions and 2 deletions

View File

@ -1,6 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.netty.advanced; package org.framework.lazy.cloud.network.heartbeat.server.netty.advanced;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.*; import org.framework.lazy.cloud.network.heartbeat.common.*;
import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -8,6 +9,7 @@ import org.springframework.stereotype.Component;
/** /**
* 上报 客户端渗透客户端数据传输通道连接成功 * 上报 客户端渗透客户端数据传输通道连接成功
*/ */
@Slf4j
@Component @Component
public class ServerHandleReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> { public class ServerHandleReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {
/** /**
@ -37,6 +39,8 @@ public class ServerHandleReportClientTransferClientPermeateChannelConnectionSucc
clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL);
if (clientChannel != null) { if (clientChannel != null) {
clientChannel.getChannel().writeAndFlush(clientConnectTagetNettyProxyMsg); clientChannel.getChannel().writeAndFlush(clientConnectTagetNettyProxyMsg);
}else {
log.error("can not find the client:【】 channel",clientId);
} }

View File

@ -50,7 +50,7 @@ public class ServerHandleReportClientTransferClientPermeateChannelInitSuccessful
if (nextChannel != null) { if (nextChannel != null) {
nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg);
}else { }else {
log.error("error"); log.error("can not find the client:【】 channel",clientId);
} }

View File

@ -1,6 +1,7 @@
package org.framework.lazy.cloud.network.heartbeat.server.netty.advanced; package org.framework.lazy.cloud.network.heartbeat.server.netty.advanced;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.MessageType; import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced;
@ -11,6 +12,7 @@ import org.springframework.stereotype.Component;
/** /**
* 上报客户端渗透客户端数据传输结果 * 上报客户端渗透客户端数据传输结果
*/ */
@Slf4j
@Component @Component
public class ServerHandleReportClientTransferClientResponseTypeAdvanced extends AbstractHandleReportClientTransferClientResponseTypeAdvanced<NettyProxyMsg> { public class ServerHandleReportClientTransferClientResponseTypeAdvanced extends AbstractHandleReportClientTransferClientResponseTypeAdvanced<NettyProxyMsg> {
/** /**
@ -41,6 +43,8 @@ public class ServerHandleReportClientTransferClientResponseTypeAdvanced extends
clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_RESPONSE); clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_RESPONSE);
if (nextChannel != null) { if (nextChannel != null) {
nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg);
}else {
log.error("can not find the client:【】 channel",clientId);
} }

View File

@ -43,7 +43,7 @@ public class ServerHandleReportClientTransferClientTypeAdvanced extends Abstract
if (nextChannel != null) { if (nextChannel != null) {
nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg);
}else { }else {
log.error("eeeee"); log.error("can not find the client:【】 channel",clientId);
} }