c#开发完整的Socks5代理客户端与服务端——客户端（已完结）

本文我们介绍下如何在Windows系统上开发一个代理本机流量的客户端，并且对接我们之前开发的Socks5服务端，实现整个代理的一条龙。对于Socks5代理的服务端的开发可以详见之前的文章。

目录

本机流量劫持

通过系统开启手动代理

通过c#程序打开Windows的手动代理， 并且设置端口号和IP地址，这样只要客户端监听该端口就可以获取到本机的Http的流量数据。

通过对注册表的修改，来开启本机的手动代理，并且设置端口，Ip设置为本机，因为客户端是本机启动的，端口设置不冲突的即可。

黑名单则是设置哪些域名或者IP段不走代理，我们这里先把局域网的排除掉。

// 引入Windows API
[DllImport("wininet.dll")]
public static extern bool InternetSetOption(IntPtr hInternet, int dwOption, IntPtr lpBuffer, int dwBufferLength);

public const int INTERNET_OPTION_SETTINGS_CHANGED = 39;
public const int INTERNET_OPTION_REFRESH = 37;

// 设置系统代理
public static void SetProxy(string proxyServer, bool enable)
{
    const string userRoot = "HKEY_CURRENT_USER";
    const string subkey = "Software\\Microsoft\\Windows\\CurrentVersion\\Internet Settings";
    const string keyName = userRoot + "\\" + subkey;

    // 设置代理服务器地址和端口
    Microsoft.Win32.Registry.SetValue(keyName, "ProxyServer", proxyServer);

    // 启用或禁用代理
    Microsoft.Win32.Registry.SetValue(keyName, "ProxyEnable", enable ? 1 : 0);

    // 通知系统设置已更改
    InternetSetOption(IntPtr.Zero, INTERNET_OPTION_SETTINGS_CHANGED, IntPtr.Zero, 0);
    InternetSetOption(IntPtr.Zero, INTERNET_OPTION_REFRESH, IntPtr.Zero, 0);
}

/// <summary>
/// 黑名单
/// </summary>
/// <param name="exceptions"></param>
public static void SetProxyExceptions(string exceptions)
{
    const string userRoot = "HKEY_CURRENT_USER";
    const string subkey = "Software\\Microsoft\\Windows\\CurrentVersion\\Internet Settings";
    const string keyName = userRoot + "\\" + subkey;

    Microsoft.Win32.Registry.SetValue(keyName, "ProxyOverride", exceptions);
}

 SystemProxy.SetProxy($"127.0.0.1:{App.SettingsModel.LocalPort}", true);
 SystemProxy.SetProxyExceptions("localhost;127.*;10.*;172.16.*;172.17.*;172.18.*;172.19.*;172.20.*;172.21.*;172.22.*;172.23.*;172.24.*;172.25.*;172.26.*;172.27.*;172.28.*;172.29.*;172.30.*;172.31.*;192.168.*;<local>");
客户端开启对应TCP服务
 _tcpListener = new TcpListener(IPAddress.Any, _httpProxyPort);
 _tcpListener.Start();

主要就是开启一个监听服务，让操作系统将对应的流量转发到我们的Socks5客户端。

将http报文进行解析，获取到请求的targetHost和Port,这样才能后面在和Socks5服务端握手的时候才能告知对方需要代理的远端信息。

解析系统的Http请求
    
    /// <summary>
    /// 解析http请求报文，提取关键信息
    /// </summary>
    /// <param name="request">http请求</param>
    /// <param name="host">请求主机</param>
    /// <param name="port">请求主机端口号</param>
    /// <returns>是否解析成功</returns>
    private bool TryParseHttpRequest(string request, out string host, out int port)
    {
        host = null;
        port = 0;

        // 解析 CONNECT 请求（如 CONNECT example.com:443 HTTP/1.1）
        if (request.StartsWith("CONNECT"))
        {
            var parts = request.Split(' ')[1].Split(':');
            host = parts[0];
            port = int.Parse(parts[1]);
            return true;
        }

        // 2. 处理 GET/POST 请求（HTTP）
        using (var reader = new StringReader(request))
        {
            string line;
            while ((line = reader.ReadLine()) != null)
            {
                // 从 Host 头提取目标
                if (line.StartsWith("Host:", StringComparison.OrdinalIgnoreCase))
                {
                    var hostParts = line.Substring(5).Trim().Split(':');
                    host = hostParts[0];
                    if (hostParts.Length > 1)
                        port = int.Parse(hostParts[1]);
                    return true;
                }

                // 空行表示头结束
                if (string.IsNullOrWhiteSpace(line))
                    break;
            }
        }

        // 3. 旧式HTTP/1.0请求可能没有Host头，从URL解析
        if (request.StartsWith("GET ") || request.StartsWith("POST "))
        {
            var url = request.Split(' ')[1];
            if (Uri.TryCreate(url, UriKind.Absolute, out var uri))
            {
                host = uri.Host;
                port = uri.Port;
                return true;
            }
        }

        return false;
    }
