十年河東，十年河西，莫欺少年窮linux
學無止境，精益求精算法
最近一段時間，編程
個人大多數精力都放在了系統架構，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，端口）；
socket -
- 觸發鏈接事件
服務器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（數據，偏移量，長度）
在Socket.Core框架中有一行代碼有問題，以下【class TcpPackServer】：
源代碼中休眠10毫秒，改爲1毫秒便可
若是是10毫秒，還有以下問題【親測】：
這樣會致使長連接會很短期內被斷開，最後致使程序崩潰。
三、如何理解TCP粘包及解決方案
引言：TCP協議是網絡通訊協議中十分重要的協議，相比於UDP協議來講，它是一個可靠的傳輸協議，而且是一個面向數據流的協議；所謂面向數據流，實際上是指數據傳輸是以流式的方式傳輸，這些傳輸的數據就像一條河裏的水，他們之間是沒有縫隙的，也就是說TCP協議傳輸的數據是無邊界的；（其實TCP粘包概念我的感受不恰當，畢竟TCP傳輸是以流式的方式）
而UDP是面向數據包的，收發數據包要麼全收要麼不收，數據包與數據包之間是有明顯的邊界的；
1、TCP粘包是什麼？
粘包發生在發送或接收緩衝區中；應用程序從緩衝區中取數據是整個緩衝區中有多少取多少；那麼就有可能第一個數據的尾部和第二個數據的頭部同時存在緩衝區，而TCP是流式的，數據無邊界，這時發生粘包。
2、TCP粘包的產生
1.發送方產生粘包
採用TCP協議傳輸數據的客戶端與服務器常常是保持一個長鏈接的狀態（一次鏈接發一次數據不存在粘包），雙方在鏈接不斷開的狀況下，能夠一直傳輸數據；但當發送的數據包過於的小時，那麼TCP協議默認的會啓用Nagle算法，將這些較小的數據包進行合併發送（緩衝區數據發送是一個堆壓的過程）；這個合併過程就是在發送緩衝區中進行的，也就是說數據發送出來它已是粘包的狀態了；
2.接收方產生粘包
接收方採用TCP協議接收數據時的過程是這樣的：數據到底接收方，從網絡模型的下方傳遞至傳輸層，傳輸層的TCP協議處理是將其放置接收緩衝區，而後由應用層來主動獲取（C語言用recv、read等函數）；這時會出現一個問題，就是咱們在程序中調用的讀取數據函數不能及時的把緩衝區中的數據拿出來，而下一個數據又到來並有一部分放入的緩衝區末尾，等咱們讀取數據時就是一個粘包；（放數據的速度 > 應用層拿數據速度）
TCP粘包解決方案
目前應用最普遍的是在消息的頭部添加數據包長度，接收方根據消息長度進行接收；在一條TCP鏈接上，數據的流式傳輸在接收緩衝區裏是有序的，其主要的問題就是第一個包的包尾與第二個包的包頭共存接收緩衝區，因此根據長度讀取是十分合適的；
1.解決發送方粘包
（1）發送產生是由於Nagle算法合併小數據包，那麼能夠禁用掉該算法；
（2）TCP提供了強制數據當即傳送的操做指令push，當填入數據後調用操做指令就能夠當即將數據發送，而沒必要等待發送緩衝區填充自動發送；
（3）數據包中加頭，頭部信息爲整個數據的長度（最普遍最經常使用）；
2.解決接收方粘包
（1）解析數據包頭部信息，根據長度來接收；
（2）自定義數據格式：在數據中放入開始、結束標識；解析時根據格式抓取數據，缺點是數據內不能含有開始或結束標識；
（3）短鏈接傳輸，創建一次鏈接只傳輸一次數據就關閉；（不推薦）
@天才臥龍的博客