}

上周在生产环境遇到了这个问题，排查了2天才定位到原因。

今天分享一下完整的解决方案，希望帮大家避坑。

atom-one-dark"

name="tableOfContents">目录

id="1.%E5%89%8D%E7%BD%AE%E8%AF%B4%E6%98%8E-toc"

style="margin-left:

id="2.%E5%9F%BA%E4%BA%8ETCP%E7%9A%84Socket%E7%BC%96%E7%A8%8B-toc"

style="margin-left:

id="2.1.%E5%85%B7%E4%BD%93%E6%AD%A5%E9%AA%A4-toc"

style="margin-left:

id="2.2.TCP%E7%BC%96%E7%A8%8B%E6%AD%A5%E9%AA%A4%E6%A0%B8%E5%BF%83%E7%89%B9%E7%82%B9-toc"

style="margin-left:

id="2.3.%E6%B3%A8%E6%84%8F-toc"

style="margin-left:

id="2.4.%E5%AE%9E%E7%8E%B0TCP%E7%BC%96%E7%A8%8B-toc"

style="margin-left:

id="2.5.%E6%B5%8B%E8%AF%95TCP%E7%BC%96%E7%A8%8B-toc"

style="margin-left:

id="3.%E5%9F%BA%E4%BA%8EUDP%E7%9A%84Socket%E7%BC%96%E7%A8%8B-toc"

style="margin-left:

id="3.1.%E5%85%B7%E4%BD%93%E6%AD%A5%E9%AA%A4-toc"

style="margin-left:

id="3.2.UDP%E7%BC%96%E7%A8%8B%E6%AD%A5%E9%AA%A4%E6%A0%B8%E5%BF%83%E7%89%B9%E7%82%B9-toc"

style="margin-left:

id="3.3.%E6%B3%A8%E6%84%8F-toc"

style="margin-left:

id="3.4.%E5%AE%9E%E7%8E%B0UDP%E7%BC%96%E7%A8%8B-toc"

style="margin-left:

id="3.5.%E6%B5%8B%E8%AF%95UDP%E7%BC%96%E7%A8%8B-toc"

style="margin-left:

name="tableOfContents">

本篇文章来分享一下Socket编程，主要了解TCP编程、UDP编程。

id="1.%E5%89%8D%E7%BD%AE%E8%AF%B4%E6%98%8E"

name="1.%E5%89%8D%E7%BD%AE%E8%AF%B4%E6%98%8E"

rgba(0,

1)">Socket编程基于TCP/UDP协议的网络编程，是程序员写代码实现设备通信的具体步骤；

justify">2）所有网络通信都是服务端+客户端模式：服务端是提供数据/服务的一方，客户端是请求数据/服务的一方。

id="2.%E5%9F%BA%E4%BA%8ETCP%E7%9A%84Socket%E7%BC%96%E7%A8%8B"

name="2.%E5%9F%BA%E4%BA%8ETCP%E7%9A%84Socket%E7%BC%96%E7%A8%8B"

