十年河東，十年河西，莫欺少年窮
學無止境，精益求精
最近一段時間，
我的大多數精力都放在了系統架構，IOT+MQTT 物聯網編程，Tcp/Ip協議Socket編程，這些方面的知識，在我之前職業生涯很少接觸過的。
首先介紹下Socket.Core框架
【框架介紹：https://awesomeopensource.com/project/fengma312/socket.core 或 https://files.cnblogs.com/files/chenwolong/SocketCore.zip】
TCP模塊簡介
Server socket.core.Server命名空間分別在socket.core下三種模式push / pull / pack。
客戶端的客戶端名稱空間，有三種模式push / pull / pack
主要過程以及相應的方法和事件介紹。
注意：connectId（guid）代表連接對象，數據（字節[]），成功（布爾）
-
- 初始化套接字（對應三種模式）
實例化服務器類TcpPushServer / TcpPullServer / TcpPackServer
實例化客戶端類TcpPushClient / TcpPullClient / TcpPackClient參數介紹int numConnections每個套接字I / O操作的最大同時連接數，int receiveBufferSize緩沖區大小（接收器），int超時時間（秒）（每10秒檢查一次），當值為0時不設置超時，uint headerFlag標頭標簽范圍為0〜1023（0x3FF），當標頭標識符等於0時不檢查標頭 -
- 開始監視/連接服務器
服務器server.Start（端口）；
客戶端client.Connect（ip，端口）； -
- 觸發連接事件
服務器server.OnAccept（connectId）; 收到連接ID，可用於發送，接收，關閉標簽
Client client.OnConnect（success）;。接收是否成功連接到服務器 -
- 發送消息
服務器server.Send（connectId，data，offset，length）;
客戶端client.Send（數據，偏移量，長度）； -
- 觸發已發送事件
服務器server.OnSend（connectId，length）;
客戶端client.OnSend（長度）； -
- 觸發接收事件
服務器server.OnReceive（connectId，data）;
客戶端client.OnReceive（數據）； -
- 關閉連接
服務器server.Close（connectId）;
客戶端client.Close（）; -
- 觸發關閉連接事件
服務器server.OnClose（connectId）;
客戶端client.OnClose（）;
三種型號介紹
- 一：推
將觸發監視事件對象OnReceive（connectId，數據）；數據立即“推送”到應用程序
- 二：拉
OnReceive（connectId，長度），它告訴應用程序已接收了多少數據。應用程序檢查數據的長度。如果滿足，它將調用組件的Fetch（connectId，length）方法，將數據“拉出”
- 三：包
pack模型組件是推拉模型的組合。該應用程序不必處理分包合同【也就是所謂的Tcp沾包】。該組件保證每個應用程序server.OnReceive（connectId，數據）/client.OnReceive（數據）事件為應用程序提供完整的數據包。注意：包模型組件會自動向每個應用程序添加4字節（32位）標頭應用程序發送的數據包。當組件接收到數據時，它將根據標頭信息自動打包。每個完整的數據包都發送到OnReceive事件被發送到應用程序PACK標頭格式（4字節）4 * 8 = 32
XXXXXXXXXXYYYYYYYYYYYYYYYYYYYYYYYY
前10個X位是標頭標識位，用於數據包驗證。有效報頭標識值的范圍是0到1023（0x3FF）。當標頭標識等於0時，不檢查標頭。Y的最后22位是長度位。包裝長度。最大有效數據包長度不能超過4194303（0x3FFFFF）個字節（字節），可以通過TcpPackServer / TcpPackClient構造函數參數headerFlag設置應用程序
服務器其他方法介紹
-
- bool SetAttached（int connectId，對象數據）
服務器為每個客戶端設置其他數據，以防止用戶建立用戶映射表
-
- T GetAttached（int connectId）
獲取指定客戶端的其他數據
-
- 屬性：ConcurrentDictionary <int，string> ClientList
獲取正在連接的客戶端信息<connectId，ip和port>
二：UDP模塊介紹
-
- 初始化UDP實現類UdpServer / UdpClients
服務器socket.core.Server.UdpServer
客戶端socket.core.Client.UdpClients
參數int receiveBufferSize每個套接字I / O操作（接收器）的緩沖區大小 -
- 發送數據
服務器server.Send（remoteEndPoint，數據，偏移量，長度）
客戶端client.Send（數據，偏移量，長度）
Client client.Send（remoteEndPoint，數據，偏移量，長度） -
- 觸發已發送事件
服務器server.OnSend（remoteEndPoint，長度）
客戶端client.OnSend （長度） -
- 觸發接收事件
服務器server.OnReceive（remoteEndPoint，數據，偏移量，長度）
客戶端client.OnReceive（數據，偏移量，長度）
引言：TCP協議是網絡通信協議中十分重要的協議，相比於UDP協議來說，它是一個可靠的傳輸協議，並且是一個面向數據流的協議；所謂面向數據流，其實是指數據傳輸是以流式的方式傳輸，這些傳輸的數據就像一條河里的水，他們之間是沒有縫隙的，也就是說TCP協議傳輸的數據是無邊界的；（其實TCP粘包概念個人感覺不恰當，畢竟TCP傳輸是以流式的方式）
而UDP是面向數據包的，收發數據包要么全收要么不收，數據包與數據包之間是有明顯的邊界的；
一、TCP粘包是什么？
粘包發生在發送或接收緩沖區中；應用程序從緩沖區中取數據是整個緩沖區中有多少取多少；那么就有可能第一個數據的尾部和第二個數據的頭部同時存在緩沖區，而TCP是流式的，數據無邊界，這時發生粘包。 
二、TCP粘包的產生
1.發送方產生粘包
采用TCP協議傳輸數據的客戶端與服務器經常是保持一個長連接的狀態（一次連接發一次數據不存在粘包），雙方在連接不斷開的情況下，可以一直傳輸數據；但當發送的數據包過於的小時，那么TCP協議默認的會啟用Nagle算法，將這些較小的數據包進行合並發送（緩沖區數據發送是一個堆壓的過程）；這個合並過程就是在發送緩沖區中進行的，也就是說數據發送出來它已經是粘包的狀態了； 
2.接收方產生粘包
接收方采用TCP協議接收數據時的過程是這樣的：數據到底接收方，從網絡模型的下方傳遞至傳輸層，傳輸層的TCP協議處理是將其放置接收緩沖區，然后由應用層來主動獲取（C語言用recv、read等函數）；這時會出現一個問題，就是我們在程序中調用的讀取數據函數不能及時的把緩沖區中的數據拿出來，而下一個數據又到來並有一部分放入的緩沖區末尾，等我們讀取數據時就是一個粘包；（放數據的速度 > 應用層拿數據速度） 
TCP粘包解決方案
目前應用最廣泛的是在消息的頭部添加數據包長度，接收方根據消息長度進行接收；在一條TCP連接上，數據的流式傳輸在接收緩沖區里是有序的，其主要的問題就是第一個包的包尾與第二個包的包頭共存接收緩沖區，所以根據長度讀取是十分合適的；
1.解決發送方粘包
（1）發送產生是因為Nagle算法合並小數據包，那么可以禁用掉該算法；
（2）TCP提供了強制數據立即傳送的操作指令push，當填入數據后調用操作指令就可以立即將數據發送，而不必等待發送緩沖區填充自動發送；
（3）數據包中加頭，頭部信息為整個數據的長度（最廣泛最常用）；
2.解決接收方粘包
（1）解析數據包頭部信息，根據長度來接收；
（2）自定義數據格式：在數據中放入開始、結束標識；解析時根據格式抓取數據，缺點是數據內不能含有開始或結束標識；
（3）短連接傳輸，建立一次連接只傳輸一次數據就關閉；（不推薦）
@天才卧龍的博客