• 日期: 2027-09-01
  • 标签: 常规

以下代码展示了如何使用 Netty 构建一个简单的 Socks5 代理服务器：

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.socks.*;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener;

public class Socks5Server {
    private static ServerBootstrap serverBootstrap = new ServerBootstrap();
    private static SocksInsideChannelInitializer channelInitializer = new SocksInsideChannelInitializer();


    public static void main(String[] args) throws Exception {

        NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);
        NioEventLoopGroup workerGroup = new NioEventLoopGroup();
        serverBootstrap.channel(NioServerSocketChannel.class);
        serverBootstrap.group(bossGroup, workerGroup);
        serverBootstrap.childHandler(channelInitializer);
        serverBootstrap.bind(52007).addListener(new GenericFutureListener<Future<? super Void>>() {
            @Override
            public void operationComplete(Future<? super Void> future) throws Exception {
                System.out.println('socks-inside-server started, listening port: ' + 52007);
            }
        });
    }

    private static class SocksInsideChannelInitializer extends ChannelInitializer<Channel> {
        private Socks5ProcessServerHandler socksProxyProcessHandler = new Socks5ProcessServerHandler();
        @Override
        protected void initChannel(Channel ch) throws Exception {
            ch.pipeline().addLast(new SocksInitRequestDecoder());
            ch.pipeline().addLast(new SocksMessageEncoder());
            ch.pipeline().addLast(socksProxyProcessHandler);
        }
    }

}


package com.lijiatun.vpn.server.test;

import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.socks.*;

@ChannelHandler.Sharable
public class Socks5ProcessServerHandler extends SimpleChannelInboundHandler<SocksRequest> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, SocksRequest msg) throws Exception {
        System.out.println(msg.requestType());

        switch (msg.requestType()) {
            case INIT:
                ctx.pipeline().addFirst(new SocksCmdRequestDecoder());
                ctx.writeAndFlush(new SocksInitResponse(SocksAuthScheme.NO_AUTH));
                break;
            case AUTH:
                ctx.pipeline().addFirst(new SocksCmdRequestDecoder());
                ctx.writeAndFlush(new SocksAuthResponse(SocksAuthStatus.SUCCESS));
                break;
            case CMD:
                SocksCmdRequest req = (SocksCmdRequest) msg;
                System.out.println(req.cmdType());
                if (req.cmdType() == SocksCmdType.CONNECT) {
                    ctx.pipeline().addLast(new SocksServerHandler());
                    ctx.pipeline().remove(this);
                    ctx.fireChannelRead(msg);
                } else {
                    ctx.close();
                }
                break;
            case UNKNOWN:
                ctx.close();
                break;
            default:
                ctx.close();
                break;
        }
    }
}
package com.lijiatun.vpn.server.test;


import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.handler.codec.socks.SocksAddressType;
import io.netty.handler.codec.socks.SocksCmdRequest;
import io.netty.handler.codec.socks.SocksCmdResponse;
import io.netty.handler.codec.socks.SocksCmdStatus;

@ChannelHandler.Sharable
class SocksServerHandler extends SimpleChannelInboundHandler<SocksCmdRequest> {


    @Override
    protected void channelRead0(final ChannelHandlerContext browserCtx, final SocksCmdRequest msg) throws Exception {

        if (msg.host() == null || msg.host().isEmpty()) {
            browserCtx.close();
            return;
        }
        browserCtx.pipeline().remove(this);
        browserCtx.pipeline().addLast(new SocksHandler(browserCtx, msg));
        browserCtx.channel().writeAndFlush(new SocksCmdResponse(SocksCmdStatus.SUCCESS, SocksAddressType.IPv4));

    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        if (ctx.channel().isActive()) {
            ctx.channel().close();
        }
    }

    private class SocksHandler extends ChannelInboundHandlerAdapter {

        private ChannelHandlerContext browserCtx;
        private SocksCmdRequest req;

        public SocksHandler(ChannelHandlerContext browserCtx, SocksCmdRequest req) {
            this.browserCtx = browserCtx;
            this.req = req;
        }

