当前位置：首页 > news >正文

netty转发tcp连接

news 2025/8/23 4:18:53

Netty 是一个高性能的网络应用框架，常用于构建高性能的 TCP/UDP 服务器和客户端。如果您想使用 Netty 转发 TCP 连接，可以创建一个简单的 TCP 代理（或中间人），它接收来自客户端的连接，然后将这些连接转发到目标服务器。

以下是一个简单的例子，演示如何使用 Netty 实现 TCP 连接的转发。

import io.netty.bootstrap.ServerBootstrap;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;public class TcpForwardingServer {private final int localPort;private final String remoteHost;private final int remotePort;public TcpForwardingServer(int localPort, String remoteHost, int remotePort) {this.localPort = localPort;this.remoteHost = remoteHost;this.remotePort = remotePort;}public void start() throws InterruptedException {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();try {// 启动服务器ServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new TcpForwardHandler(remoteHost, remotePort));}});ChannelFuture serverFuture = serverBootstrap.bind(localPort).sync();System.out.println("TCP Forwarding Server started on port " + localPort);serverFuture.channel().closeFuture().sync();} finally {workerGroup.shutdownGracefully();bossGroup.shutdownGracefully();}}public static void main(String[] args) throws InterruptedException {int localPort = 9991; // 本地监听端口String remoteHost = "127.0.0.1"; // 目标服务器地址int remotePort = 9091; // 目标服务器端口new TcpForwardingServer(localPort, remoteHost, remotePort).start();}
}class TcpForwardHandler extends ChannelInboundHandlerAdapter {private final String remoteHost;private final int remotePort;private ChannelFuture remoteChannelFuture;public TcpForwardHandler(String remoteHost, int remotePort) {this.remoteHost = remoteHost;this.remotePort = remotePort;}@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {// 连接到远程主机Bootstrap bootstrap = new Bootstrap();bootstrap.group(ctx.channel().eventLoop()).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast(new TcpForwardClientHandler(ctx));}});remoteChannelFuture = bootstrap.connect(remoteHost, remotePort);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {cause.printStackTrace();ctx.close();}
}class TcpForwardClientHandler extends ChannelInboundHandlerAdapter {private final ChannelHandlerContext clientCtx;public TcpForwardClientHandler(ChannelHandlerContext clientCtx) {this.clientCtx = clientCtx;}@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {// 将接收到的数据转发到客户端clientCtx.writeAndFlush(msg);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {cause.printStackTrace();ctx.close();}
}

代码说明

1. TcpForwardingServer:
- 这个类负责启动 TCP 服务器，监听来自客户端的连接请求，并将其转发到指定的远程服务器。

2. TcpForwardHandler:
- 当客户端连接到转发服务器时，`channelActive` 方法会被调用。在这个方法中，它会连接到目标服务器。
- 该处理程序会监听来自客户端的流量，并将其转发到目标服务器。

3. TcpForwardClientHandler:
- 这个类处理从远程服务器接收到的数据，并将其转发回原始客户端。

运行方式

1. **编译并运行**:
- 确保您已经在项目中添加了 Netty 依赖。如果使用 Maven，可以在 `pom.xml` 中添加以下依赖：
     <dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.1.68.Final</version> </dependency>
2. 配置参数:
- 在 `main` 方法中，您可以根据需要更改 `localPort`、`remoteHost` 和 `remotePort` 变量。

3. 启动服务器:
- 运行程序后，您的 TCP 代理服务器将开始监听指定的本地端口，并将其流量转发到目标服务器。