rgba(0,

id="2.1.%E5%85%B7%E4%BD%93%E6%AD%A5%E9%AA%A4"

name="2.1.%E5%85%B7%E4%BD%93%E6%AD%A5%E9%AA%A4"

style="margin-left:

justify">TCP是C/S架构，核心：有连接、双向交互。

justify">【2】②启动监听对象，绑定IP地址+端口号 →

服务端开始在指定端口等待客户端连接；

justify">【6】④数据交换：收发数据（本质是网络流的读写）

justify">【4】②调用连接方法，连接指定的服务器（IP

+端口）

id="2.2.TCP%E7%BC%96%E7%A8%8B%E6%AD%A5%E9%AA%A4%E6%A0%B8%E5%BF%83%E7%89%B9%E7%82%B9"

name="2.2.TCP%E7%BC%96%E7%A8%8B%E6%AD%A5%E9%AA%A4%E6%A0%B8%E5%BF%83%E7%89%B9%E7%82%B9"

style="margin-left:

justify">2.2.TCP编程步骤核心特点

style="margin-left:

justify">1）必须先启动服务端，再启动客户端，否则客户端连接失败；

justify">2）建立连接后，服务端和客户端是一对一的专属通信，稳定可靠；

传输完成后，服务端和客户端还需要执行「关闭连接」，完成四次挥手。

justify">2）标注的数字（如【1】）是执行顺序，绝对不能颠倒！

id="2.4.%E5%AE%9E%E7%8E%B0TCP%E7%BC%96%E7%A8%8B"

name="2.4.%E5%AE%9E%E7%8E%B0TCP%E7%BC%96%E7%A8%8B"

style="margin-left:

使用本地测试，服务端是控制台程序，本地启动后，Unity客户端连127.0.0.1即可通信，完全免费、无网络限制、稳定。

src="https://i-blog.csdnimg.cn/direct/c4637172d78740b0afa83464fbf41b2b.png"

alt=""

src="https://i-blog.csdnimg.cn/direct/893ecd1b0cf2462faa55cb5cf1fa4c4b.png"

args){Console.WriteLine("TCP服务端：本地控制台服务端");Console.WriteLine("服务端已启动，监听端口:9999");Console.WriteLine("等待Unity客户端连接...\n");//【1】①创建监听对象TcpListener

server

9999);try{//【2】②启动监听server.Start();//【5】③阻塞等待客户端连接

(控制台不怕阻塞)Socket

server.AcceptSocket();Console.WriteLine($"[{DateTime.Now}]客户端连接成功！

客户端IP：{socket.RemoteEndPoint}");if

(socket.Connected){//【6】④数据交换：服务端【先发后收】NetworkStream

stream

NetworkStream(socket);StreamReader

reader

};//第一步：服务端发送消息给服务端Console.WriteLine("\n请输入要发送给Unity客户端的信息：");string

sendMsg

Console.ReadLine();writer.WriteLine(sendMsg);//StreamWriter有缓冲区，写入的数据会先存到缓冲区，不会立刻发送到网络，只有调用Flush()才会强制把缓冲区的所有数据发送出去，不写的话，数据发不出去，服务端就永远收不到消息writer.Flush();//清空缓冲区，必须写，否则数据发不出去Console.WriteLine($"[{DateTime.Now}]服务端已发送：{sendMsg}");//第二步：服务端接收服务端的消息string

recvMsg

reader.ReadLine();Console.WriteLine($"[{DateTime.Now}]服务端收到客户端消息：{recvMsg}");//关闭资源writer.Close();reader.Close();stream.Close();socket.Close();}}catch

(Exception

ex){Console.WriteLine($"[{DateTime.Now}]服务端异常：{ex.Message}"

);}finally{server.Stop();Console.WriteLine($"\n[{DateTime.Now}]服务端已关闭，按任意键退出...");Console.ReadKey();}}}

}

tipContent;//服务器配置（本地测试：本地控制台服务端）private

string

"127.0.0.1";//"tcpbin.com";private

int

transform.Find("TipContent").GetComponent();connectBtn

transform.Find("ConnectBtn").GetComponent

class="language-cs">();connectBtn.onClick.AddListener(OnConnectBtnClicked);tipContent.text

async

OnConnectBtnClicked(){connectBtn.interactable

"正在连接服务端...";await

ConnectAndCommunicate();//异步执行，不会卡死UnityconnectBtn.interactable

true;}///

ConnectAndCommunicate(){try{//【3】①创建客户端对象tcpClient

new

TcpClient();//【4】②异步连接服务器（无阻塞）//控制台的reader.ReadLine()、writer.WriteLine()都是同步阻塞方法//Unity是单线程渲染，一旦执行这些方法，整个Unity编辑器会卡死，直到有数据/连接//使用异步方法(async/await)可以解决该问题await

tcpClient.ConnectAsync(serverIp,

serverPort);if

(tcpClient.Connected){tipContent.text

$"[{DateTime.Now}]连接服务端成功！

等待接收消息...";Socket

socket

};//【7】③数据交换：客户端【先收后发】//第一步：客户端接收服务端的消息string

recvMsg

reader.ReadLineAsync();tipContent.text

$"\n[{DateTime.Now}]收到服务端消息：{recvMsg}";//第二步：客户端发送消息给服务端string

sendMsg

$"[{DateTime.Now}]Unity客户端收到消息啦！

已回复";await

writer.WriteLineAsync(sendMsg);writer.Flush();//必须刷新缓冲区，数据才会发出去tipContent.text

$"\n[{DateTime.Now}]已发送消息给服务端：{sendMsg}";}}catch

(Exception

$"[{DateTime.Now}]连接/通信失败：{ex.Message}";}finally{//关闭所有资源，防止内存泄漏CloseAll();tipContent.text

$"\n\n[{DateTime.Now}]连接已关闭，可重新点击连接";}}///

///

netStream.Close();tcpClient?.Close();tcpClient

null;}///

id="2.5.%E6%B5%8B%E8%AF%95TCP%E7%BC%96%E7%A8%8B"