        @Override
        public void channelRead(ChannelHandlerContext outsideProxyCtx, Object msg) throws Exception {
            System.out.println(req.host());
            System.out.println(req.port());
            System.out.println(msg);
            // 处理HTTP请求
            if (msg instanceof FullHttpRequest) {
                FullHttpRequest request = (FullHttpRequest) msg;
                if (request.decoderResult().isSuccess()) {
                    // 获取请求的信息
                    String method = request.method().name();
                    String uri = request.uri();
                    String version = request.protocolVersion().text();
                    System.out.println('HTTP Request: ' + method + ' ' + uri + ' ' + version);
                    // 返回响应
                    String response = 'Hello World!';
                    FullHttpResponse httpResponse = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
                            HttpResponseStatus.OK, Unpooled.wrappedBuffer(response.getBytes()));
                    httpResponse.headers().set(HttpHeaderNames.CONTENT_TYPE, 'text/plain');
                    httpResponse.headers().set(HttpHeaderNames.CONTENT_LENGTH, httpResponse.content().readableBytes());
                    outsideProxyCtx.writeAndFlush(httpResponse);
                } else {
                    browserCtx.close();
                }
            }
        }

    }
}

package com.lijiatun.vpn.server.test;


import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.handler.codec.socks.SocksAddressType;
import io.netty.handler.codec.socks.SocksCmdRequest;
import io.netty.handler.codec.socks.SocksCmdResponse;
import io.netty.handler.codec.socks.SocksCmdStatus;

@ChannelHandler.Sharable
class SocksServerHandler extends SimpleChannelInboundHandler<SocksCmdRequest> {


    @Override
    protected void channelRead0(final ChannelHandlerContext browserCtx, final SocksCmdRequest msg) throws Exception {

        if (msg.host() == null || msg.host().isEmpty()) {
            browserCtx.close();
            return;
        }
        browserCtx.pipeline().remove(this);
        browserCtx.pipeline().addLast(new SocksHandler(browserCtx, msg));
        browserCtx.channel().writeAndFlush(new SocksCmdResponse(SocksCmdStatus.SUCCESS, SocksAddressType.IPv4));

    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        if (ctx.channel().isActive()) {
            ctx.channel().close();
        }
    }

    private class SocksHandler extends ChannelInboundHandlerAdapter {

        private ChannelHandlerContext browserCtx;
        private SocksCmdRequest req;

        public SocksHandler(ChannelHandlerContext browserCtx, SocksCmdRequest req) {
            this.browserCtx = browserCtx;
            this.req = req;
        }

        @Override
        public void channelRead(ChannelHandlerContext outsideProxyCtx, Object msg) throws Exception {
            System.out.println(req.host());
            System.out.println(req.port());
            System.out.println(msg);
            // 处理HTTP请求
            if (msg instanceof FullHttpRequest) {
                FullHttpRequest request = (FullHttpRequest) msg;
                if (request.decoderResult().isSuccess()) {
                    // 获取请求的信息
                    String method = request.method().name();
                    String uri = request.uri();
                    String version = request.protocolVersion().text();
                    System.out.println('HTTP Request: ' + method + ' ' + uri + ' ' + version);
                    // 返回响应
                    String response = 'Hello World!';
                    FullHttpResponse httpResponse = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
                            HttpResponseStatus.OK, Unpooled.wrappedBuffer(response.getBytes()));
                    httpResponse.headers().set(HttpHeaderNames.CONTENT_TYPE, 'text/plain');
                    httpResponse.headers().set(HttpHeaderNames.CONTENT_LENGTH, httpResponse.content().readableBytes());
                    outsideProxyCtx.writeAndFlush(httpResponse);
                } else {
                    browserCtx.close();
                }
            }
        }

    }
}

该代码包含以下几个关键部分：

  1. 启动服务器: Socks5Server 类负责启动服务器，监听指定端口（52007）并处理连接请求。
  2. 通道初始化: SocksInsideChannelInitializer 类在每个连接建立时，向通道的管道中添加必要的处理器，包括：
    • SocksInitRequestDecoder: 解码 Socks5 初始化请求。
    • SocksMessageEncoder: 编码 Socks5 消息。
    • Socks5ProcessServerHandler: 处理 Socks5 请求，负责验证和转发请求。
  3. 请求处理: Socks5ProcessServerHandler 类处理不同的 Socks5 请求类型，并根据请求类型进行相应操作。
  4. HTTP 处理: SocksServerHandler 类负责处理 HTTP 请求，从浏览器代理转发到目标服务器，并返回响应。

该示例代码展示了使用 Netty 构建 Socks5 代理服务器的基本流程。您可以根据实际需求，进一步扩展和完善该代码，例如：

  • 添加更复杂的验证机制。
  • 实现目标服务器地址的解析和重定向。
  • 优化性能和稳定性。
  • 添加日志记录和监控功能。
  • 支持 HTTPS 等其他协议。

参考代码仅供学习参考，实际应用中可能需要根据您的具体场景进行调整和优化。

使用 Netty 构建 Socks5 代理服务器

原文地址: https://www.cveoy.top/t/topic/oae6 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录