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】 优化代理

Browse Source
This commit is contained in:
wujiawei 2025-04-29 09:15:59 +08:00
parent d8a8b630ae
commit e51ad201de
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/context/NettyTcpProxySocketApplicationListener.java
View File

@ -34,9 +34,9 @@ public class NettyTcpProxySocketApplicationListener implements SocketApplication
*/ */
@Override @Override
public void doRunning() throws Exception { public void doRunning() throws Exception {
try {
ProtocolProxyProperties.TcpProtocolProxy tcpProtocolProxy = protocolProxyProperties.getTcpProtocolProxy(); ProtocolProxyProperties.TcpProtocolProxy tcpProtocolProxy = protocolProxyProperties.getTcpProtocolProxy();
Integer tcpProtocolProxyPort = tcpProtocolProxy.getPort(); Integer tcpProtocolProxyPort = tcpProtocolProxy.getPort();
try {
ServerBootstrap b = new ServerBootstrap(); ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup) b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class) .channel(NioServerSocketChannel.class)
@ -61,7 +61,7 @@ public class NettyTcpProxySocketApplicationListener implements SocketApplication
}); });
channelFuture.channel().closeFuture().sync(); channelFuture.channel().closeFuture().sync();
} catch (Exception e) { } catch (Exception e) {
log.error("启动TCP 协议代理 失败", e); log.error("启动TCP 协议代理 失败,端口:{}", tcpProtocolProxyPort, e);
} finally { } finally {
destroy(); destroy();
// 服务器已关闭 // 服务器已关闭

2
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/context/NettyTcpServerSocketApplicationListener.java
View File

@ -56,7 +56,7 @@ public class NettyTcpServerSocketApplicationListener implements SocketApplicatio
channelFuture.addListener((ChannelFutureListener) channelFuture -> { channelFuture.addListener((ChannelFutureListener) channelFuture -> {
// 服务器已启动 // 服务器已启动
log.info("TCP 服务器启动成功"); log.info("TCP 服务器启动成功【{}】",tcpPort);
}); });
channelFuture.channel().closeFuture().sync(); channelFuture.channel().closeFuture().sync();
} catch (Exception e) { } catch (Exception e) {