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】 bug fix

Browse Source
This commit is contained in:
wujiawei 2025-04-06 21:24:12 +08:00
parent fe8a2c865a
commit 9b44a199be
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/proxy/http/filter/NettyHttpClientProxyServerRealFilter.java
View File

@ -10,15 +10,15 @@ import lombok.extern.slf4j.Slf4j;
import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder; import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder; import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder;
import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer; import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;
import org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.http.NettyHttpClientProxyServerTransfer; import org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.http.NettyHttpClientProxyClientTransfer;
import org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.http.handler.NettyHttpClientProxyServerRealHandler; import org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.http.handler.NettyHttpClientProxyServerRealHandler;
@Slf4j @Slf4j
public class NettyHttpClientProxyServerRealFilter extends DebugChannelInitializer<SocketChannel> { public class NettyHttpClientProxyServerRealFilter extends DebugChannelInitializer<SocketChannel> {
private final NettyHttpClientProxyServerTransfer nettyHttpClientProxyServerTransfer; private final NettyHttpClientProxyClientTransfer nettyHttpClientProxyClientTransfer;
public NettyHttpClientProxyServerRealFilter(NettyHttpClientProxyServerTransfer nettyHttpClientProxyServerTransfer) { public NettyHttpClientProxyServerRealFilter(NettyHttpClientProxyClientTransfer nettyHttpClientProxyClientTransfer) {
this.nettyHttpClientProxyServerTransfer = nettyHttpClientProxyServerTransfer; this.nettyHttpClientProxyClientTransfer = nettyHttpClientProxyClientTransfer;
} }
/** /**
@ -30,11 +30,11 @@ public class NettyHttpClientProxyServerRealFilter extends DebugChannelInitialize
@Override @Override
protected void initChannel0(SocketChannel ch) { protected void initChannel0(SocketChannel ch) {
ChannelPipeline pipeline = ch.pipeline(); ChannelPipeline pipeline = ch.pipeline();
Boolean isSsl = nettyHttpClientProxyServerTransfer.isSsl(); Boolean isSsl = nettyHttpClientProxyClientTransfer.isSsl();
if(isSsl!=null && isSsl) { if(isSsl!=null && isSsl) {
log.info("init channel0 ssl"); log.info("init channel0 ssl");
String targetIp = nettyHttpClientProxyServerTransfer.getTargetIp(); String targetIp = nettyHttpClientProxyClientTransfer.getTargetIp();
Integer targetPort = nettyHttpClientProxyServerTransfer.getTargetPort(); Integer targetPort = nettyHttpClientProxyClientTransfer.getTargetPort();
// 适配https // 适配https
try { try {
SslContext sslContext = SslContextBuilder.forClient() SslContext sslContext = SslContextBuilder.forClient()