mirror of
https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git
synced 2025-06-06 21:37:56 +08:00
【fix】 bug fix
This commit is contained in:
parent
9b44a199be
commit
394dfdf337
@ -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.NettyHttpClientProxyClientTransfer;
|
import org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.http.NettyHttpClientProxyServerTransfer;
|
||||||
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 NettyHttpClientProxyClientTransfer nettyHttpClientProxyClientTransfer;
|
private final NettyHttpClientProxyServerTransfer nettyHttpClientProxyServerTransfer;
|
||||||
|
|
||||||
public NettyHttpClientProxyServerRealFilter(NettyHttpClientProxyClientTransfer nettyHttpClientProxyClientTransfer) {
|
public NettyHttpClientProxyServerRealFilter(NettyHttpClientProxyServerTransfer nettyHttpClientProxyServerTransfer) {
|
||||||
this.nettyHttpClientProxyClientTransfer = nettyHttpClientProxyClientTransfer;
|
this.nettyHttpClientProxyServerTransfer = nettyHttpClientProxyServerTransfer;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -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 = nettyHttpClientProxyClientTransfer.isSsl();
|
Boolean isSsl = nettyHttpClientProxyServerTransfer.isSsl();
|
||||||
if(isSsl!=null && isSsl) {
|
if(isSsl!=null && isSsl) {
|
||||||
log.info("init channel0 ssl");
|
log.info("init channel0 ssl");
|
||||||
String targetIp = nettyHttpClientProxyClientTransfer.getTargetIp();
|
String targetIp = nettyHttpClientProxyServerTransfer.getTargetIp();
|
||||||
Integer targetPort = nettyHttpClientProxyClientTransfer.getTargetPort();
|
Integer targetPort = nettyHttpClientProxyServerTransfer.getTargetPort();
|
||||||
// 适配https
|
// 适配https
|
||||||
try {
|
try {
|
||||||
SslContext sslContext = SslContextBuilder.forClient()
|
SslContext sslContext = SslContextBuilder.forClient()
|
||||||
|
@ -1,4 +0,0 @@
|
|||||||
package org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.http.socket;
|
|
||||||
|
|
||||||
public class xx {
|
|
||||||
}
|
|
Loading…
x
Reference in New Issue
Block a user