一 Key 接入 .NET 3.5 異步 Socket 客戶端：SocketAsyncEventArgs 配置骨架與連通性驗(yàn)證)
1. 老項(xiàng)目里那套 Socket 客戶端為什么還要折騰.NET 3.5 的異步 Socket 客戶端放到今天依然有它的生存空間。很多工控上位機(jī)、老 ERP 插件、桌面采集端還鎖在 3.5 框架上升級一次成本高得嚇人但業(yè)務(wù)又要求把數(shù)據(jù)往統(tǒng)一通道上送。這時(shí)候你手里能用的牌不多BeginConnect/EndConnect那套 APM 寫起來回調(diào)套回調(diào)Thread加阻塞Receive又容易把 UI 卡死。SocketAsyncEventArgs是 3.5 里少數(shù)既能扛并發(fā)、又不依賴新框架的異步模型它把一次連接、一次收發(fā)都抽象成一個(gè)可復(fù)用的事件參數(shù)對象配合對象池能顯著減少 GC 壓力。這篇聚焦的是「客戶端」側(cè)用SocketAsyncEventArgs寫一個(gè)能連、能收、能發(fā)、斷了能重連的最小骨架并且把 TaoToken 統(tǒng)一 Key 和 API 通道的配置放進(jìn)app.config讓老框架項(xiàng)目不用改架構(gòu)就能接入統(tǒng)一通道。適合誰手上維護(hù)著 .NET 3.5 項(xiàng)目、需要把設(shè)備數(shù)據(jù)或業(yè)務(wù)請求走統(tǒng)一 API 通道的開發(fā)者。讀完你能拿到一份可直接粘貼的配置骨架、一段可運(yùn)行的客戶端代碼以及一次明確的連通性驗(yàn)證動(dòng)作和預(yù)期結(jié)果。需要先說明一點(diǎn)TaoToken 在這里扮演的是「統(tǒng)一 Key API 通道」的角色客戶端通過它去訪問模型對話、Coding Plan 等能力而不是替代你的 Socket 通信本身。Socket 負(fù)責(zé)傳輸TaoToken 負(fù)責(zé)鑒權(quán)和路由兩者是配合關(guān)系。2. TaoToken 前置統(tǒng)一 Key 與 API 通道怎么擺進(jìn) app.config在動(dòng)手寫 Socket 之前先把配置層理清楚。老項(xiàng)目最忌諱把 Key 硬編碼進(jìn).cs文件一旦要換環(huán)境就得重新編譯。app.config的appSettings是最省事的落點(diǎn)3.5 原生支持讀取用ConfigurationManager.AppSettings即可。你需要先在 TaoToken 控制臺拿到統(tǒng)一 Key。入口在官網(wǎng) https://taotoken.net/?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 登錄后進(jìn)控制臺創(chuàng)建 API Key具體頁面是 https://taotoken.net/console?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 。Key 的管理和查看在 https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 接入細(xì)節(jié)看文檔 https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 。API 基地址是 https://taotoken.net/api 注意這個(gè)地址不帶任何查詢參數(shù)配置里直接寫死即可。配置骨架長這樣我把它拆成「通道地址」「鑒權(quán)」「Socket 行為」三組方便你按環(huán)境替換?xml version1.0 encodingutf-8? configuration appSettings !-- TaoToken 統(tǒng)一通道 -- add keyTaoToken.ApiBase valuehttps://taotoken.net/api / add keyTaoToken.ApiKey valuesk-你的統(tǒng)一Key / add keyTaoToken.Model valueclaude-3-5-sonnet / !-- Socket 客戶端行為 -- add keySocket.Host value127.0.0.1 / add keySocket.Port value9000 / add keySocket.ConnectTimeoutMs value5000 / add keySocket.BufferSize value8192 / add keySocket.ReconnectDelayMs value3000 / add keySocket.MaxReconnect value5 / /appSettings /configuration注意TaoToken.ApiKey不要提交到版本庫。老項(xiàng)目常用做法是放一份app.config.template真實(shí) Key 由部署腳本注入或者用機(jī)器級環(huán)境變量覆蓋。讀取封裝一個(gè)靜態(tài)類避免到處寫字符串public static class AppConfig { public static string ApiBase { get { return ConfigurationManager.AppSettings[TaoToken.ApiBase]; } } public static string ApiKey { get { return ConfigurationManager.AppSettings[TaoToken.ApiKey]; } } public static string Host { get { return ConfigurationManager.AppSettings[Socket.Host]; } } public static int Port { get { return int.Parse(ConfigurationManager.AppSettings[Socket.Port]); } } public static int BufferSize { get { return int.Parse(ConfigurationManager.AppSettings[Socket.BufferSize]); } } public static int ReconnectDelayMs { get { return int.Parse(ConfigurationManager.AppSettings[Socket.ReconnectDelayMs]); } } public static int MaxReconnect { get { return int.Parse(ConfigurationManager.AppSettings[Socket.MaxReconnect]); } } }這里有個(gè)容易忽略的點(diǎn).NET 3.5 的ConfigurationManager在System.Configuration程序集里項(xiàng)目引用里要手動(dòng)加上否則編譯報(bào)「找不到類型或命名空間」。這是老項(xiàng)目接入時(shí)第一個(gè)坑先記下。3. 可復(fù)制配置SocketAsyncEventArgs 客戶端骨架下面這段是核心。設(shè)計(jì)思路是一個(gè)AsyncSocketClient類持有Socket實(shí)例用兩個(gè)SocketAsyncEventArgs分別負(fù)責(zé)收和發(fā)連接、接收、發(fā)送都走SocketAsyncEventArgs的完成回調(diào)。斷線重連用一個(gè)簡單的重試計(jì)數(shù)加定時(shí)器。先看連接部分。ConnectAsync在 3.5 里通過SocketAsyncEventArgs的Completed事件回調(diào)using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; public class AsyncSocketClient { private Socket _socket; private readonly SocketAsyncEventArgs _connectArgs; private readonly SocketAsyncEventArgs _receiveArgs; private readonly SocketAsyncEventArgs _sendArgs; private readonly byte[] _receiveBuffer; private int _reconnectCount; private bool _manualClose; public event Actionstring OnMessage; public event Actionbool OnConnectionChanged; public AsyncSocketClient() { _receiveBuffer new byte[AppConfig.BufferSize]; _connectArgs new SocketAsyncEventArgs(); _connectArgs.RemoteEndPoint new DnsEndPoint(AppConfig.Host, AppConfig.Port); _connectArgs.Completed OnConnectCompleted; _receiveArgs new SocketAsyncEventArgs(); _receiveArgs.SetBuffer(_receiveBuffer, 0, _receiveBuffer.Length); _receiveArgs.Completed OnReceiveCompleted; _sendArgs new SocketAsyncEventArgs(); _sendArgs.Completed OnSendCompleted; } public void Connect() { _manualClose false; _socket new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); bool pending _socket.ConnectAsync(_connectArgs); if (!pending) OnConnectCompleted(_socket, _connectArgs); }連接完成的回調(diào)里判斷SocketError成功就掛上接收private void OnConnectCompleted(object sender, SocketAsyncEventArgs e) { if (e.SocketError SocketError.Success) { _reconnectCount 0; RaiseConnection(true); StartReceive(); } else { RaiseConnection(false); ScheduleReconnect(); } } private void StartReceive() { if (_socket null) return; bool pending _socket.ReceiveAsync(_receiveArgs); if (!pending) OnReceiveCompleted(_socket, _receiveArgs); }接收回調(diào)是數(shù)據(jù)入口注意BytesTransferred 0表示對端關(guān)閉要觸發(fā)重連private void OnReceiveCompleted(object sender, SocketAsyncEventArgs e) { if (e.SocketError SocketError.Success e.BytesTransferred 0) { string msg Encoding.UTF8.GetString(e.Buffer, e.Offset, e.BytesTransferred); if (OnMessage ! null) OnMessage(msg); StartReceive(); } else { RaiseConnection(false); ScheduleReconnect(); } }發(fā)送部分把待發(fā)數(shù)據(jù)拷進(jìn)SocketAsyncEventArgs的緩沖。3.5 里沒有Memory用SetBuffer加偏移即可public void Send(string text) { if (_socket null || !_socket.Connected) return; byte[] data Encoding.UTF8.GetBytes(text); _sendArgs.SetBuffer(data, 0, data.Length); bool pending _socket.SendAsync(_sendArgs); if (!pending) OnSendCompleted(_socket, _sendArgs); } private void OnSendCompleted(object sender, SocketAsyncEventArgs e) { if (e.SocketError ! SocketError.Success) { RaiseConnection(false); ScheduleReconnect(); } }重連用Timer做延遲避免斷線瞬間瘋狂重試private void ScheduleReconnect() { if (_manualClose) return; if (_reconnectCount AppConfig.MaxReconnect) return; _reconnectCount; Timer t null; t new Timer(state { t.Dispose(); try { Connect(); } catch { ScheduleReconnect(); } }, null, AppConfig.ReconnectDelayMs, Timeout.Infinite); } private void RaiseConnection(bool ok) { if (OnConnectionChanged ! null) OnConnectionChanged(ok); } public void Close() { _manualClose true; if (_socket ! null) { try { _socket.Shutdown(SocketShutdown.Both); } catch { } _socket.Close(); _socket null; } } }這段骨架刻意保持最小沒有做粘包拆包沒有做心跳。真實(shí)項(xiàng)目里這兩塊必須補(bǔ)但那是另一個(gè)話題先把連通性跑通。4. 驗(yàn)證請求一次可執(zhí)行的連通性動(dòng)作與預(yù)期結(jié)果代碼寫完了怎么確認(rèn)它真的通了分兩步先驗(yàn)證 TaoToken 統(tǒng)一通道本身可達(dá)再驗(yàn)證 Socket 客戶端能連上你的服務(wù)端。第一步用命令行驗(yàn)證 TaoToken 通道。打開 cmd執(zhí)行curl -X POST https://taotoken.net/api/v1/chat/completions ^ -H Authorization: Bearer sk-你的統(tǒng)一Key ^ -H Content-Type: application/json ^ -d {\model\:\claude-3-5-sonnet\,\messages\:[{\role\:\user\,\content\:\ping\}]}預(yù)期結(jié)果是返回一段 JSON包含choices字段和模型回復(fù)內(nèi)容。如果返回 401說明 Key 不對返回 404檢查路徑是不是/api/v1/chat/completions。這一步通了說明統(tǒng)一 Key 和 API 通道沒問題。想更直觀地看模型返回可以直接用模型對話頁面 https://taotoken.net/chat?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 手動(dòng)發(fā)一條消息對照。第二步驗(yàn)證 Socket 客戶端。寫一個(gè)控制臺入口連上后發(fā)一條消息觀察回調(diào)class Program { static void Main() { var client new AsyncSocketClient(); client.OnConnectionChanged ok Console.WriteLine(連接狀態(tài): ok); client.OnMessage msg Console.WriteLine(收到: msg); client.Connect(); Console.WriteLine(按回車發(fā)送測試消息...); Console.ReadLine(); client.Send(hello from .net 3.5 client); Console.ReadLine(); client.Close(); } }預(yù)期輸出順序是先打印「連接狀態(tài): True」然后你回車后服務(wù)端如果回顯會(huì)打印「收到: ...」。如果一直停在「連接狀態(tài): False」說明Socket.Host和Socket.Port指向的服務(wù)端沒起來或者防火墻攔了。實(shí)測下來最容易出問題的是端口寫錯(cuò)和DnsEndPoint解析失敗先在本地用telnet 127.0.0.1 9000確認(rèn)端口通不通。提示如果你暫時(shí)沒有自己的 Socket 服務(wù)端可以先用一個(gè)本地TcpListener起個(gè)回顯服務(wù)來驗(yàn)證客戶端邏輯確認(rèn)收發(fā)和重連都正常后再換成真實(shí)服務(wù)端。5. 本篇常見錯(cuò)排查老框架下跑這套代碼報(bào)錯(cuò)集中在幾個(gè)地方我按出現(xiàn)頻率排一下。第一個(gè)是編譯期報(bào)「未能找到類型或命名空間名稱 SocketAsyncEventArgs」。這通常是因?yàn)轫?xiàng)目目標(biāo)框架不是 .NET 3.5或者引用了錯(cuò)誤的System.dll。檢查項(xiàng)目屬性里的目標(biāo)框架確認(rèn)是 3.5并且System引用正常。第二個(gè)是運(yùn)行時(shí)SocketException: 由于目標(biāo)計(jì)算機(jī)積極拒絕無法連接。這是服務(wù)端沒監(jiān)聽對應(yīng)端口不是客戶端代碼問題。用netstat -ano | findstr 9000看端口有沒有被監(jiān)聽。第三個(gè)是重連風(fēng)暴。如果ScheduleReconnect里沒有_reconnectCount上限斷線后會(huì)無限重試日志刷屏。上面代碼里加了MaxReconnect但真實(shí)項(xiàng)目建議再加指數(shù)退避比如延遲按ReconnectDelayMs * (1 _reconnectCount)增長。第四個(gè)是SetBuffer復(fù)用導(dǎo)致的臟數(shù)據(jù)。_sendArgs和_receiveArgs是復(fù)用的如果發(fā)送時(shí)數(shù)據(jù)長度小于上次BytesTransferred可能讀到舊內(nèi)容。解決辦法是每次發(fā)送都重新SetBuffer接收時(shí)嚴(yán)格按e.BytesTransferred截取不要讀整個(gè) buffer。第五個(gè)是ConfigurationManager讀不到配置。老項(xiàng)目里app.config必須和 exe 同名同目錄單元測試項(xiàng)目里讀的是App.config而不是app.config大小寫和文件名都要對。第六個(gè)是跨線程更新 UI。OnMessage回調(diào)跑在 IO 線程上如果直接更新 WinForm 控件會(huì)拋「線程間操作無效」。用Control.Invoke或BeginInvoke包一層。6. 接入之后把統(tǒng)一通道用起來連通性驗(yàn)證通過后下一步就是把 TaoToken 的能力真正接進(jìn)業(yè)務(wù)。如果你只是偶爾調(diào)一下模型做驗(yàn)證用模型對話頁面最省事如果是長期在 IDE 里做編碼輔助、或者要跑 Agent 類任務(wù)建議直接上 Coding Plan把統(tǒng)一 Key 配進(jìn)開發(fā)工具省去每次手動(dòng)拼請求的麻煩。Coding Plan 的入口在 https://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 配置方式文檔里有說明?；氐?Socket 本身這套骨架只是起點(diǎn)。真實(shí)項(xiàng)目里你至少還要補(bǔ)三塊粘包拆包按長度前綴或分隔符切分、心跳保活定時(shí)發(fā) ping超時(shí)判定斷線、以及發(fā)送隊(duì)列避免多線程同時(shí)SendAsync導(dǎo)致SocketAsyncEventArgs被并發(fā)復(fù)用。這三塊補(bǔ)上客戶端才算能在生產(chǎn)環(huán)境跑。最后留一個(gè)我踩過的坑SocketAsyncEventArgs的Completed事件在同步完成時(shí)不會(huì)觸發(fā)所以每次調(diào)用ConnectAsync、ReceiveAsync、SendAsync后都要判斷返回值false就手動(dòng)調(diào)一次回調(diào)。上面代碼里每處都做了這個(gè)判斷漏掉任何一處都會(huì)導(dǎo)致「有時(shí)候通、有時(shí)候卡死」的詭異現(xiàn)象。 TaoToken 統(tǒng)一 Key 接入 .NET 3.5 異步 Socket 客戶端：SocketAsyncEventArgs 配置骨架與連通性驗(yàn)證
1. 老項(xiàng)目里那套 Socket 客戶端為什么還要折騰.NET 3.5 的異步 Socket 客戶端放到今天依然有它的生存空間。很多工控上位機(jī)、老 ERP 插件、桌面采集端還鎖在 3.5 框架上升級一次成本高得嚇人但業(yè)務(wù)又要求把數(shù)據(jù)往統(tǒng)一通道上送。這時(shí)候你手里能用的牌不多BeginConnect/EndConnect那套 APM 寫起來回調(diào)套回調(diào)Thread加阻塞Receive又容易把 UI 卡死。SocketAsyncEventArgs是 3.5 里少數(shù)既能扛并發(fā)、又不依賴新框架的異步模型它把一次連接、一次收發(fā)都抽象成一個(gè)可復(fù)用的事件參數(shù)對象配合對象池能顯著減少 GC 壓力。這篇聚焦的是「客戶端」側(cè)用SocketAsyncEventArgs寫一個(gè)能連、能收、能發(fā)、斷了能重連的最小骨架并且把 TaoToken 統(tǒng)一 Key 和 API 通道的配置放進(jìn)app.config讓老框架項(xiàng)目不用改架構(gòu)就能接入統(tǒng)一通道。適合誰手上維護(hù)著 .NET 3.5 項(xiàng)目、需要把設(shè)備數(shù)據(jù)或業(yè)務(wù)請求走統(tǒng)一 API 通道的開發(fā)者。讀完你能拿到一份可直接粘貼的配置骨架、一段可運(yùn)行的客戶端代碼以及一次明確的連通性驗(yàn)證動(dòng)作和預(yù)期結(jié)果。需要先說明一點(diǎn)TaoToken 在這里扮演的是「統(tǒng)一 Key API 通道」的角色客戶端通過它去訪問模型對話、Coding Plan 等能力而不是替代你的 Socket 通信本身。Socket 負(fù)責(zé)傳輸TaoToken 負(fù)責(zé)鑒權(quán)和路由兩者是配合關(guān)系。2. TaoToken 前置統(tǒng)一 Key 與 API 通道怎么擺進(jìn) app.config在動(dòng)手寫 Socket 之前先把配置層理清楚。老項(xiàng)目最忌諱把 Key 硬編碼進(jìn).cs文件一旦要換環(huán)境就得重新編譯。app.config的appSettings是最省事的落點(diǎn)3.5 原生支持讀取用ConfigurationManager.AppSettings即可。你需要先在 TaoToken 控制臺拿到統(tǒng)一 Key。入口在官網(wǎng) https://taotoken.net/?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 登錄后進(jìn)控制臺創(chuàng)建 API Key具體頁面是 https://taotoken.net/console?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 。Key 的管理和查看在 https://taotoken.net/api-keys?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 接入細(xì)節(jié)看文檔 https://taotoken.net/doc?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 。API 基地址是 https://taotoken.net/api 注意這個(gè)地址不帶任何查詢參數(shù)配置里直接寫死即可。配置骨架長這樣我把它拆成「通道地址」「鑒權(quán)」「Socket 行為」三組方便你按環(huán)境替換?xml version1.0 encodingutf-8? configuration appSettings !-- TaoToken 統(tǒng)一通道 -- add keyTaoToken.ApiBase valuehttps://taotoken.net/api / add keyTaoToken.ApiKey valuesk-你的統(tǒng)一Key / add keyTaoToken.Model valueclaude-3-5-sonnet / !-- Socket 客戶端行為 -- add keySocket.Host value127.0.0.1 / add keySocket.Port value9000 / add keySocket.ConnectTimeoutMs value5000 / add keySocket.BufferSize value8192 / add keySocket.ReconnectDelayMs value3000 / add keySocket.MaxReconnect value5 / /appSettings /configuration注意TaoToken.ApiKey不要提交到版本庫。老項(xiàng)目常用做法是放一份app.config.template真實(shí) Key 由部署腳本注入或者用機(jī)器級環(huán)境變量覆蓋。讀取封裝一個(gè)靜態(tài)類避免到處寫字符串public static class AppConfig { public static string ApiBase { get { return ConfigurationManager.AppSettings[TaoToken.ApiBase]; } } public static string ApiKey { get { return ConfigurationManager.AppSettings[TaoToken.ApiKey]; } } public static string Host { get { return ConfigurationManager.AppSettings[Socket.Host]; } } public static int Port { get { return int.Parse(ConfigurationManager.AppSettings[Socket.Port]); } } public static int BufferSize { get { return int.Parse(ConfigurationManager.AppSettings[Socket.BufferSize]); } } public static int ReconnectDelayMs { get { return int.Parse(ConfigurationManager.AppSettings[Socket.ReconnectDelayMs]); } } public static int MaxReconnect { get { return int.Parse(ConfigurationManager.AppSettings[Socket.MaxReconnect]); } } }這里有個(gè)容易忽略的點(diǎn).NET 3.5 的ConfigurationManager在System.Configuration程序集里項(xiàng)目引用里要手動(dòng)加上否則編譯報(bào)「找不到類型或命名空間」。這是老項(xiàng)目接入時(shí)第一個(gè)坑先記下。3. 可復(fù)制配置SocketAsyncEventArgs 客戶端骨架下面這段是核心。設(shè)計(jì)思路是一個(gè)AsyncSocketClient類持有Socket實(shí)例用兩個(gè)SocketAsyncEventArgs分別負(fù)責(zé)收和發(fā)連接、接收、發(fā)送都走SocketAsyncEventArgs的完成回調(diào)。斷線重連用一個(gè)簡單的重試計(jì)數(shù)加定時(shí)器。先看連接部分。ConnectAsync在 3.5 里通過SocketAsyncEventArgs的Completed事件回調(diào)using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; public class AsyncSocketClient { private Socket _socket; private readonly SocketAsyncEventArgs _connectArgs; private readonly SocketAsyncEventArgs _receiveArgs; private readonly SocketAsyncEventArgs _sendArgs; private readonly byte[] _receiveBuffer; private int _reconnectCount; private bool _manualClose; public event Actionstring OnMessage; public event Actionbool OnConnectionChanged; public AsyncSocketClient() { _receiveBuffer new byte[AppConfig.BufferSize]; _connectArgs new SocketAsyncEventArgs(); _connectArgs.RemoteEndPoint new DnsEndPoint(AppConfig.Host, AppConfig.Port); _connectArgs.Completed OnConnectCompleted; _receiveArgs new SocketAsyncEventArgs(); _receiveArgs.SetBuffer(_receiveBuffer, 0, _receiveBuffer.Length); _receiveArgs.Completed OnReceiveCompleted; _sendArgs new SocketAsyncEventArgs(); _sendArgs.Completed OnSendCompleted; } public void Connect() { _manualClose false; _socket new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); bool pending _socket.ConnectAsync(_connectArgs); if (!pending) OnConnectCompleted(_socket, _connectArgs); }連接完成的回調(diào)里判斷SocketError成功就掛上接收private void OnConnectCompleted(object sender, SocketAsyncEventArgs e) { if (e.SocketError SocketError.Success) { _reconnectCount 0; RaiseConnection(true); StartReceive(); } else { RaiseConnection(false); ScheduleReconnect(); } } private void StartReceive() { if (_socket null) return; bool pending _socket.ReceiveAsync(_receiveArgs); if (!pending) OnReceiveCompleted(_socket, _receiveArgs); }接收回調(diào)是數(shù)據(jù)入口注意BytesTransferred 0表示對端關(guān)閉要觸發(fā)重連private void OnReceiveCompleted(object sender, SocketAsyncEventArgs e) { if (e.SocketError SocketError.Success e.BytesTransferred 0) { string msg Encoding.UTF8.GetString(e.Buffer, e.Offset, e.BytesTransferred); if (OnMessage ! null) OnMessage(msg); StartReceive(); } else { RaiseConnection(false); ScheduleReconnect(); } }發(fā)送部分把待發(fā)數(shù)據(jù)拷進(jìn)SocketAsyncEventArgs的緩沖。3.5 里沒有Memory用SetBuffer加偏移即可public void Send(string text) { if (_socket null || !_socket.Connected) return; byte[] data Encoding.UTF8.GetBytes(text); _sendArgs.SetBuffer(data, 0, data.Length); bool pending _socket.SendAsync(_sendArgs); if (!pending) OnSendCompleted(_socket, _sendArgs); } private void OnSendCompleted(object sender, SocketAsyncEventArgs e) { if (e.SocketError ! SocketError.Success) { RaiseConnection(false); ScheduleReconnect(); } }重連用Timer做延遲避免斷線瞬間瘋狂重試private void ScheduleReconnect() { if (_manualClose) return; if (_reconnectCount AppConfig.MaxReconnect) return; _reconnectCount; Timer t null; t new Timer(state { t.Dispose(); try { Connect(); } catch { ScheduleReconnect(); } }, null, AppConfig.ReconnectDelayMs, Timeout.Infinite); } private void RaiseConnection(bool ok) { if (OnConnectionChanged ! null) OnConnectionChanged(ok); } public void Close() { _manualClose true; if (_socket ! null) { try { _socket.Shutdown(SocketShutdown.Both); } catch { } _socket.Close(); _socket null; } } }這段骨架刻意保持最小沒有做粘包拆包沒有做心跳。真實(shí)項(xiàng)目里這兩塊必須補(bǔ)但那是另一個(gè)話題先把連通性跑通。4. 驗(yàn)證請求一次可執(zhí)行的連通性動(dòng)作與預(yù)期結(jié)果代碼寫完了怎么確認(rèn)它真的通了分兩步先驗(yàn)證 TaoToken 統(tǒng)一通道本身可達(dá)再驗(yàn)證 Socket 客戶端能連上你的服務(wù)端。第一步用命令行驗(yàn)證 TaoToken 通道。打開 cmd執(zhí)行curl -X POST https://taotoken.net/api/v1/chat/completions ^ -H Authorization: Bearer sk-你的統(tǒng)一Key ^ -H Content-Type: application/json ^ -d {\model\:\claude-3-5-sonnet\,\messages\:[{\role\:\user\,\content\:\ping\}]}預(yù)期結(jié)果是返回一段 JSON包含choices字段和模型回復(fù)內(nèi)容。如果返回 401說明 Key 不對返回 404檢查路徑是不是/api/v1/chat/completions。這一步通了說明統(tǒng)一 Key 和 API 通道沒問題。想更直觀地看模型返回可以直接用模型對話頁面 https://taotoken.net/chat?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 手動(dòng)發(fā)一條消息對照。第二步驗(yàn)證 Socket 客戶端。寫一個(gè)控制臺入口連上后發(fā)一條消息觀察回調(diào)class Program { static void Main() { var client new AsyncSocketClient(); client.OnConnectionChanged ok Console.WriteLine(連接狀態(tài): ok); client.OnMessage msg Console.WriteLine(收到: msg); client.Connect(); Console.WriteLine(按回車發(fā)送測試消息...); Console.ReadLine(); client.Send(hello from .net 3.5 client); Console.ReadLine(); client.Close(); } }預(yù)期輸出順序是先打印「連接狀態(tài): True」然后你回車后服務(wù)端如果回顯會(huì)打印「收到: ...」。如果一直停在「連接狀態(tài): False」說明Socket.Host和Socket.Port指向的服務(wù)端沒起來或者防火墻攔了。實(shí)測下來最容易出問題的是端口寫錯(cuò)和DnsEndPoint解析失敗先在本地用telnet 127.0.0.1 9000確認(rèn)端口通不通。提示如果你暫時(shí)沒有自己的 Socket 服務(wù)端可以先用一個(gè)本地TcpListener起個(gè)回顯服務(wù)來驗(yàn)證客戶端邏輯確認(rèn)收發(fā)和重連都正常后再換成真實(shí)服務(wù)端。5. 本篇常見錯(cuò)排查老框架下跑這套代碼報(bào)錯(cuò)集中在幾個(gè)地方我按出現(xiàn)頻率排一下。第一個(gè)是編譯期報(bào)「未能找到類型或命名空間名稱 SocketAsyncEventArgs」。這通常是因?yàn)轫?xiàng)目目標(biāo)框架不是 .NET 3.5或者引用了錯(cuò)誤的System.dll。檢查項(xiàng)目屬性里的目標(biāo)框架確認(rèn)是 3.5并且System引用正常。第二個(gè)是運(yùn)行時(shí)SocketException: 由于目標(biāo)計(jì)算機(jī)積極拒絕無法連接。這是服務(wù)端沒監(jiān)聽對應(yīng)端口不是客戶端代碼問題。用netstat -ano | findstr 9000看端口有沒有被監(jiān)聽。第三個(gè)是重連風(fēng)暴。如果ScheduleReconnect里沒有_reconnectCount上限斷線后會(huì)無限重試日志刷屏。上面代碼里加了MaxReconnect但真實(shí)項(xiàng)目建議再加指數(shù)退避比如延遲按ReconnectDelayMs * (1 _reconnectCount)增長。第四個(gè)是SetBuffer復(fù)用導(dǎo)致的臟數(shù)據(jù)。_sendArgs和_receiveArgs是復(fù)用的如果發(fā)送時(shí)數(shù)據(jù)長度小于上次BytesTransferred可能讀到舊內(nèi)容。解決辦法是每次發(fā)送都重新SetBuffer接收時(shí)嚴(yán)格按e.BytesTransferred截取不要讀整個(gè) buffer。第五個(gè)是ConfigurationManager讀不到配置。老項(xiàng)目里app.config必須和 exe 同名同目錄單元測試項(xiàng)目里讀的是App.config而不是app.config大小寫和文件名都要對。第六個(gè)是跨線程更新 UI。OnMessage回調(diào)跑在 IO 線程上如果直接更新 WinForm 控件會(huì)拋「線程間操作無效」。用Control.Invoke或BeginInvoke包一層。6. 接入之后把統(tǒng)一通道用起來連通性驗(yàn)證通過后下一步就是把 TaoToken 的能力真正接進(jìn)業(yè)務(wù)。如果你只是偶爾調(diào)一下模型做驗(yàn)證用模型對話頁面最省事如果是長期在 IDE 里做編碼輔助、或者要跑 Agent 類任務(wù)建議直接上 Coding Plan把統(tǒng)一 Key 配進(jìn)開發(fā)工具省去每次手動(dòng)拼請求的麻煩。Coding Plan 的入口在 https://taotoken.net/coding-plan?utm_sourcetaotoken_aicg_blog_endutm_mediumcsdnutm_campaignrewriteutm_content 配置方式文檔里有說明?；氐?Socket 本身這套骨架只是起點(diǎn)。真實(shí)項(xiàng)目里你至少還要補(bǔ)三塊粘包拆包按長度前綴或分隔符切分、心跳保活定時(shí)發(fā) ping超時(shí)判定斷線、以及發(fā)送隊(duì)列避免多線程同時(shí)SendAsync導(dǎo)致SocketAsyncEventArgs被并發(fā)復(fù)用。這三塊補(bǔ)上客戶端才算能在生產(chǎn)環(huán)境跑。最后留一個(gè)我踩過的坑SocketAsyncEventArgs的Completed事件在同步完成時(shí)不會(huì)觸發(fā)所以每次調(diào)用ConnectAsync、ReceiveAsync、SendAsync后都要判斷返回值false就手動(dòng)調(diào)一次回調(diào)。上面代碼里每處都做了這個(gè)判斷漏掉任何一處都會(huì)導(dǎo)致「有時(shí)候通、有時(shí)候卡死」的詭異現(xiàn)象。