远程Socks5服务端握手

这里我们采用的是带有认证的握手，需要服务端也开启认证配置，这里对于握手协议和认证还不清楚的可以看我集合的上面一篇文章

将http的远程信息作为握手信息与服务端建立连接，让服务端建立与目标的连接代理。

    /// <summary>
    /// 带有身份验证的登录
    /// </summary>
    /// <param name="socks5Stream"></param>
    /// <param name="targetHost"></param>
    /// <param name="targetPort"></param>
    /// <param name="username"></param>
    /// <param name="password"></param>
    /// <returns></returns>
    /// <exception cref="Exception"></exception>
    private async Task PerformSocks5Handshake(NetworkStream socks5Stream,
                                              string targetHost,
                                              int targetPort,
                                              string username,
                                              string password)
    {
        // === 1. 协商认证方法 ===
        // 发送支持的认证方法：无认证(0x00) 和 用户名/密码(0x02)
        var authMethods = new byte[] { 0x05, 0x02, 0x00, 0x02 };
        await socks5Stream.WriteAsync(authMethods, 0, authMethods.Length);

        // 读取服务器选择的认证方法
        var authResponse = new byte[2];
        await socks5Stream.ReadAsync(authResponse, 0, 2);

        if (authResponse[1] == 0xFF)
            throw new Exception("SOCKS5服务器不支持任何提供的认证方法");

        // === 2. 用户名/密码认证 ===
        if (authResponse[1] == 0x02)
        {
            // 构建认证请求包
            var authRequest = new byte[3 + username.Length + password.Length];
            authRequest[0] = 0x01; // 认证子协商版本
            authRequest[1] = (byte)username.Length;
            Encoding.ASCII.GetBytes(username).CopyTo(authRequest, 2);
            authRequest[2 + username.Length] = (byte)password.Length;
            Encoding.ASCII.GetBytes(password).CopyTo(authRequest, 3 + username.Length);

            await socks5Stream.WriteAsync(authRequest, 0, authRequest.Length);

            // 读取认证响应
            var authResult = new byte[2];
            await socks5Stream.ReadAsync(authResult, 0, 2);
            if (authResult[1] != 0x00)
                throw new Exception("SOCKS5用户名/密码认证失败");
        }

        // === 3. 发送连接请求 ===
        var request = new byte[7 + targetHost.Length];
        request[0] = 0x05; // VER
        request[1] = 0x01; // CMD=CONNECT
        request[2] = 0x00; // RSV
        request[3] = 0x03; // ATYP=域名
        request[4] = (byte)targetHost.Length;
        Encoding.ASCII.GetBytes(targetHost).CopyTo(request, 5);
        BitConverter.GetBytes(IPAddress.HostToNetworkOrder((short)targetPort)).CopyTo(request, 5 + targetHost.Length);

        await socks5Stream.WriteAsync(request, 0, request.Length);

        // === 4. 读取连接响应 ===
        var response = new byte[10];
        await socks5Stream.ReadAsync(response, 0, 10);
        if (response[1] != 0x00)
            throw new Exception($"SOCKS5连接失败 (状态码: {response[1]})");
    }
交换流量

所谓的交换流量就是把远程代理的流量和本机的请求流量通过客户端作为中间人来转发

    private async Task ForwardDataAsync(NetworkStream src, NetworkStream dest)
    {
        var buffer = new byte[4096];
        int bytesRead;
        while ((bytesRead = await src.ReadAsync(buffer, 0, buffer.Length)) > 0)
        {
            await dest.WriteAsync(buffer, 0, bytesRead);
        }
    }