name="2.5.%E6%B5%8B%E8%AF%95TCP%E7%BC%96%E7%A8%8B">2.5.测试TCP编程

1）先启动TCP服务端，若是不先启动，会无法连接

src="https://i-blog.csdnimg.cn/direct/c2e1a094954f44769aa9a8f2c0c88730.png"

alt=""

src="https://i-blog.csdnimg.cn/direct/1896a4eb77a3418d9c7928bc033a95d6.png"

width="1512">

最佳实践：

经过多个项目的验证，我总结了几个关键点：1)

做好异常处理

这些看似简单，但能避免很多生产环境问题。

2）在客户端点击“连接服务端”

src="https://i-blog.csdnimg.cn/direct/f597d2d20bbe4f0984a08758250ba6d5.png"

width="1563">

src="https://i-blog.csdnimg.cn/direct/e4357cf364274c379839f2324f781337.png"

width="1499">

3）在服务端输入要给客户端发送的信息，如：Hi,我是服务端！

客户端收到信息并回复后，服务端和客户端的连接断开。

src="https://i-blog.csdnimg.cn/direct/cbb3d77c97da482eace49be0f422e08b.png"

alt=""

src="https://i-blog.csdnimg.cn/direct/32fb9f9b05f74e41a47d9ebcf9e9ad90.png"

width="1512">

也可以使用免费公网TCP测试服务器，IP为tcpbin.com，端口为4242，该服务器的功能：发什么，它就原封不动给返回什么（回声服务器），适合测试TCP收发是否正常。

id="3.%E5%9F%BA%E4%BA%8EUDP%E7%9A%84Socket%E7%BC%96%E7%A8%8B"

name="3.%E5%9F%BA%E4%BA%8EUDP%E7%9A%84Socket%E7%BC%96%E7%A8%8B"

rgba(0,

id="3.1.%E5%85%B7%E4%BD%93%E6%AD%A5%E9%AA%A4"

name="3.1.%E5%85%B7%E4%BD%93%E6%AD%A5%E9%AA%A4"

style="margin-left:

1)">UDP无连接，步骤极简，核心：无连接、直接收发。

UDP没有服务端/客户端的严格区分，只有发送方/接收方，双方平等，无需建立连接。

id="3.2.UDP%E7%BC%96%E7%A8%8B%E6%AD%A5%E9%AA%A4%E6%A0%B8%E5%BF%83%E7%89%B9%E7%82%B9"

name="3.2.UDP%E7%BC%96%E7%A8%8B%E6%AD%A5%E9%AA%A4%E6%A0%B8%E5%BF%83%E7%89%B9%E7%82%B9"

style="margin-left:

justify">3.2.UDP编程步骤核心特点

style="margin-left:

justify">1）无需建立连接，没有握手和挥手，代码极简；

justify">2）发送方发完数据就完事，不管接收方是否在线、是否收到。

UDP无连接，客户端可以先发数据，服务端后接收；或者服务端先发，客户端后接收。

id="3.4.%E5%AE%9E%E7%8E%B0UDP%E7%BC%96%E7%A8%8B"

name="3.4.%E5%AE%9E%E7%8E%B0UDP%E7%BC%96%E7%A8%8B"

style="margin-left:

使用本地测试，服务端是控制台程序，本地启动后，Unity客户端连127.0.0.1即可通信，完全免费、无网络限制、稳定。

args){Console.WriteLine("UDP服务端：本地控制台服务端");Console.WriteLine("服务端绑定端口：8888

(接收客户端消息)");Console.WriteLine("客户端绑定端口：9999

serverListenPort

9999;//①创建创建监听对象//绑定8888端口，持续监听+发送UdpClient

udpServer

UdpClient(serverListenPort);IPEndPoint

clientPoint

IPEndPoint(IPAddress.Parse(clientIP),

clientListenPort);try{//②数据交换//1）作为接收方，接收数据//新开线程：持续监听8888端口，接收客户端发送的消息System.Threading.Thread

receiveThread

=>{//初始化在循环外,避免每次接收都重新创建，导致无法正确获取客户端地址IPEndPoint

remotePoint

Encoding.UTF8.GetString(recvBytes);Console.WriteLine($"\n[{DateTime.Now}]【收到客户端消息】：{recvInfo}");Console.WriteLine($"消息来源：{remotePoint}\n");}catch

}}});receiveThread.IsBackground

true;receiveThread.Start();//2）作为发送方，发送数据//主线程：持续输入内容，发送消息给客户端while

