摘要:通信協(xié)議于年被定為標(biāo)準(zhǔn),并由補(bǔ)充規(guī)范。連接創(chuàng)建后,客戶端服務(wù)端進(jìn)行數(shù)據(jù)交換時(shí),協(xié)議控制的數(shù)據(jù)包頭部較小。包頭是包的開始標(biāo)記,整個(gè)包的大小就是包的結(jié)束標(biāo)。如何自定義協(xié)議發(fā)送時(shí)數(shù)據(jù)包是由包頭數(shù)據(jù)組成的其中包頭內(nèi)容分為包類型包長(zhǎng)度。
深南大道鎮(zhèn)樓定義一個(gè)自己的通訊協(xié)議并不難,關(guān)鍵在于這個(gè)協(xié)議的可用性,可拓展性,復(fù)雜業(yè)務(wù)場(chǎng)景的實(shí)用性
即時(shí)通訊應(yīng)用中,客戶端和服務(wù)器端都可以看成一個(gè)服務(wù)器一起復(fù)習(xí)一下websocket
WebSocket是一種在單個(gè)TCP連接上進(jìn)行全雙工通信的協(xié)議。WebSocket通信協(xié)議于2011年被IETF定為標(biāo)準(zhǔn)RFC 6455,并由RFC7936補(bǔ)充規(guī)范。WebSocket API也被W3C定為標(biāo)準(zhǔn)。
WebSocket使得客戶端和服務(wù)器之間的數(shù)據(jù)交換變得更加簡(jiǎn)單,允許服務(wù)端主動(dòng)向客戶端推送數(shù)據(jù),在WebSocket API中,瀏覽器和服務(wù)器只需要完成一次握手,兩者之間就直接可以創(chuàng)建持久性的連接,并進(jìn)行雙向數(shù)據(jù)傳輸。
說說ws協(xié)議的優(yōu)點(diǎn):說到優(yōu)點(diǎn),這里的對(duì)比參照物是 HTTP 協(xié)議,概括地說就是:支持雙向通信,更靈活,更高效,可擴(kuò)展性更好。
支持雙向通信,實(shí)時(shí)性更強(qiáng)。
更好的二進(jìn)制支持。
較少的控制開銷。連接創(chuàng)建后,ws 客戶端、服務(wù)端進(jìn)行數(shù)據(jù)交換時(shí),協(xié)議控制的數(shù)據(jù)包頭部較小。在不* 包含頭部的情況下,服務(wù)端到客戶端的包頭只有 2~10 字節(jié)(取決于數(shù)據(jù)包長(zhǎng)度),客戶端到服務(wù)端的的話,需要加上額外的 4 字節(jié)的掩碼。而 HTTP 協(xié)議每次通信都需要攜帶完整的頭部。
支持?jǐn)U展。ws 協(xié)議定義了擴(kuò)展,用戶可以擴(kuò)展協(xié)議,或者實(shí)現(xiàn)自定義的子協(xié)議。(比如支持自定義壓縮算法等)
我們先看看web socket協(xié)議的實(shí)現(xiàn)具體過程,再用代碼抽象,定義自己的即時(shí)通訊協(xié)議:
連接握手過程
關(guān)于WebSocket有一句很常見的話: Websocket復(fù)用了HTTP的握手通道, 它具體指的是:
客戶端通過HTTP請(qǐng)求與WebSocket服務(wù)器協(xié)商升級(jí)協(xié)議, 協(xié)議升級(jí)完成后, 后續(xù)的數(shù)據(jù)交換則遵照WebSocket協(xié)議
客戶端: 申請(qǐng)協(xié)議升級(jí)
首先由客戶端換發(fā)起協(xié)議升級(jí)請(qǐng)求, 根據(jù)WebSocket協(xié)議規(guī)范, 請(qǐng)求頭必須包含如下的內(nèi)容
GET / HTTP/1.1 Host: localhost:8080 Origin: http://127.0.0.1:3000 Connection: Upgrade Upgrade: websocket Sec-WebSocket-Version: 13 Sec-WebSocket-Key: w4v7O6xFTi36lq3RNcgctw
請(qǐng)求頭詳解
請(qǐng)求行: 請(qǐng)求方法必須是GET, HTTP版本至少是1.1
請(qǐng)求必須含有Host
如果請(qǐng)求來自瀏覽器客戶端, 必須包含Origin
請(qǐng)求必須含有Connection, 其值必須含有"Upgrade"記號(hào)
請(qǐng)求必須含有Upgrade, 其值必須含有"websocket"關(guān)鍵字
請(qǐng)求必須含有Sec-Websocket-Version, 其值必須是13
請(qǐng)求必須含有Sec-Websocket-Key, 用于提供基本的防護(hù), 比如無意的連接
1.2 服務(wù)器: 響應(yīng)協(xié)議升級(jí)
服務(wù)器返回的響應(yīng)頭必須包含如下的內(nèi)容
HTTP/1.1 101 Switching Protocols
Connection:Upgrade
Upgrade: websocket
Sec-WebSocket-Accept: Oy4NRAQ13jhfONC7bP8dTKb4PTU=
響應(yīng)行: HTTP/1.1 101 Switching Protocols
響應(yīng)必須含有Upgrade, 其值為"weboscket"
響應(yīng)必須含有Connection, 其值為"Upgrade"
響應(yīng)必須含有Sec-Websocket-Accept, 根據(jù)請(qǐng)求首部的Sec-Websocket-key計(jì)算出來
Sec-WebSocket-Key/Accept的計(jì)算規(guī)范提到:
Sec-WebSocket-Key值由一個(gè)隨機(jī)生成的16字節(jié)的隨機(jī)數(shù)通過base64編碼得到的
Key可以避免服務(wù)器收到非法的WebSocket連接, 比如http請(qǐng)求連接到websocket, 此時(shí)服務(wù)端可以直接拒絕
Key可以用來初步確保服務(wù)器認(rèn)識(shí)ws協(xié)議, 但也不能排除有的http服務(wù)器只處理Sec-WebSocket-Key, 并不實(shí)現(xiàn)ws協(xié)議
Key可以避免反向代理緩存
在瀏覽器中發(fā)起ajax請(qǐng)求, Sec-Websocket-Key以及相關(guān)header是被禁止的, 這樣可以避免客戶端發(fā)送ajax請(qǐng)求時(shí), 意外請(qǐng)求協(xié)議升級(jí)
最終需要強(qiáng)調(diào)的是: Sec-WebSocket-Key/Accept并不是用來保證數(shù)據(jù)的安全性, 因?yàn)槠溆?jì)算/轉(zhuǎn)換公式都是公開的, 而且非常簡(jiǎn)單, 最主要的作用是預(yù)防一些意外的情況
WebSocket通信的最小單位是幀, 由一個(gè)或多個(gè)幀組成一條完整的消息, 交換數(shù)據(jù)的過程中, 發(fā)送端和接收端需要做的事情如下:發(fā)送端: 將消息切割成多個(gè)幀, 并發(fā)送給服務(wù)端
接收端: 接受消息幀, 并將關(guān)聯(lián)的幀重新組裝成完整的消息
數(shù)據(jù)幀格式詳解FIN: 占1bit
0表示不是消息的最后一個(gè)分片
1表示是消息的最后一個(gè)分片
RSV1, RSV2, RSV3: 各占1bit, 一般情況下全為0, 與Websocket拓展有關(guān), 如果出現(xiàn)非零的值且沒有采用WebSocket拓展, 連接出錯(cuò)
Opcode: 占4bit %x0: 表示本次數(shù)據(jù)傳輸采用了數(shù)據(jù)分片, 當(dāng)前數(shù)據(jù)幀為其中一個(gè)數(shù)據(jù)分片 %x1: 表示這是一個(gè)文本幀 %x2: 表示這是一個(gè)二進(jìn)制幀 %x3-7: 保留的操作代碼, 用于后續(xù)定義的非控制幀 %x8: 表示連接斷開 %x9: 表示這是一個(gè)心跳請(qǐng)求(ping) %xA: 表示這是一個(gè)心跳響應(yīng)(pong) %xB-F: 保留的操作代碼, 用于后續(xù)定義的非控制幀
Mask: 占1bit
0表示不對(duì)數(shù)據(jù)載荷進(jìn)行掩碼異或操作
1表示對(duì)數(shù)據(jù)載荷進(jìn)行掩碼異或操作
Payload length: 占7或7+16或7+64bit
0~125: 數(shù)據(jù)長(zhǎng)度等于該值
126: 后續(xù)的2個(gè)字節(jié)代表一個(gè)16位的無符號(hào)整數(shù), 值為數(shù)據(jù)的長(zhǎng)度
127: 后續(xù)的8個(gè)字節(jié)代表一個(gè)64位的無符號(hào)整數(shù), 值為數(shù)據(jù)的長(zhǎng)度
Masking-key: 占0或4bytes
1: 攜帶了4字節(jié)的Masking-key
0: 沒有Masking-key
掩碼的作用并不是防止數(shù)據(jù)泄密,而是為了防止早期版本協(xié)議中存在的代理緩存污染攻擊等問題
payload data: 載荷數(shù)據(jù)
數(shù)據(jù)傳遞
WebSocket的每條消息可能被切分成多個(gè)數(shù)據(jù)幀, 當(dāng)接收到一個(gè)數(shù)據(jù)幀時(shí),會(huì)根據(jù)FIN值來判斷, 是否為最后一個(gè)數(shù)據(jù)幀
數(shù)據(jù)幀傳遞示例:
FIN=0, Opcode=0x1: 發(fā)送文本類型, 消息還沒有發(fā)送完成,還有后續(xù)幀
FIN=0, Opcode=0x0: 消息沒有發(fā)送完成, 還有后續(xù)幀, 接在上一條后面
FIN=1, Opcode=0x0: 消息發(fā)送完成, 沒有后續(xù)幀, 接在上一條后面組成完整消息
正式開始定義屬于我們自己的通訊協(xié)議:
我們?yōu)槭裁匆远xTCP應(yīng)用層傳輸協(xié)議?
針對(duì)特定的用戶群體,實(shí)現(xiàn)通訊信息的真正加密,復(fù)雜場(chǎng)景下更靈活的通信
因?yàn)樵赥CP流傳輸?shù)倪^程中,可能會(huì)出現(xiàn)分包與黏包的現(xiàn)象。我們?yōu)榱私鉀Q這些問題,需要我們自定義通信協(xié)議進(jìn)行封包與解包。
什么是分包與黏包?
分包:指接受方?jīng)]有接受到一個(gè)完整的包,只接受了部分。
黏包:指發(fā)送方發(fā)送的若干包數(shù)據(jù)到接收方接收時(shí)粘成一包,從接收緩沖區(qū)看,后一包數(shù)據(jù)的頭緊接著前一包數(shù)據(jù)的尾。
PS:因?yàn)門CP是面向字節(jié)流的,是沒有邊界的概念的,嚴(yán)格意義上來說,是沒有分包和黏包的概念的,但是為了更好理解,也更好來描述現(xiàn)象,我在這里就接著采用這兩個(gè)名詞來解釋現(xiàn)象了。我覺得大家知道這個(gè)概念就行了,不必細(xì)扣,能解決問題就行。
產(chǎn)生分包與黏包現(xiàn)象的原因是什么?
產(chǎn)生分包原因:
可能是IP分片傳輸導(dǎo)致的,也可能是傳輸過程中丟失部分包導(dǎo)致出現(xiàn)的半包,還有可能就是一個(gè)包可能被分成了兩次傳輸,在取數(shù)據(jù)的時(shí)候,先取到了一部分(還可能與接收的緩沖區(qū)大小有關(guān)系),總之就是一個(gè)數(shù)據(jù)包被分成了多次接收。
產(chǎn)生黏包的原因:
由于TCP協(xié)議本身的機(jī)制(面向連接的可靠地協(xié)議-三次握手機(jī)制)客戶端與服務(wù)器會(huì)維持一個(gè)連接(Channel),數(shù)據(jù)在連接不斷開的情況下,可以持續(xù)不斷地將多個(gè)數(shù)據(jù)包發(fā)往服務(wù)器,但是如果發(fā)送的網(wǎng)絡(luò)數(shù)據(jù)包太小,那么他本身會(huì)啟用Nagle算法(可配置是否啟用)對(duì)較小的數(shù)據(jù)包進(jìn)行合并(基于此,TCP的網(wǎng)絡(luò)延遲要UDP的高些)然后再發(fā)送(超時(shí)或者包大小足夠)。那么這樣的話,服務(wù)器在接收到消息(數(shù)據(jù)流)的時(shí)候就無法區(qū)分哪些數(shù)據(jù)包是客戶端自己分開發(fā)送的,這樣產(chǎn)生了粘包;服務(wù)器在接收到數(shù)據(jù)后,放到緩沖區(qū)中,如果消息沒有被及時(shí)從緩存區(qū)取走,下次在取數(shù)據(jù)的時(shí)候可能就會(huì)出現(xiàn)一次取出多個(gè)數(shù)據(jù)包的情況,造成粘包現(xiàn)象
什么是封包與解包?
TCP/IP 網(wǎng)絡(luò)數(shù)據(jù)以流的方式傳輸,數(shù)據(jù)流是由包組成,如何判定接收方收到的包是否是一個(gè)完整的包就要在發(fā)送時(shí)對(duì)包進(jìn)行處理,這就是封包技術(shù),將包處理成包頭,包體。
包頭是包的開始標(biāo)記,整個(gè)包的大小就是包的結(jié)束標(biāo)。
如何自定義協(xié)議?
發(fā)送時(shí)數(shù)據(jù)包是由包頭+數(shù)據(jù) 組成的:其中包頭內(nèi)容分為包類型+包長(zhǎng)度。
接收時(shí),只需要先保證將數(shù)據(jù)包的包頭讀完整,通過收到的數(shù)據(jù)包包頭里的數(shù)據(jù)長(zhǎng)度和數(shù)據(jù)包類型,判斷出我們將要收到一個(gè)帶有什么樣類型的多少長(zhǎng)度的數(shù)據(jù)。然后循環(huán)接收直到接收的數(shù)據(jù)大小等于數(shù)據(jù)長(zhǎng)度停止,此時(shí)我們完成接收一個(gè)完整數(shù)據(jù)包。
用代碼書寫一個(gè)常見的解密后的包:
{ header:{ cmdid:oxa212, msgid:xxxxxx, sessionid:xxxx .... }, body:{ sessiontype:1, datalength:100, formid:xxx, told:xxxx, msgid:xxxxxxx, content:"dear" } }
今天為了降低難度,沒有使用prob格式傳輸哦。
當(dāng)然還有心跳的發(fā)包和回包,與上面類似,只是內(nèi)容不一致。
今天只書寫客戶端node.js的部分代碼,服務(wù)端的代碼,打算后期使用golang書寫。
上面說到了,WebSocket通信的最小單位是幀, 由一個(gè)或多個(gè)幀組成一條完整的消息, 交換數(shù)據(jù)的過程中, 發(fā)送端和接收端需要做的事情如下:
發(fā)送端: 將消息切割成多個(gè)幀, 并發(fā)送給服務(wù)端
接收端: 接受消息幀, 并將關(guān)聯(lián)的幀重新組裝成完整的消息
出現(xiàn)黏包和分包的問題,通俗易懂的說就是,創(chuàng)建buffer緩沖區(qū),把二進(jìn)制的數(shù)據(jù)一點(diǎn)一點(diǎn)點(diǎn)切出來,然后變成特定的js對(duì)象使用。
第一步 先與服務(wù)端建立tcp鏈接const {Socket} = require("net") const tcp = new Socket() tcp.setKeepAlive(true); tcp.setNoDelay(true); //保持底層tcp鏈接不斷,長(zhǎng)連接第二步,指定對(duì)應(yīng)域名端口號(hào)鏈接
tcp.connect(80,142.122.0.0)第三步 建立成功鏈接后發(fā)送心跳包,并且服務(wù)端回復(fù)心跳包
每個(gè)人定制的心跳發(fā)包回包都不一樣,具體格式可以參考上面,自行定制心跳包的內(nèi)容和檢測(cè)時(shí)間,多長(zhǎng)時(shí)間檢測(cè)不到心跳的處理機(jī)制。
第四步,收到服務(wù)端數(shù)據(jù),拆包,根據(jù)不同的數(shù)據(jù)類型給予不同的處理機(jī)制,決定哪些渲染到頁(yè)面上,哪些放入數(shù)據(jù)庫(kù),做持久性存儲(chǔ)等。這里寫一點(diǎn)拆包代碼
根據(jù)后端傳送的數(shù)據(jù)類型 使用對(duì)應(yīng)不同的解析 readUInt8 readUInt16LE readUInt32LE readIntLE等處理后得到myBuf const myBuf = buffer.slice(start);//從對(duì)應(yīng)的指針開始的位置截取buffer const header = myBuf.slice(headstart,headend)//截取對(duì)應(yīng)的頭部buffer const body = JSON.parse(myBuf.slice(headend-headstart,bodylength).tostring()) //精確截取body的buffer,并且轉(zhuǎn)化成js對(duì)象
怎么拆包,長(zhǎng)度是多少,要看大家各自的定義方式,參考websocket的定義格式:Node.js目前支持的字符編碼包括:
ascii - 僅支持 7 位 ASCII 數(shù)據(jù)。如果設(shè)置去掉高位的話,這種編碼是非常快的。
utf8 - 多字節(jié)編碼的 Unicode 字符。許多網(wǎng)頁(yè)和其他文檔格式都使用 UTF-8 。
utf16le - 2 或 4 個(gè)字節(jié),小字節(jié)序編碼的 Unicode 字符。支持代理對(duì)(U+10000 至 U+10FFFF)。
ucs2 - utf16le 的別名。
base64 - Base64 編碼。
latin1 - 一種把 Buffer 編碼成一字節(jié)編碼的字符串的方式。
binary - latin1 的別名。
hex - 將每個(gè)字節(jié)編碼為兩個(gè)十六進(jìn)制字符。
組包
創(chuàng)建 Buffer 類
Buffer 提供了以下 API 來創(chuàng)建 Buffer 類:
Buffer.alloc(size[, fill[, encoding]]): 返回一個(gè)指定大小的 Buffer 實(shí)例,如果沒有設(shè)置 fill,則默認(rèn)填滿 0
Buffer.allocUnsafe(size): 返回一個(gè)指定大小的 Buffer 實(shí)例,但是它不會(huì)被初始化,所以它可能包含敏感的數(shù)據(jù)
Buffer.allocUnsafeSlow(size)
Buffer.from(array): 返回一個(gè)被 array 的值初始化的新的 Buffer 實(shí)例(傳入的 array 的元素只能是數(shù)字,不然就會(huì)自動(dòng)被 0 覆蓋)
Buffer.from(arrayBuffer[, byteOffset[, length]]): 返回一個(gè)新建的與給定的 ArrayBuffer 共享同一內(nèi)存的 Buffer。
Buffer.from(buffer): 復(fù)制傳入的 Buffer 實(shí)例的數(shù)據(jù),并返回一個(gè)新的 Buffer 實(shí)例
Buffer.from(string[, encoding]): 返回一個(gè)被 string 的值初始化的新的 Buffer 實(shí)例
所謂組包,就是把對(duì)應(yīng)的js對(duì)象,變成二進(jìn)制數(shù)據(jù),然后推送給服務(wù)端
這里寫一個(gè)簡(jiǎn)單的組包
const obj = { header:{ datalength:123, sessiontype:1, cmdid:xxx,}, body:{ content:"hello", sessionid:xxx, fromid:xxx, toid:xxx } } 將上面的js對(duì)象轉(zhuǎn)化成buf后,推送給服務(wù)端 tcp.write(buf,cb) cb是一個(gè)異步回掉,當(dāng)數(shù)據(jù)推送完后才會(huì)調(diào)用。下面給出常用的buffer操作api
方法參考手冊(cè)
以下列出了 Node.js Buffer 模塊常用的方法(注意有些方法在舊版本是沒有的):
序號(hào) 方法 & 描述
1 new Buffer(size)
分配一個(gè)新的 size 大小單位為8位字節(jié)的 buffer。 注意, size 必須小于 kMaxLength,否則,將會(huì)拋出異常 RangeError。廢棄的: 使用 Buffer.alloc() 代替(或 Buffer.allocUnsafe())。
2 new Buffer(buffer)
拷貝參數(shù) buffer 的數(shù)據(jù)到 Buffer 實(shí)例。廢棄的: 使用 Buffer.from(buffer) 代替。
3 new Buffer(str[, encoding])
分配一個(gè)新的 buffer ,其中包含著傳入的 str 字符串。 encoding 編碼方式默認(rèn)為 "utf8"。 廢棄的: 使用 Buffer.from(string[, encoding]) 代替。
4 buf.length
返回這個(gè) buffer 的 bytes 數(shù)。注意這未必是 buffer 里面內(nèi)容的大小。length 是 buffer 對(duì)象所分配的內(nèi)存數(shù),它不會(huì)隨著這個(gè) buffer 對(duì)象內(nèi)容的改變而改變。
5 buf.write(string[, offset[, length]][, encoding])
根據(jù)參數(shù) offset 偏移量和指定的 encoding 編碼方式,將參數(shù) string 數(shù)據(jù)寫入buffer。 offset 偏移量默認(rèn)值是 0, encoding 編碼方式默認(rèn)是 utf8。 length 長(zhǎng)度是將要寫入的字符串的 bytes 大小。 返回 number 類型,表示寫入了多少 8 位字節(jié)流。如果 buffer 沒有足夠的空間來放整個(gè) string,它將只會(huì)只寫入部分字符串。 length 默認(rèn)是 buffer.length - offset。 這個(gè)方法不會(huì)出現(xiàn)寫入部分字符。
6 buf.writeUIntLE(value, offset, byteLength[, noAssert])
將 value 寫入到 buffer 里, 它由 offset 和 byteLength 決定,最高支持 48 位無符號(hào)整數(shù),小端對(duì)齊,例如:
const buf = Buffer.allocUnsafe(6); buf.writeUIntLE(0x1234567890ab, 0, 6); // 輸出:console.log(buf); noAssert 值為 true 時(shí),不再驗(yàn)證 value 和 offset 的有效性。 默認(rèn)是 false。
7 buf.writeUIntBE(value, offset, byteLength[, noAssert])
將 value 寫入到 buffer 里, 它由 offset 和 byteLength 決定,最高支持 48 位無符號(hào)整數(shù),大端對(duì)齊。noAssert 值為 true 時(shí),不再驗(yàn)證 value 和 offset 的有效性。 默認(rèn)是 false。
const buf = Buffer.allocUnsafe(6); buf.writeUIntBE(0x1234567890ab, 0, 6); // 輸出:console.log(buf);
8 buf.writeIntLE(value, offset, byteLength[, noAssert])
將value 寫入到 buffer 里, 它由offset 和 byteLength 決定,最高支持48位有符號(hào)整數(shù),小端對(duì)齊。noAssert 值為 true 時(shí),不再驗(yàn)證 value 和 offset 的有效性。 默認(rèn)是 false。
9 buf.writeIntBE(value, offset, byteLength[, noAssert])
將value 寫入到 buffer 里, 它由offset 和 byteLength 決定,最高支持48位有符號(hào)整數(shù),大端對(duì)齊。noAssert 值為 true 時(shí),不再驗(yàn)證 value 和 offset 的有效性。 默認(rèn)是 false。
10 buf.readUIntLE(offset, byteLength[, noAssert])
支持讀取 48 位以下的無符號(hào)數(shù)字,小端對(duì)齊。noAssert 值為 true 時(shí), offset 不再驗(yàn)證是否超過 buffer 的長(zhǎng)度,默認(rèn)為 false。
11 buf.readUIntBE(offset, byteLength[, noAssert])
支持讀取 48 位以下的無符號(hào)數(shù)字,大端對(duì)齊。noAssert 值為 true 時(shí), offset 不再驗(yàn)證是否超過 buffer 的長(zhǎng)度,默認(rèn)為 false。
12 buf.readIntLE(offset, byteLength[, noAssert])
支持讀取 48 位以下的有符號(hào)數(shù)字,小端對(duì)齊。noAssert 值為 true 時(shí), offset 不再驗(yàn)證是否超過 buffer 的長(zhǎng)度,默認(rèn)為 false。
13 buf.readIntBE(offset, byteLength[, noAssert])
支持讀取 48 位以下的有符號(hào)數(shù)字,大端對(duì)齊。noAssert 值為 true 時(shí), offset 不再驗(yàn)證是否超過 buffer 的長(zhǎng)度,默認(rèn)為 false。
14 buf.toString([encoding[, start[, end]]])
根據(jù) encoding 參數(shù)(默認(rèn)是 "utf8")返回一個(gè)解碼過的 string 類型。還會(huì)根據(jù)傳入的參數(shù) start (默認(rèn)是 0) 和 end (默認(rèn)是 buffer.length)作為取值范圍。
15 buf.toJSON()
將 Buffer 實(shí)例轉(zhuǎn)換為 JSON 對(duì)象。
16 buf[index]
獲取或設(shè)置指定的字節(jié)。返回值代表一個(gè)字節(jié),所以返回值的合法范圍是十六進(jìn)制0x00到0xFF 或者十進(jìn)制0至 255。
17 buf.equals(otherBuffer)
比較兩個(gè)緩沖區(qū)是否相等,如果是返回 true,否則返回 false。
18 buf.compare(otherBuffer)
比較兩個(gè) Buffer 對(duì)象,返回一個(gè)數(shù)字,表示 buf 在 otherBuffer 之前,之后或相同。
19 buf.copy(targetBuffer[, targetStart[, sourceStart[, sourceEnd]]])
buffer 拷貝,源和目標(biāo)可以相同。 targetStart 目標(biāo)開始偏移和 sourceStart 源開始偏移默認(rèn)都是 0。 sourceEnd 源結(jié)束位置偏移默認(rèn)是源的長(zhǎng)度 buffer.length 。
20 buf.slice([start[, end]])
剪切 Buffer 對(duì)象,根據(jù) start(默認(rèn)是 0 ) 和 end (默認(rèn)是 buffer.length ) 偏移和裁剪了索引。 負(fù)的索引是從 buffer 尾部開始計(jì)算的。
21 buf.readUInt8(offset[, noAssert])
根據(jù)指定的偏移量,讀取一個(gè)無符號(hào) 8 位整數(shù)。若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 如果這樣 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
22 buf.readUInt16LE(offset[, noAssert])
根據(jù)指定的偏移量,使用特殊的 endian 字節(jié)序格式讀取一個(gè)無符號(hào) 16 位整數(shù)。若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出 buffer 的末尾。默認(rèn)是 false。
23 buf.readUInt16BE(offset[, noAssert])
根據(jù)指定的偏移量,使用特殊的 endian 字節(jié)序格式讀取一個(gè)無符號(hào) 16 位整數(shù),大端對(duì)齊。若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出 buffer 的末尾。默認(rèn)是 false。
24 buf.readUInt32LE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian 字節(jié)序格式讀取一個(gè)無符號(hào) 32 位整數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
25 buf.readUInt32BE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian 字節(jié)序格式讀取一個(gè)無符號(hào) 32 位整數(shù),大端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
26 buf.readInt8(offset[, noAssert])
根據(jù)指定的偏移量,讀取一個(gè)有符號(hào) 8 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出 buffer 的末尾。默認(rèn)是 false。
27 buf.readInt16LE(offset[, noAssert])
根據(jù)指定的偏移量,使用特殊的 endian 格式讀取一個(gè) 有符號(hào) 16 位整數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出 buffer 的末尾。默認(rèn)是 false。
28 buf.readInt16BE(offset[, noAssert])
根據(jù)指定的偏移量,使用特殊的 endian 格式讀取一個(gè) 有符號(hào) 16 位整數(shù),大端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出 buffer 的末尾。默認(rèn)是 false。
29 buf.readInt32LE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian 字節(jié)序格式讀取一個(gè)有符號(hào) 32 位整數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
30 buf.readInt32BE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian 字節(jié)序格式讀取一個(gè)有符號(hào) 32 位整數(shù),大端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
31 buf.readFloatLE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian 字節(jié)序格式讀取一個(gè) 32 位雙浮點(diǎn)數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer的末尾。默認(rèn)是 false。
32 buf.readFloatBE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian 字節(jié)序格式讀取一個(gè) 32 位雙浮點(diǎn)數(shù),大端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer的末尾。默認(rèn)是 false。
33 buf.readDoubleLE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian字節(jié)序格式讀取一個(gè) 64 位雙精度數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
34 buf.readDoubleBE(offset[, noAssert])
根據(jù)指定的偏移量,使用指定的 endian字節(jié)序格式讀取一個(gè) 64 位雙精度數(shù),大端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 offset 可能會(huì)超出buffer 的末尾。默認(rèn)是 false。
35 buf.writeUInt8(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量將 value 寫入 buffer。注意:value 必須是一個(gè)合法的無符號(hào) 8 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則不要使用。默認(rèn)是 false。
36 buf.writeUInt16LE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)合法的無符號(hào) 16 位整數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出buffer的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
37 buf.writeUInt16BE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)合法的無符號(hào) 16 位整數(shù),大端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出buffer的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
38 buf.writeUInt32LE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式(LITTLE-ENDIAN:小字節(jié)序)將 value 寫入buffer。注意:value 必須是一個(gè)合法的無符號(hào) 32 位整數(shù),小端對(duì)齊。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著value 可能過大,或者offset可能會(huì)超出buffer的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
39 buf.writeUInt32BE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式(Big-Endian:大字節(jié)序)將 value 寫入buffer。注意:value 必須是一個(gè)合法的有符號(hào) 32 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者offset可能會(huì)超出buffer的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
40 buf.writeInt8(value, offset[, noAssert])
41 buf.writeInt16LE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)合法的 signed 16 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false 。
42 buf.writeInt16BE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)合法的 signed 16 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false 。
43 buf.writeInt32LE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)合法的 signed 32 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
44 buf.writeInt32BE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)合法的 signed 32 位整數(shù)。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
45 buf.writeFloatLE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer 。注意:當(dāng) value 不是一個(gè) 32 位浮點(diǎn)數(shù)類型的值時(shí),結(jié)果將是不確定的。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
46 buf.writeFloatBE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer 。注意:當(dāng) value 不是一個(gè) 32 位浮點(diǎn)數(shù)類型的值時(shí),結(jié)果將是不確定的。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成 value 被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
47 buf.writeDoubleLE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)有效的 64 位double 類型的值。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成value被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
48 buf.writeDoubleBE(value, offset[, noAssert])
根據(jù)傳入的 offset 偏移量和指定的 endian 格式將 value 寫入 buffer。注意:value 必須是一個(gè)有效的 64 位double 類型的值。 若參數(shù) noAssert 為 true 將不會(huì)驗(yàn)證 value 和 offset 偏移量參數(shù)。 這意味著 value 可能過大,或者 offset 可能會(huì)超出 buffer 的末尾從而造成value被丟棄。 除非你對(duì)這個(gè)參數(shù)非常有把握,否則盡量不要使用。默認(rèn)是 false。
49 buf.fill(value, offset)
使用指定的 value 來填充這個(gè) buffer。如果沒有指定 offset (默認(rèn)是 0) 并且 end (默認(rèn)是 buffer.length) ,將會(huì)填充整個(gè)buffer。
最后的總結(jié):
實(shí)時(shí)通訊,特別是三端加密和消息同步這塊,是非常復(fù)雜的,本人大概只寫到了10分之1
組包和拆包,具體要根據(jù)你特定的業(yè)務(wù)場(chǎng)景還有公司定制的協(xié)議去具體操作,這里只是一個(gè)大概闡述
后臺(tái)的代碼以后我會(huì)盡力用golang和node.js各寫一份。
海量高并發(fā)場(chǎng)景,機(jī)房部署,整體架構(gòu)這里都沒有寫,因?yàn)榇_實(shí)太多了,一旦并發(fā)量上來了,無論前后端要做的事情都非常多
有幸公司昨天在深圳萬象城請(qǐng)到了Bilibili的架構(gòu)師毛劍先生給我們培訓(xùn),他讓我對(duì)后端的認(rèn)識(shí)又深刻了不少,特別是IM整體架構(gòu)和優(yōu)化這塊,以后總結(jié)好了,也會(huì)給大家分享
如果有寫得不對(duì)的地方,請(qǐng)指出,謝謝。
加解密的過程沒有寫上來,這塊也是非常核心。
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.specialneedsforspecialkids.com/yun/114859.html
摘要:通信協(xié)議于年被定為標(biāo)準(zhǔn),并由補(bǔ)充規(guī)范。連接創(chuàng)建后,客戶端服務(wù)端進(jìn)行數(shù)據(jù)交換時(shí),協(xié)議控制的數(shù)據(jù)包頭部較小。包頭是包的開始標(biāo)記,整個(gè)包的大小就是包的結(jié)束標(biāo)。如何自定義協(xié)議發(fā)送時(shí)數(shù)據(jù)包是由包頭數(shù)據(jù)組成的其中包頭內(nèi)容分為包類型包長(zhǎng)度。 showImg(https://segmentfault.com/img/bVbud6m?w=1440&h=1080); 深南大道鎮(zhèn)樓 定義一個(gè)自己的通訊協(xié)議并...
摘要:通信協(xié)議于年被定為標(biāo)準(zhǔn),并由補(bǔ)充規(guī)范。連接創(chuàng)建后,客戶端服務(wù)端進(jìn)行數(shù)據(jù)交換時(shí),協(xié)議控制的數(shù)據(jù)包頭部較小。包頭是包的開始標(biāo)記,整個(gè)包的大小就是包的結(jié)束標(biāo)。如何自定義協(xié)議發(fā)送時(shí)數(shù)據(jù)包是由包頭數(shù)據(jù)組成的其中包頭內(nèi)容分為包類型包長(zhǎng)度。 showImg(https://segmentfault.com/img/bVbud6m?w=1440&h=1080); 深南大道鎮(zhèn)樓 定義一個(gè)自己的通訊協(xié)議并...
摘要:只有動(dòng)手,你才能真的理解作者的構(gòu)思的巧妙只有動(dòng)手,你才能真正掌握一門技術(shù)持續(xù)更新中項(xiàng)目地址求求求源碼系列跟一起學(xué)如何寫函數(shù)庫(kù)中高級(jí)前端面試手寫代碼無敵秘籍如何用不到行代碼寫一款屬于自己的類庫(kù)原理講解實(shí)現(xiàn)一個(gè)對(duì)象遵循規(guī)范實(shí)戰(zhàn)手摸手,帶你用擼 Do it yourself!!! 只有動(dòng)手,你才能真的理解作者的構(gòu)思的巧妙 只有動(dòng)手,你才能真正掌握一門技術(shù) 持續(xù)更新中…… 項(xiàng)目地址 https...
閱讀 3731·2021-11-17 09:33
閱讀 2757·2021-09-22 15:12
閱讀 3358·2021-08-12 13:24
閱讀 2453·2019-08-30 11:14
閱讀 1744·2019-08-29 14:09
閱讀 1334·2019-08-26 14:01
閱讀 3075·2019-08-26 13:49
閱讀 1787·2019-08-26 12:16