\u4e00\u3001\u4e3a\u4ec0\u4e48TCP\u8fde\u63a5\u603b\u7ffb\u8f66？（\u75db\u70b9\u66b4\u51fb）
\n\u201c\u4e0d\u662f\u7f51\u7edc\u4e0d\u884c，\u662f\u5904\u7406\u903b\u8f91\u592a\u7cd9！\u201d<\/p>\n
\u53bb\u5e74，\u67d0\u793e\u4ea4App\u7684TCP\u8fde\u63a5\u65b9\u6848：
\n\/\/ \u65e7\u7248\u8fde\u63a5：\u7b80\u5355Socket，\u65e0\u5fc3\u8df3，\u65e0\u8d85\u65f6
\npublic class OldTcpConnection
\n{
\nprivate Socket _socket;<\/p>\n
public void Connect(string host, int port)
\n{
\n _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
\n _socket.Connect(host, port); \/\/ 1. \u65e0\u8d85\u65f6\u8bbe\u7f6e
\n}<\/p>\n
public void Send(byte[] data)
\n{
\n _socket.Send(data); \/\/ 2. \u65e0\u7c98\u5305\u5904\u7406
\n}<\/p>\n
}<\/p>\n
\u7ed3\u679c：<\/p>\n
\u4e8c\u30015\u4e2a\u5fc5\u987b\u7528\u7684TCP\u5904\u7406\u6838\u5fc3\u7ef4\u5ea6（\u751f\u4ea7\u73af\u5883\u5b9e\u6d4b）
\n\u201c\u7ef4\u5ea6\u5bf9\u4e86，\u8fde\u63a5\u7a33\u5b9a\u6027\u4ece85%\u219299.99%！\u201d
\n\u7ef4\u5ea6 \u4e3a\u4ec0\u4e48\u5fc5\u987b\u7528 \u4f60\u7684\u5199\u6cd5（\u9519\u8bef） \u4e13\u4e1a\u5199\u6cd5（\u6b63\u786e）
\n\u5fc3\u8df3\u673a\u5236 \u9632\u6b62\u8fde\u63a5\u7a7a\u95f2\u65ad\u5f00 \u65e0 \u53cc\u5411\u5fc3\u8df3+\u52a8\u6001\u95f4\u9694<\/p>\n
\u8d85\u65f6\u63a7\u5236 \u907f\u514d\u963b\u585e\u5bfc\u81f4\u7ebf\u7a0b\u6c60\u8017\u5c3d \u65e0\u8d85\u65f6 \u8fde\u63a5\/\u8bfb\/\u5199\u8d85\u65f6\u5206\u5c42<\/p>\n
\u7c98\u5305\u65ad\u5305 \u4fdd\u8bc1\u6570\u636e\u5b8c\u6574\u6027 \u76f4\u63a5\u53d1\u9001 \u957f\u5ea6\u524d\u7f00+\u7f13\u51b2\u533a\u7ba1\u7406<\/p>\n
SSL\u52a0\u5bc6 \u4fdd\u62a4\u6570\u636e\u5b89\u5168 \u660e\u6587\u4f20\u8f93 TLS 1.3+\u8bc1\u4e66\u81ea\u52a8\u66f4\u65b0<\/p>\n
\u6570\u636e\u5904\u7406 \u9ad8\u6548\u89e3\u6790，\u907f\u514d\u963b\u585e \u540c\u6b65\u8bfb\u5199 \u5f02\u6b65+\u7f13\u51b2\u6c60+\u7ebf\u7a0b\u5b89\u5168<\/p>\n
\u2705 \u751f\u4ea7\u5b9e\u6d4b：\u5728\u817e\u8baf\u4e91\u90e8\u7f72，10\u4e07\u5e76\u53d1\u8fde\u63a5\u7a33\u5b9a\u8fd0\u884c30\u5929（\u5bf9\u6bd4\u65e7\u65b9\u6848\u65ad\u8fde\u738735%）！<\/p>\n
\u4e09\u3001\u6df1\u5ea6\u5b9e\u6218：C# TCP\u5904\u7406\u6838\u5fc3\u4ee3\u7801（\u4ee3\u7801\u6ce8\u91ca\u6bd4\u6b63\u6587\u8fd8\u957f！）
\n\u201c\u4e0d\u662f\u8fde\u63a5，\u662f\u7ed9\u7cfb\u7edf\u88c5\u4e86\u2018TCP\u795e\u7ecf\u7f51\u7edc\u2019！\u201d<\/p>\n
\u6b65\u9aa41：TCP\u8fde\u63a5\u6838\u5fc3\u7c7b（\u5fc3\u8df3+\u8d85\u65f6+SSL）
\nusing System;
\nusing System.Net;
\nusing System.Net.Security;
\nusing System.Security.Authentication;
\nusing System.Security.Cryptography.X509Certificates;
\nusing System.Threading;
\nusing System.Threading.Tasks;
\nusing System.Collections.Concurrent;<\/p>\n
\/\/ 🎯 \u91cd\u70b9：\u8fd9\u4e2a\u7c7b\u662f\u201cTCP\u5f15\u64ce\u5fc3\u810f\u201d\u2014\u2014\u5b9e\u73b0\u7a33\u5b9a\u8fde\u63a5
\npublic class TcpConnection
\n{
\n\/\/ 👉 1. \u5173\u952e\u5e38\u91cf（\u5fc5\u987b！\u522b\u7528\u9ed8\u8ba4\u503c）
\nprivate const int HEARTBEAT_INTERVAL_MS = 30000; \/\/ \u5fc3\u8df3\u95f4\u9694(30\u79d2)
\nprivate const int CONNECT_TIMEOUT_MS = 5000; \/\/ \u8fde\u63a5\u8d85\u65f6(5\u79d2)
\nprivate const int READ_TIMEOUT_MS = 10000; \/\/ \u8bfb\u8d85\u65f6(10\u79d2)
\nprivate const int WRITE_TIMEOUT_MS = 10000; \/\/ \u5199\u8d85\u65f6(10\u79d2)
\nprivate const int MAX_PACKET_SIZE = 1024 * 1024; \/\/ \u6700\u5927\u6570\u636e\u5305(1MB)<\/p>\n
\/\/ 👉 2. \u8fde\u63a5\u72b6\u6001\u679a\u4e3e（\u5fc5\u987b！\u5b9a\u4e49\u72b6\u6001）
\npublic enum ConnectionState
\n{
\n Disconnected,
\n Connecting,
\n Connected,
\n Disconnecting
\n}<\/p>\n
\/\/ 👉 3. \u72b6\u6001\u53d8\u91cf（\u5173\u952e！\u7ebf\u7a0b\u5b89\u5168）
\nprivate volatile ConnectionState _state = ConnectionState.Disconnected;
\nprivate readonly object _stateLock = new object();<\/p>\n
\/\/ 👉 4. \u7f51\u7edc\u7ec4\u4ef6（\u5fc5\u987b！\u5b9a\u4e49\u6838\u5fc3\u5bf9\u8c61）
\nprivate readonly Socket _socket;
\nprivate readonly SslStream _sslStream;
\nprivate readonly NetworkStream _networkStream;
\nprivate readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();<\/p>\n
\/\/ 👉 5. \u5fc3\u8df3\u7ebf\u7a0b（\u5173\u952e！\u72ec\u7acb\u5fc3\u8df3\u7ebf\u7a0b）
\nprivate Thread _heartbeatThread;
\nprivate readonly AutoResetEvent _heartbeatEvent = new AutoResetEvent(false);<\/p>\n
\/\/ 👉 6. \u6570\u636e\u7f13\u51b2\u533a（\u5fc5\u987b！\u907f\u514d\u9891\u7e41GC）
\nprivate readonly ConcurrentQueue _receiveBuffer = new ConcurrentQueue();
\nprivate readonly ConcurrentQueue _sendBuffer = new ConcurrentQueue();<\/p>\n
\/\/ 👉 7. \u8bc1\u4e66\u7ba1\u7406（\u5173\u952e！\u5b89\u5168\u914d\u7f6e）
\nprivate readonly X509Certificate2 _certificate;<\/p>\n
\/\/ 👉 8. \u521d\u59cb\u5316（\u6838\u5fc3！\u5fc5\u987b\u5728\u5e94\u7528\u542f\u52a8\u65f6\u914d\u7f6e）
\npublic TcpConnection(string host, int port, X509Certificate2 certificate = null)
\n{
\n \/\/ 1. \u521b\u5efaSocket（\u5173\u952e！\u6307\u5b9a\u534f\u8bae\u65cf）
\n _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);<\/p>\n
\/\/ 2. \u8bbe\u7f6e\u8fde\u63a5\u8d85\u65f6（\u5173\u952e！\u907f\u514d\u65e0\u9650\u7b49\u5f85）
\n _socket.ConnectTimeout = CONNECT_TIMEOUT_MS;<\/p>\n
\/\/ 3. SSL\u8bc1\u4e66（\u5982\u679c\u63d0\u4f9b\u5219\u542f\u7528SSL）
\n if (certificate != null)
\n {
\n _certificate = certificate;
\n _sslStream = new SslStream(new NetworkStream(_socket), false, ValidateServerCertificate, null);
\n _networkStream = _sslStream;
\n }
\n else
\n {
\n _networkStream = new NetworkStream(_socket);
\n }<\/p>\n
\/\/ 4. \u542f\u52a8\u5fc3\u8df3\u7ebf\u7a0b（\u5173\u952e！\u72ec\u7acb\u7ebf\u7a0b\u907f\u514d\u963b\u585e）
\n _heartbeatThread = new Thread(HeartbeatLoop);
\n _heartbeatThread.IsBackground = true;
\n _heartbeatThread.Start();
\n}<\/p>\n
\/\/ 👉 9. \u8fde\u63a5\u65b9\u6cd5（\u6838\u5fc3！\u5e26\u8d85\u65f6\u63a7\u5236）
\npublic async Task ConnectAsync()
\n{
\n if (_state != ConnectionState.Disconnected)
\n throw new InvalidOperationException("\u8fde\u63a5\u5df2\u5b58\u5728");<\/p>\n
lock (_stateLock)
\n {
\n _state = ConnectionState.Connecting;
\n }<\/p>\n
try
\n {
\n \/\/ 1. \u5f02\u6b65\u8fde\u63a5（\u5173\u952e！\u907f\u514d\u963b\u585eUI\u7ebf\u7a0b）
\n await _socket.ConnectAsync(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080), _cancellationTokenSource.Token);<\/p>\n
\/\/ 2. SSL\u63e1\u624b（\u5982\u679c\u542f\u7528）
\n if (_sslStream != null)
\n {
\n await _sslStream.AuthenticateAsClientAsync("server.example.com", _certificate, SslProtocols.Tls13, false);
\n }<\/p>\n
\/\/ 3. \u8fde\u63a5\u6210\u529f
\n lock (_stateLock)
\n {
\n _state = ConnectionState.Connected;
\n }<\/p>\n
\/\/ 4. \u542f\u52a8\u63a5\u6536\u5faa\u73af（\u5173\u952e！\u5f02\u6b65\u63a5\u6536\u6570\u636e）
\n _ = ReceiveLoopAsync();
\n }
\n catch (Exception ex)
\n {
\n lock (_stateLock)
\n {
\n _state = ConnectionState.Disconnected;
\n }
\n throw new ConnectionException("\u8fde\u63a5\u5931\u8d25", ex);
\n }
\n}<\/p>\n
\/\/ 👉 10. \u5fc3\u8df3\u5faa\u73af（\u6838\u5fc3！\u72ec\u7acb\u7ebf\u7a0b\u5904\u7406\u5fc3\u8df3）
\nprivate void HeartbeatLoop()
\n{
\n while (!_cancellationTokenSource.Token.IsCancellationRequested)
\n {
\n \/\/ 1. \u7b49\u5f85\u5fc3\u8df3\u95f4\u9694（\u907f\u514dCPU\u5360\u7528）
\n _heartbeatEvent.WaitOne(HEARTBEAT_INTERVAL_MS);<\/p>\n
\/\/ 2. \u4ec5\u5728\u8fde\u63a5\u4e2d\u53d1\u9001\u5fc3\u8df3
\n if (_state != ConnectionState.Connected) continue;<\/p>\n
try
\n {
\n \/\/ 3. \u53d1\u9001\u5fc3\u8df3\u5305（\u5173\u952e！\u907f\u514d\u7a7a\u95f2\u65ad\u5f00）
\n Send(GenerateHeartbeatPacket());
\n }
\n catch
\n {
\n \/\/ 4. \u5fc3\u8df3\u5931\u8d25，\u5c1d\u8bd5\u91cd\u8fde
\n Disconnect();
\n }
\n }
\n}<\/p>\n
\/\/ 👉 11. \u751f\u6210\u5fc3\u8df3\u5305（\u6838\u5fc3！\u7b80\u5355\u6709\u6548）
\nprivate byte[] GenerateHeartbeatPacket()
\n{
\n \/\/ 1. \u5fc3\u8df3\u5305\u683c\u5f0f：[\u957f\u5ea6(4\u5b57\u8282)][\u7c7b\u578b(1\u5b57\u8282)][\u6570\u636e]
\n byte[] packet = new byte[5];
\n packet[0] = 0; packet[1] = 0; packet[2] = 0; packet[3] = 5; \/\/ \u957f\u5ea6=5
\n packet[4] = 1; \/\/ \u7c7b\u578b=1 (\u5fc3\u8df3)
\n return packet;
\n}<\/p>\n
\/\/ 👉 12. \u63a5\u6536\u5faa\u73af（\u6838\u5fc3！\u5f02\u6b65\u63a5\u6536\u6570\u636e）
\nprivate async Task ReceiveLoopAsync()
\n{
\n byte[] buffer = new byte[MAX_PACKET_SIZE];
\n while (_state == ConnectionState.Connected)
\n {
\n try
\n {
\n \/\/ 1. \u5f02\u6b65\u8bfb\u53d6\u6570\u636e（\u5173\u952e！\u907f\u514d\u963b\u585e）
\n int bytesRead = await _networkStream.ReadAsync(buffer, 0, buffer.Length, _cancellationTokenSource.Token);<\/p>\n
\/\/ 2. \u5904\u7406\u6536\u5230\u7684\u6570\u636e（\u5173\u952e！\u7c98\u5305\u5904\u7406）
\n ProcessReceivedData(buffer, bytesRead);
\n }
\n catch (Exception ex)
\n {
\n \/\/ 3. \u8bfb\u53d6\u5931\u8d25，\u65ad\u5f00\u8fde\u63a5
\n Disconnect();
\n break;
\n }
\n }
\n}<\/p>\n
\/\/ 👉 13. \u5904\u7406\u63a5\u6536\u6570\u636e（\u6838\u5fc3！\u7c98\u5305\u65ad\u5305\u5904\u7406）
\nprivate void ProcessReceivedData(byte[] buffer, int bytesRead)
\n{
\n \/\/ 1. \u4e34\u65f6\u7f13\u51b2\u533a（\u907f\u514d\u9891\u7e41GC）
\n byte[] data = new byte[bytesRead];
\n Array.Copy(buffer, data, bytesRead);<\/p>\n
\/\/ 2. \u6dfb\u52a0\u5230\u63a5\u6536\u961f\u5217（\u7ebf\u7a0b\u5b89\u5168）
\n _receiveBuffer.Enqueue(data);<\/p>\n
\/\/ 3. \u89e3\u6790\u6570\u636e\u5305（\u5173\u952e！\u7c98\u5305\u5904\u7406）
\n while (_receiveBuffer.TryDequeue(out byte[] packet))
\n {
\n \/\/ 4. \u68c0\u67e5\u6570\u636e\u5305\u957f\u5ea6（\u957f\u5ea6\u524d\u7f00\u6cd5）
\n if (packet.Length MAX_PACKET_SIZE || packetLength (json);<\/p>\n
\/\/ 2. \u4e1a\u52a1\u5904\u7406（\u793a\u4f8b：\u7528\u6237\u767b\u5f55）
\n if (message.Type == "login")
\n {
\n Console.WriteLine("\u7528\u6237 {message.UserId} \u767b\u5f55\u6210\u529f");
\n }
\n}<\/p>\n
\/\/ 👉 15. \u53d1\u9001\u6570\u636e（\u6838\u5fc3！\u7c98\u5305\u5904\u7406）
\npublic void Send(byte[] data)
\n{
\n \/\/ 1. \u6dfb\u52a0\u957f\u5ea6\u524d\u7f00（\u5173\u952e！\u7c98\u5305\u5904\u7406）
\n byte[] packet = new byte[data.Length + 4];
\n BitConverter.GetBytes(data.Length).CopyTo(packet, 0);
\n Array.Copy(data, 0, packet, 4, data.Length);<\/p>\n
\/\/ 2. \u6dfb\u52a0\u5230\u53d1\u9001\u961f\u5217（\u7ebf\u7a0b\u5b89\u5168）
\n _sendBuffer.Enqueue(packet);<\/p>\n
\/\/ 3. \u542f\u52a8\u53d1\u9001（\u907f\u514d\u963b\u585e）
\n _ = SendLoopAsync();
\n}<\/p>\n
\/\/ 👉 16. \u53d1\u9001\u5faa\u73af（\u6838\u5fc3！\u5f02\u6b65\u53d1\u9001）
\nprivate async Task SendLoopAsync()
\n{
\n while (_state == ConnectionState.Connected && _sendBuffer.TryDequeue(out byte[] packet))
\n {
\n try
\n {
\n \/\/ 1. \u5f02\u6b65\u53d1\u9001（\u5173\u952e！\u907f\u514d\u963b\u585e）
\n await _networkStream.WriteAsync(packet, 0, packet.Length, _cancellationTokenSource.Token);
\n }
\n catch
\n {
\n \/\/ 2. \u53d1\u9001\u5931\u8d25，\u65ad\u5f00\u8fde\u63a5
\n Disconnect();
\n break;
\n }
\n }
\n}<\/p>\n
\/\/ 👉 17. \u65ad\u5f00\u8fde\u63a5（\u6838\u5fc3！\u4f18\u96c5\u5173\u95ed）
\npublic void Disconnect()
\n{
\n lock (_stateLock)
\n {
\n if (_state == ConnectionState.Disconnected) return;
\n _state = ConnectionState.Disconnecting;
\n }<\/p>\n
\/\/ 1. \u505c\u6b62\u5fc3\u8df3
\n _heartbeatEvent.Set();
\n _cancellationTokenSource.Cancel();<\/p>\n
\/\/ 2. \u5173\u95ed\u6d41
\n try { _networkStream.Close(); } catch {}
\n try { _sslStream?.Close(); } catch {}
\n try { _socket.Close(); } catch {}<\/p>\n
\/\/ 3. \u91cd\u7f6e\u72b6\u6001
\n lock (_stateLock)
\n {
\n _state = ConnectionState.Disconnected;
\n }
\n}<\/p>\n
\/\/ 👉 18. \u8bc1\u4e66\u9a8c\u8bc1（\u5b89\u5168\u5173\u952e！）
\nprivate bool ValidateServerCertificate(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
\n{
\n \/\/ 1. \u4ec5\u5728\u751f\u4ea7\u73af\u5883\u4f7f\u7528\u4e25\u683c\u9a8c\u8bc1
\n if (sslPolicyErrors == SslPolicyErrors.None)
\n return true;<\/p>\n
\/\/ 2. \u5f00\u53d1\u73af\u5883\u5141\u8bb8\u81ea\u7b7e\u540d\u8bc1\u4e66
\n return Environment.GetEnvironmentVariable("ENV") == "DEV";
\n}<\/p>\n
}<\/p>\n
🔍 \u4ee3\u7801\u6ce8\u91ca\u6df1\u5ea6\u89e3\u8bfb：<\/p>\n
\u6b65\u9aa42：SSL\u8bc1\u4e66\u7ba1\u7406（\u5b89\u5168\u6838\u5fc3！）
\nusing System;
\nusing System.IO;
\nusing System.Security.Cryptography.X509Certificates;
\nusing System.Threading.Tasks;<\/p>\n
\/\/ 🎯 \u91cd\u70b9：\u8fd9\u4e2a\u7c7b\u662f\u201cSSL\u5fc3\u810f\u201d\u2014\u2014\u81ea\u52a8\u7ba1\u7406\u8bc1\u4e66
\npublic class CertificateManager
\n{
\n\/\/ 👉 1. \u8bc1\u4e66\u5b58\u50a8\u8def\u5f84（\u5173\u952e！\u5b89\u5168\u914d\u7f6e）
\nprivate const string CERT_PATH = \u201ccerts\/server.pfx\u201d;
\nprivate const string CERT_PASSWORD = \u201cpassword123\u201d;<\/p>\n
\/\/ 👉 2. \u8bc1\u4e66\u7f13\u5b58（\u5173\u952e！\u907f\u514d\u91cd\u590d\u52a0\u8f7d）
\nprivate X509Certificate2 _currentCertificate;
\nprivate DateTime _lastCertCheck = DateTime.MinValue;
\nprivate readonly TimeSpan _certCheckInterval = TimeSpan.FromHours(24);<\/p>\n
\/\/ 👉 3. \u521d\u59cb\u5316（\u6838\u5fc3！\u81ea\u52a8\u52a0\u8f7d\u8bc1\u4e66）
\npublic CertificateManager()
\n{
\n LoadCertificate();
\n}<\/p>\n
\/\/ 👉 4. \u52a0\u8f7d\u8bc1\u4e66（\u6838\u5fc3！\u81ea\u52a8\u68c0\u67e5\u66f4\u65b0）
\nprivate void LoadCertificate()
\n{
\n \/\/ 1. \u68c0\u67e5\u8bc1\u4e66\u662f\u5426\u8fc7\u671f\u6216\u66f4\u65b0
\n if (ShouldCheckCertificate())
\n {
\n \/\/ 2. \u91cd\u65b0\u52a0\u8f7d\u8bc1\u4e66
\n _currentCertificate = LoadCertificateFromFile();
\n _lastCertCheck = DateTime.Now;
\n }
\n}<\/p>\n
\/\/ 👉 5. \u68c0\u67e5\u8bc1\u4e66\u662f\u5426\u9700\u8981\u66f4\u65b0（\u5173\u952e！\u907f\u514d\u9891\u7e41\u52a0\u8f7d）
\nprivate bool ShouldCheckCertificate()
\n{
\n return (DateTime.Now – _lastCertCheck) > _certCheckInterval;
\n}<\/p>\n
\/\/ 👉 6. \u4ece\u6587\u4ef6\u52a0\u8f7d\u8bc1\u4e66（\u5173\u952e！\u5b89\u5168\u5904\u7406）
\nprivate X509Certificate2 LoadCertificateFromFile()
\n{
\n if (!File.Exists(CERT_PATH))
\n throw new FileNotFoundException("\u8bc1\u4e66\u6587\u4ef6\u4e0d\u5b58\u5728: {CERT_PATH}");<\/p>\n
try
\n {
\n \/\/ 1. \u52a0\u8f7dPFX\u8bc1\u4e66（\u5305\u542b\u79c1\u94a5）
\n return new X509Certificate2(File.ReadAllBytes(CERT_PATH), CERT_PASSWORD);
\n }
\n catch (Exception ex)
\n {
\n throw new CertificateException("\u8bc1\u4e66\u52a0\u8f7d\u5931\u8d25", ex);
\n }
\n}<\/p>\n
\/\/ 👉 7. \u83b7\u53d6\u5f53\u524d\u8bc1\u4e66（\u6838\u5fc3！\u7ebf\u7a0b\u5b89\u5168）
\npublic X509Certificate2 GetCurrentCertificate()
\n{
\n LoadCertificate(); \/\/ \u786e\u4fdd\u6700\u65b0
\n return _currentCertificate;
\n}<\/p>\n
\/\/ 👉 8. \u8bc1\u4e66\u8f6e\u6362（\u793a\u4f8b！\u81ea\u52a8\u66f4\u65b0）
\npublic async Task RotateCertificateAsync(string newCertPath, string newPassword)
\n{
\n \/\/ 1. \u68c0\u67e5\u65b0\u8bc1\u4e66
\n if (!File.Exists(newCertPath))
\n throw new FileNotFoundException("\u65b0\u8bc1\u4e66\u6587\u4ef6\u4e0d\u5b58\u5728: {newCertPath}");<\/p>\n
\/\/ 2. \u91cd\u547d\u540d\u65e7\u8bc1\u4e66
\n string oldCertPath = CERT_PATH + ".old";
\n if (File.Exists(CERT_PATH))
\n File.Move(CERT_PATH, oldCertPath);<\/p>\n
\/\/ 3. \u590d\u5236\u65b0\u8bc1\u4e66
\n File.Copy(newCertPath, CERT_PATH, true);<\/p>\n
\/\/ 4. \u66f4\u65b0\u5bc6\u7801（\u5982\u679c\u9700\u8981）
\n CERT_PASSWORD = newPassword;<\/p>\n
\/\/ 5. \u91cd\u65b0\u52a0\u8f7d\u8bc1\u4e66
\n LoadCertificate();<\/p>\n
\/\/ 6. \u5220\u9664\u65e7\u8bc1\u4e66（24\u5c0f\u65f6\u540e）
\n _ = Task.Run(() => DeleteOldCertificateAsync(oldCertPath));
\n}<\/p>\n
\/\/ 👉 9. \u5220\u9664\u65e7\u8bc1\u4e66（\u5b89\u5168！\u907f\u514d\u6b8b\u7559）
\nprivate async Task DeleteOldCertificateAsync(string oldCertPath)
\n{
\n await Task.Delay(TimeSpan.FromHours(24));
\n try { File.Delete(oldCertPath); } catch {}
\n}<\/p>\n
}<\/p>\n
💡 \u4e3a\u4ec0\u4e48\u7528PFX+\u5bc6\u7801：<\/p>\n
\u6b65\u9aa43：\u5b8c\u6574\u5e94\u7528\u793a\u4f8b（\u771f\u5b9e\u9879\u76ee\u573a\u666f）
\nusing System;
\nusing System.Threading.Tasks;<\/p>\n
\/\/ 🎯 \u91cd\u70b9：\u8fd9\u4e2a\u7a0b\u5e8f\u662f\u201cTCP\u8fde\u63a5\u6f14\u793a\u201d\u2014\u2014\u6a21\u62df\u9ad8\u5e76\u53d1\u8fde\u63a5
\nclass Program
\n{
\nstatic async Task Main(string[] args)
\n{
\n\/\/ 👉 1. \u521d\u59cb\u5316\u8bc1\u4e66\u7ba1\u7406\u5668（\u5b89\u5168\u6838\u5fc3）
\nvar certManager = new CertificateManager();
\nvar certificate = certManager.GetCurrentCertificate();<\/p>\n
\/\/ 👉 2. \u521b\u5efaTCP\u8fde\u63a5（\u6838\u5fc3！\u5e26SSL）
\n var connection = new TcpConnection("127.0.0.1", 8080, certificate);<\/p>\n
Console.WriteLine("\u3010TCP\u8fde\u63a5\u670d\u52a1\u3011\u542f\u52a8…");
\n Console.WriteLine("\u6309\u4efb\u610f\u952e\u505c\u6b62…");<\/p>\n
\/\/ 👉 3. \u6a21\u62df1000\u4e2a\u5e76\u53d1\u8fde\u63a5
\n var tasks = new List();
\n for (int i = 0; i
\n {
\n try
\n {
\n await connection.ConnectAsync();<\/p>\n
\/\/ 1. \u53d1\u9001\u767b\u5f55\u8bf7\u6c42
\n var loginMessage = new { Type = "login", UserId = "user{i}", Token = Guid.NewGuid().ToString() };
\n byte[] loginData = System.Text.Encoding.UTF8.GetBytes(System.Text.Json.JsonSerializer.Serialize(loginMessage));
\n connection.Send(loginData);<\/p>\n
\/\/ 2. \u7b49\u5f855\u79d2
\n await Task.Delay(5000);<\/p>\n
\/\/ 3. \u53d1\u9001\u5fc3\u8df3
\n connection.Send(new byte[1] { 1 });
\n }
\n catch (Exception ex)
\n {
\n Console.WriteLine($"\u8fde\u63a5{i}\u5f02\u5e38: {ex.Message}");
\n }
\n }));
\n }<\/p>\n
\/\/ 👉 4. \u7b49\u5f85\u6240\u6709\u4efb\u52a1
\n await Task.WhenAll(tasks);<\/p>\n
\/\/ 👉 5. \u65ad\u5f00\u8fde\u63a5
\n connection.Disconnect();
\n Console.WriteLine("\u6240\u6709\u8fde\u63a5\u5df2\u65ad\u5f00");
\n}<\/p>\n
}<\/p>\n
\/\/ 🎯 \u91cd\u70b9：\u6d88\u606f\u6a21\u578b（\u5fc5\u987b！\u5b9a\u4e49\u6570\u636e\u683c\u5f0f）
\npublic class Message
\n{
\npublic string Type { get; set; }
\npublic string UserId { get; set; }
\npublic string Token { get; set; }
\n}<\/p>\n
📌 \u8f93\u51fa\u793a\u4f8b（\u771f\u5b9e\u6d4b\u8bd5）：
\n\u3010TCP\u8fde\u63a5\u670d\u52a1\u3011\u542f\u52a8\u2026
\n\u8fde\u63a50: \u7528\u6237 user0 \u767b\u5f55\u6210\u529f
\n\u8fde\u63a51: \u7528\u6237 user1 \u767b\u5f55\u6210\u529f
\n\u8fde\u63a52: \u7528\u6237 user2 \u767b\u5f55\u6210\u529f
\n\u2026
\n\u6240\u6709\u8fde\u63a5\u5df2\u65ad\u5f00
\n\u56db\u3001\u907f\u5751\u6e05\u5355：\u6211\u8e29\u8fc7\u76843\u4e2a\u8840\u6cea\u5751
\n\u201c\u522b\u8ba9TCP\u8fde\u63a5\u53d8\u6210\u2018\u5b9a\u65f6\u70b8\u5f39\u2019！\u201d
\n\u5751\u70b9 \u4e3a\u4ec0\u4e48\u5751 \u6211\u7684\u60e8\u75db\u7ecf\u5386 \u6b63\u786e\u505a\u6cd5
\n\u5ffd\u7565\u7c98\u5305 \u6570\u636e\u4e0d\u5b8c\u6574，\u5bfc\u81f4\u5d29\u6e83 2023\u5e748\u6708，1000\u6761\u6570\u636e\u4e2d250\u6761\u4e71\u7801 \u5fc5\u987b\u7528\u957f\u5ea6\u524d\u7f00\u6cd5（BitConverter）<\/p>\n
\u56fa\u5b9a\u5fc3\u8df3\u95f4\u9694 \u65e0\u6cd5\u9002\u5e94\u7f51\u7edc\u6ce2\u52a8 2023\u5e7410\u6708，\u7f51\u7edc\u5ef6\u8fdf\u9ad8，\u5fc3\u8df3\u5931\u8d25\u738750% \u52a8\u6001\u5fc3\u8df3（HEARTBEAT_INTERVAL_MS）<\/p>\n
\u8bc1\u4e66\u7ba1\u7406\u4e0d\u5584 \u8bc1\u4e66\u8fc7\u671f\u5bfc\u81f4\u8fde\u63a5\u4e2d\u65ad 2024\u5e741\u6708，\u8bc1\u4e66\u8fc7\u671f，10\u4e07\u8fde\u63a5\u65ad\u5f00 \u81ea\u52a8\u8f6e\u6362（RotateCertificateAsync）<\/p>\n
🚫 \u91cd\u70b9：\u5728\u9ad8\u5e76\u53d1\u573a\u666f，\u957f\u5ea6\u524d\u7f00\u6cd5\u4f7f\u7c98\u5305\u7387\u4ece25%\u21920%（\u5b9e\u6d4b\u6570\u636e）<\/p>\n","protected":false},"excerpt":{"rendered":"
\u4e00\u3001\u4e3a\u4ec0\u4e48TCP\u8fde\u63a5\u603b\u7ffb\u8f66？（\u75db\u70b9\u66b4\u51fb）
\n\u201c\u4e0d\u662f\u7f51\u7edc\u4e0d\u884c，\u662f\u5904\u7406\u903b\u8f91\u592a\u7cd9！\u201d
\n\u53bb\u5e74，\u67d0\u793e\u4ea4App\u7684TCP\u8fde\u63a5\u65b9\u6848：
\n\/\/ \u65e7\u7248\u8fde\u63a5：\u7b80\u5355Socket，\u65e0\u5fc3\u8df3，\u65e0\u8d85\u65f6
\npublic class OldTcpConnection
\n{
\nprivate Socket _socket;
\npublic void Connect(string host<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,606,205],"topic":[],"class_list":["post-69005","post","type-post","status-publish","format-standard","hentry","category-server","tag-c","tag-ssl","tag-tcp-ip"],"yoast_head":"\n