await Task.WhenAny(ForwardDataAsync(httpStream, socks5Stream),ForwardDataAsync(socks5Stream, httpStream)
代理流量显示

客户端也需要显示上传和下载流量的一些显示，我们这里简单点，因为我们之前开发的服务端是有基于用户的流量统计的，所以只需要把数据获取到就行，一般情况下为了性能，也可以做双端统计减少压力。

我们这里通过SSE将用户的流量信息基于用户名推送到客户端。

public async Task ConnectAsync(string remoteAddress, string userName)
{
    _httpClient = new HttpClient(new HttpClientHandler
    {
        Proxy = new WebProxy($"http://{remoteAddress}:5000"), // 明确指定代理
    });
    _cts = new CancellationTokenSource();

    try
    {
        using var response = await _httpClient
            .GetAsync($"http://{remoteAddress}:5000/account/flow/{userName}", HttpCompletionOption.ResponseHeadersRead,_cts.Token);
        if (response.IsSuccessStatusCode)
        {
            using var stream = await response.Content.ReadAsStreamAsync();
            using var reader = new StreamReader(stream);
            while (!_cts.Token.IsCancellationRequested)
            {
                var line = await reader.ReadLineAsync();
                if (!string.IsNullOrEmpty(line))
                {
                    MessageReceived?.Invoke(line);
                }
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"SSE连接错误: {ex.Message}");
    }
}

验证

远端开启服务端

image

开启客户端

添加一些配置
包括：服务端IP,服务端Port,本地代理Port,用户名密码
image
开启客户端
image
可以看到代理成功，走的是本机的代理和服务端的代理请求
image

结尾

因为本身代理采用的修改系统代理设置是一种基础设置，所谓可能存在下面影响：
仅影响支持系统代理的应用（部分UWP应用、游戏等会绕过
无法代理非HTTP/HTTPS流量（如DNS、UDP

源码地址

https://github.com/BruceQiu1996/Socks5Server

From:https://www.cnblogs.com/qwqwQAQ/p/18867762
BruceNeter
100+评论
captcha
    相关文章
    1. uniapp跨平台开发HarmonyOS NEXT应用初体验
      之前写过使用uniapp开发鸿蒙应用的教程，简单介绍了如何配置开发环境和运行项目。那时候的HbuilderX还是4.22版本，小一年过去了HbuilderX的正式版本已经来到4.64，历经了多个版本的更新后，跨平台开发鸿蒙应用的体验大幅提升。今天再次跟大家分享一下使用uniapp开发鸿蒙的使用教程。
      幽蓝计划
      20 小时前
    3. 透明证书机制——安全审计
      目录证书透明（CT）的定义CT审计的流程识别网站是否使用了CT技术Reference 一些前置知识： https://www.cnblogs.com/mysticbinary/p/17260648.html 证书透明（CT）的定义 CT的目的是监测和审计数字证书。透过证书日志、监控和审计系统，证书透
      Mysticbinary
      21 小时前
    4. MCP 实践系列：百度 AI 搜索
      今天在腾讯云MCP市场，我发现了许多不同的MCP组件。接下来，我打算逐一深入了解每个组件的具体功能。今天的重点将是百度AI搜索。 百度AI搜索结合了百度的传统搜索和人工智能技术，能让用户体验到更智能的搜索方式。比如，基础搜索帮助你快速找到各种需要的内容，像是查天气、找餐厅推荐，甚至查看新闻，所有这些
      努力的小雨
      21 小时前
    5. 在 .NET 中使用 Sqids 快速的为数字 ID 披上神秘短串，轻松隐藏敏感数字！
      前言 在当今数字化时代，数据的安全性和隐私性至关重要。随着网络应用的不断发展，数字 ID 作为数据标识和访问控制的关键元素，其保护显得尤为重要。然而，传统的数字 ID 往往直接暴露了一些敏感信息，如顺序编号或数据库主键ID，这不仅增加了数据泄露的风险，还可能让不法分子有机可乘。 本文大姚将带领大家在
      追逐时光者
      22 小时前
    6. Vue 3中的ref和template refs详解（含Vue2迁移到Vue3方法）
      Vue 3中的ref和template refs详解 在Vue 3中，ref和模板引用（template refs）是两个相关但不同的概念，它们在组合式API（Composition API）中扮演着重要角色。 ref - 响应式引用 ref是Vue 3中创建响应式数据的主要方式之一。 基本用法 i
      Dandelion_000
      18 小时前
    8. Java实现minio上传文件加解密操作
      一、背景与需求 在云存储场景中，数据安全是核心需求之一。MinIO作为高性能对象存储服务，支持通过客户端加密（CSE）在数据上传前完成加密，确保即使存储服务器被攻破，攻击者也无法获取明文数据。本文将详解如何通过Java实现MinIO文件的加密上传与解密下载，结合AES对称加密算法和BouncyCas
      ghostmen
      20 小时前
    9. 关于ADB-数据包抓取-反编译工具(手机刷机使用)
      1 逆向基本流程 1 获取目标app(官网，豌豆荚)，尽量不要去华为应用市场，小米应用市场下载--多渠道打包，安装到手机上 2 使用抓包工具抓包分析（charles，fiddler。。。） 3 使用反编译工具（JADX，JD-GUI。。），把apk反编译成java代码，分析java代码，定位代码位置
      生而自由爱而无畏
      20 小时前
    10. SpringBoot中的拦截器江湖
      前言 很多小伙伴在工作中遇到拦截需求就无脑写HandlerInterceptor，结果被复杂场景搞得鼻青脸肿。 作为一名有多年开发经验的程序员，今天领大家到SpringBoot的山头认认6把交椅： 这篇文章以梁山为背景的介绍SpringBoot中的拦截器，可能更通俗易懂。 希望对你会有所帮助，记得点
      苏三说技术
      19 小时前