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

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

目录

• 本机流量劫持
  
  
  
  • 通过系统开启手动代理
    
  • 客户端开启对应TCP服务
    
  • 解析系统的Http请求
    
  • 远程Socks5服务端握手
    
  • 交换流量
    
  • 代理流量显示
    
  
  
• 验证
  
  
  
  • 远端开启服务端
    
  • 开启客户端
    
  
  
• 结尾
  
• 源码地址
  

本机流量劫持

通过系统开启手动代理

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

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

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

1. // 引入Windows API
2. [DllImport("wininet.dll")]
3. public static extern bool InternetSetOption(IntPtr hInternet, int dwOption, IntPtr lpBuffer, int dwBufferLength);
5. public const int INTERNET_OPTION_SETTINGS_CHANGED = 39;
6. public const int INTERNET_OPTION_REFRESH = 37;
8. // 设置系统代理
9. public static void SetProxy(string proxyServer, bool enable)
10. {
11.     const string userRoot = "HKEY_CURRENT_USER";
12.     const string subkey = "Software\\Microsoft\\Windows\\CurrentVersion\\Internet Settings";
13.     const string keyName = userRoot + "\" + subkey;
15.     // 设置代理服务器地址和端口
16.     Microsoft.Win32.Registry.SetValue(keyName, "ProxyServer", proxyServer);
18.     // 启用或禁用代理
19.     Microsoft.Win32.Registry.SetValue(keyName, "ProxyEnable", enable ? 1 : 0);
21.     // 通知系统设置已更改
22.     InternetSetOption(IntPtr.Zero, INTERNET_OPTION_SETTINGS_CHANGED, IntPtr.Zero, 0);
23.     InternetSetOption(IntPtr.Zero, INTERNET_OPTION_REFRESH, IntPtr.Zero, 0);
24. }
26. /// <summary>
27. /// 黑名单
28. /// </summary>
29. /// <param name="exceptions"></param>
30. public static void SetProxyExceptions(string exceptions)
31. {
32.     const string userRoot = "HKEY_CURRENT_USER";
33.     const string subkey = "Software\\Microsoft\\Windows\\CurrentVersion\\Internet Settings";
34.     const string keyName = userRoot + "\" + subkey;
36.     Microsoft.Win32.Registry.SetValue(keyName, "ProxyOverride", exceptions);
37. }

复制代码

1. SystemProxy.SetProxy($"127.0.0.1:{App.SettingsModel.LocalPort}", true);
2. 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服务

1. _tcpListener = new TcpListener(IPAddress.Any, _httpProxyPort);
2. _tcpListener.Start();

复制代码

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

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

解析系统的Http请求

1.    
2.     /// <summary>
3.     /// 解析http请求报文，提取关键信息
4.     /// </summary>
5.     /// <param name="request">http请求</param>
6.     /// <param name="host">请求主机</param>
7.     /// <param name="port">请求主机端口号</param>
8.     /// <returns>是否解析成功</returns>
9.     private bool TryParseHttpRequest(string request, out string host, out int port)
10.     {
11.         host = null;
12.         port = 0;
14.         // 解析 CONNECT 请求（如 CONNECT example.com:443 HTTP/1.1）
15.         if (request.StartsWith("CONNECT"))
16.         {
17.             var parts = request.Split(' ')[1].Split(':');
18.             host = parts[0];
19.             port = int.Parse(parts[1]);
20.             return true;
21.         }
23.         // 2. 处理 GET/POST 请求（HTTP）
24.         using (var reader = new StringReader(request))
25.         {
26.             string line;
27.             while ((line = reader.ReadLine()) != null)
28.             {
29.                 // 从 Host 头提取目标
30.                 if (line.StartsWith("Host:", StringComparison.OrdinalIgnoreCase))
31.                 {
32.                     var hostParts = line.Substring(5).Trim().Split(':');
33.                     host = hostParts[0];
34.                     if (hostParts.Length > 1)
35.                         port = int.Parse(hostParts[1]);
36.                     return true;
37.                 }
39.                 // 空行表示头结束
40.                 if (string.IsNullOrWhiteSpace(line))
41.                     break;
42.             }
43.         }
45.         // 3. 旧式HTTP/1.0请求可能没有Host头，从URL解析
46.         if (request.StartsWith("GET ") || request.StartsWith("POST "))
47.         {
48.             var url = request.Split(' ')[1];
49.             if (Uri.TryCreate(url, UriKind.Absolute, out var uri))
50.             {
51.                 host = uri.Host;
52.                 port = uri.Port;
53.                 return true;
54.             }
55.         }
57.         return false;
58.     }

复制代码

远程Socks5服务端握手

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

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