(true){Console.WriteLine("\n请输入要发送给客户端的消息：");string

sendInfo

Encoding.UTF8.GetBytes(sendInfo);udpServer.Send(sendBytes,

sendBytes.Length,

clientPoint);Console.WriteLine($"[{DateTime.Now}]服务端已发送：{sendInfo}

客户端({clientIP}:{clientListenPort})");}}catch

(Exception

ex){Console.WriteLine($"[{DateTime.Now}]发送失败：{ex.Message}");}finally{udpServer.Close();Console.WriteLine($"[{DateTime.Now}]服务端已关闭");}}}

}

inputMsg;//UDP配置：端口分离，永不冲突private

int

8888;//服务端的监听端口(给服务端发消息必须发这个端口)private

UdpClient

udpClient_Receive;//专门用于【接收】的UDP对象private

UdpClient

udpClient_Send;//专门用于【发送】的UDP对象private

void

transform.Find("TipContent").GetComponent();sendBtn

transform.Find("SendBtn").GetComponent

class="language-cs">();inputMsg

transform.Find("SendInputField").GetComponent();sendBtn.onClick.AddListener(OnSendBtnClick);StartReceive();tipContent.text

$"UDP客户端就绪\n1.已监听端口：{clientListenPort}，等待接收服务端消息\n2.输入内容点击发送：给服务端发消息";}private

async

ReceiveUDPData(){try{//1）作为接收方//①创建监听对象//绑定9999端口，固定监听，永不随机udpClient_Receive

new

UdpClient(clientListenPort);//持续接收，直到手动停止while

result

udpClient_Receive.ReceiveAsync();string

recvInfo

Encoding.UTF8.GetString(result.Buffer);if

(tipContent

$"[{DateTime.Now}]收到消息：{recvInfo}\n来源：{result.RemoteEndPoint}\n持续监听9999端口中...";}}}catch

(SocketException

SocketError.AddressAlreadyInUse){tipContent.text

$"[{DateTime.Now}]接收失败：9999端口被占用，请关闭其他程序重试";}else{tipContent.text

$"[{DateTime.Now}]接收异常：{ex.Message}";}}}catch

(Exception

$"[{DateTime.Now}]接收失败：{ex.Message}";}finally{CloseAll();}}private

async

(string.IsNullOrEmpty(inputMsg?.text)){if

(tipContent

$"[{DateTime.Now}]发送成功：{sendStr}\n发送至：{serverIP}:{serverListenPort}\n客户端可继续收发消息";}}private

async

sendStr){try{//2）作为发送方//①创建监听对象//发送时不要绑定9999端口，让系统随机分配发送端口using

(UdpClient

Encoding.UTF8.GetBytes(sendStr);IPEndPoint

serverPoint

IPEndPoint(IPAddress.Parse(serverIP),

sendClient.SendAsync(sendBytes,

sendBytes.Length,

$"[{DateTime.Now}]发送失败：{ex.Message}";}}///

///

CloseAll(){udpClient_Receive?.Close();udpClient_Send?.Close();udpClient_Receive

null;udpClient_Send

OnDestroy(){CloseAll();//清空所有引用tipContent

null;sendBtn

}

style="margin-left:

id="3.5.%E6%B5%8B%E8%AF%95UDP%E7%BC%96%E7%A8%8B"

name="3.5.%E6%B5%8B%E8%AF%95UDP%E7%BC%96%E7%A8%8B"

style="margin-left:

src="https://i-blog.csdnimg.cn/direct/554868b1920548e4927db7f80dd90a06.png"

alt=""

src="https://i-blog.csdnimg.cn/direct/af6778e1b97049ec8b11cb008bbfaa18.png"

width="1565">

2）客户端发数据，服务端接收

src="https://i-blog.csdnimg.cn/direct/19b344c9352f41ee8a25ec826602cd90.png"

alt=""

src="https://i-blog.csdnimg.cn/direct/fba69dd4231d4c15a20530635efca653.png"

width="1734">

3）服务端发数据，客户端接收

src="https://i-blog.csdnimg.cn/direct/ddccb4821a22443288d24bffd7b93522.png"

alt=""

src="https://i-blog.csdnimg.cn/direct/cb23ca235f664070a94ea4bfa2c5c54f.png"

justify">4.总结

style="margin-left:

justify">TCP：面向连接、可靠、有序、慢

想继续了解TCP和UDP可以参考【一文了解】TCP协议和UDP协议

好了，本次的分享到这里就结束啦，希望对你有所帮助~