alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-06 21:37:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] 通道数据添加appKey、appSecret、originalIp验证

Browse Source
This commit is contained in:
wujiawei 2024-10-28 14:24:16 +08:00
parent b7d571ccc1
commit b2cd1eee0a
8 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java
View File

@ -156,7 +156,7 @@ public class NettyClientPermeateClientRealSocket {
} else { } else {
log.info("无法连接到服务端...."); log.info("无法连接到服务端....");
transferChannel.eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
try { try {
newVisitorConnect2Server(clientId, newVisitorConnect2Server(clientId,
clientTargetIp, clientTargetIp,

2
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorTransferSocket.java
View File

@ -91,7 +91,7 @@ public class NettyClientPermeateClientVisitorTransferSocket {
} else { } else {
log.info("无法连接到服务端...."); log.info("无法连接到服务端....");
transferChannel.eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
try { try {
buildTransferServer(internalNetworkClientPermeateClientVisitor,visitorChannel); buildTransferServer(internalNetworkClientPermeateClientVisitor,visitorChannel);
} catch (Exception e) { } catch (Exception e) {

2
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorTransferSocket.java
View File

@ -87,7 +87,7 @@ public class NettyClientPermeateServerVisitorTransferSocket {
} else { } else {
log.warn("客户端渗透服务端通信通道中断...."); log.warn("客户端渗透服务端通信通道中断....");
transferChannel.eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
try { try {
buildTransferServer(internalNetworkClientPermeateServerVisitor, visitorChannel); buildTransferServer(internalNetworkClientPermeateServerVisitor, visitorChannel);
} catch (Exception e) { } catch (Exception e) {

2
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientSocket.java
View File

@ -119,7 +119,7 @@ public class NettyClientSocket {
// 离线 // 离线
NettyServerContext.removeServerEndpointChannels(serverId, clientId); NettyServerContext.removeServerEndpointChannels(serverId, clientId);
clientChangeEvent.clientOffLine(inetHost, inetPort,serverId, clientId); clientChangeEvent.clientOffLine(inetHost, inetPort,serverId, clientId);
futureListener.channel().eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
try { try {
newConnect2Server(inetHost, inetPort, clientId, serverId, clientChangeEvent); newConnect2Server(inetHost, inetPort, clientId, serverId, clientChangeEvent);
} catch (InterruptedException e) { } catch (InterruptedException e) {

2
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyServerPermeateClientRealSocket.java
View File

@ -201,7 +201,7 @@ public class NettyServerPermeateClientRealSocket {
} else { } else {
log.info("每隔2s重连...."); log.info("每隔2s重连....");
// 离线 // 离线
transferChannel.eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
try { try {
newVisitorConnect2Server(internalNetworkPenetrationRealClient, nettyClientProperties, handleChannelTypeAdvancedList,realChannel); newVisitorConnect2Server(internalNetworkPenetrationRealClient, nettyClientProperties, handleChannelTypeAdvancedList,realChannel);
} catch (InterruptedException e) { } catch (InterruptedException e) {

2
wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java
View File

@ -2,6 +2,7 @@ package org.framework.lazy.cloud.network.heartbeat.common;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.ArrayList; import java.util.ArrayList;
@ -36,6 +37,7 @@ public class ChannelContext {
if(existChannel.isActive()){ if(existChannel.isActive()){
existChannelList.add(existChannel); existChannelList.add(existChannel);
}else { }else {
log.warn("close channel with client:{}", ChannelAttributeKeyUtils.getClientId(existChannel));
existChannel.close(); existChannel.close();
} }
} }

2
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyClientPermeateServerConnectRealSocket.java
View File

@ -71,7 +71,7 @@ public class NettyClientPermeateServerConnectRealSocket {
} else { } else {
log.error("服务端内网渗透 无法连接当前网络内的目标IP：【{}】,目标端口:【{}】", targetIp, targetPort); log.error("服务端内网渗透 无法连接当前网络内的目标IP：【{}】,目标端口:【{}】", targetIp, targetPort);
channelFuture.channel().eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
buildNewRealServer(visitorId, visitorPort, targetIp, targetPort, transferChannel); buildNewRealServer(visitorId, visitorPort, targetIp, targetPort, transferChannel);
}, 2, TimeUnit.SECONDS); }, 2, TimeUnit.SECONDS);
} }

2
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectRealSocket.java
View File

@ -76,7 +76,7 @@ public class NettyServerPermeateServerConnectRealSocket {
} else { } else {
log.error("服务端内网渗透 无法连接当前网络内的目标IP：【{}】,目标端口:【{}】", clientTargetIp, clientTargetPort); log.error("服务端内网渗透 无法连接当前网络内的目标IP：【{}】,目标端口:【{}】", clientTargetIp, clientTargetPort);
channelFuture.channel().eventLoop().schedule(() -> { eventLoopGroup.schedule(() -> {
buildNewRealServer(internalNetworkServerPermeateServerRealServer, visitorChannel, visitorId); buildNewRealServer(internalNetworkServerPermeateServerRealServer, visitorChannel, visitorId);
}, 2, TimeUnit.SECONDS); }, 2, TimeUnit.SECONDS);
} }