1.     /// <summary>
2.     /// 带有身份验证的登录
3.     /// </summary>
4.     /// <param name="socks5Stream"></param>
5.     /// <param name="targetHost"></param>
6.     /// <param name="targetPort"></param>
7.     /// <param name="username"></param>
8.     /// <param name="password"></param>
9.     /// <returns></returns>
10.     /// <exception cref="Exception"></exception>
11.     private async Task PerformSocks5Handshake(NetworkStream socks5Stream,
12.                                               string targetHost,
13.                                               int targetPort,
14.                                               string username,
15.                                               string password)
16.     {
17.         // === 1. 协商认证方法 ===
18.         // 发送支持的认证方法：无认证(0x00) 和 用户名/密码(0x02)
19.         var authMethods = new byte[] { 0x05, 0x02, 0x00, 0x02 };
20.         await socks5Stream.WriteAsync(authMethods, 0, authMethods.Length);
22.         // 读取服务器选择的认证方法
23.         var authResponse = new byte[2];
24.         await socks5Stream.ReadAsync(authResponse, 0, 2);
26.         if (authResponse[1] == 0xFF)
27.             throw new Exception("SOCKS5服务器不支持任何提供的认证方法");
29.         // === 2. 用户名/密码认证 ===
30.         if (authResponse[1] == 0x02)
31.         {
32.             // 构建认证请求包
33.             var authRequest = new byte[3 + username.Length + password.Length];
34.             authRequest[0] = 0x01; // 认证子协商版本
35.             authRequest[1] = (byte)username.Length;
36.             Encoding.ASCII.GetBytes(username).CopyTo(authRequest, 2);
37.             authRequest[2 + username.Length] = (byte)password.Length;
38.             Encoding.ASCII.GetBytes(password).CopyTo(authRequest, 3 + username.Length);
40.             await socks5Stream.WriteAsync(authRequest, 0, authRequest.Length);
42.             // 读取认证响应
43.             var authResult = new byte[2];
44.             await socks5Stream.ReadAsync(authResult, 0, 2);
45.             if (authResult[1] != 0x00)
46.                 throw new Exception("SOCKS5用户名/密码认证失败");
47.         }
49.         // === 3. 发送连接请求 ===
50.         var request = new byte[7 + targetHost.Length];
51.         request[0] = 0x05; // VER
52.         request[1] = 0x01; // CMD=CONNECT
53.         request[2] = 0x00; // RSV
54.         request[3] = 0x03; // ATYP=域名
55.         request[4] = (byte)targetHost.Length;
56.         Encoding.ASCII.GetBytes(targetHost).CopyTo(request, 5);
57.         BitConverter.GetBytes(IPAddress.HostToNetworkOrder((short)targetPort)).CopyTo(request, 5 + targetHost.Length);
59.         await socks5Stream.WriteAsync(request, 0, request.Length);
61.         // === 4. 读取连接响应 ===
62.         var response = new byte[10];
63.         await socks5Stream.ReadAsync(response, 0, 10);
64.         if (response[1] != 0x00)
65.             throw new Exception($"SOCKS5连接失败 (状态码: {response[1]})");
66.     }

复制代码

交换流量

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

1.     private async Task ForwardDataAsync(NetworkStream src, NetworkStream dest)
2.     {
3.         var buffer = new byte[4096];
4.         int bytesRead;
5.         while ((bytesRead = await src.ReadAsync(buffer, 0, buffer.Length)) > 0)
6.         {
7.             await dest.WriteAsync(buffer, 0, bytesRead);
8.         }
9.     }

复制代码

1. await Task.WhenAny(ForwardDataAsync(httpStream, socks5Stream),ForwardDataAsync(socks5Stream, httpStream)

复制代码

代理流量显示

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

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

1. public async Task ConnectAsync(string remoteAddress, string userName)
2. {
3.     _httpClient = new HttpClient(new HttpClientHandler
4.     {
5.         Proxy = new WebProxy($"http://{remoteAddress}:5000"), // 明确指定代理
6.     });
7.     _cts = new CancellationTokenSource();
9.     try
10.     {
11.         using var response = await _httpClient
12.             .GetAsync($"http://{remoteAddress}:5000/account/flow/{userName}", HttpCompletionOption.ResponseHeadersRead,_cts.Token);
13.         if (response.IsSuccessStatusCode)
14.         {
15.             using var stream = await response.Content.ReadAsStreamAsync();
16.             using var reader = new StreamReader(stream);
17.             while (!_cts.Token.IsCancellationRequested)
18.             {
19.                 var line = await reader.ReadLineAsync();
20.                 if (!string.IsNullOrEmpty(line))
21.                 {
22.                     MessageReceived?.Invoke(line);
23.                 }
24.             }
25.         }
26.     }
27.     catch (Exception ex)
28.     {
29.         Console.WriteLine($"SSE连接错误: {ex.Message}");
30.     }
31. }

复制代码

验证

远端开启服务端

开启客户端

添加一些配置
包括：服务端IP,服务端Port,本地代理Port,用户名密码

开启客户端

可以看到代理成功，走的是本机的代理和服务端的代理请求

结尾

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

https://github.com/BruceQiu1996/Socks5Server

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！