摘要:模塊概覽模塊是同樣是的核心模塊。在模塊概覽里提到,繼承了,此外,客戶端與服務端的通信均依賴于。正常關(guān)閉的同時,會被執(zhí)行,同時會觸發(fā)事件。事實上,中的在內(nèi)部實現(xiàn)中也是加入了做為事件的監(jiān)聽函數(shù)。默認情況下,會完成自我銷毀操作。
模塊概覽本文摘錄自《Nodejs學習筆記》,更多章節(jié)及更新,請訪問 github主頁地址。歡迎加群交流,群號 197339705。
net模塊是同樣是nodejs的核心模塊。在http模塊概覽里提到,http.Server繼承了net.Server,此外,http客戶端與http服務端的通信均依賴于socket(net.Socket)。也就是說,做node服務端編程,net基本是繞不開的一個模塊。
從組成來看,net模塊主要包含兩部分,了解socket編程的同學應該比較熟悉了:
net.Server:TCP server,內(nèi)部通過socket來實現(xiàn)與客戶端的通信。
net.Socket:tcp/本地 socket的node版實現(xiàn),它實現(xiàn)了全雙工的stream接口。
本文從一個簡單的 tcp服務端/客戶端 的例子開始講解,好讓讀者有個概要的認識。接著再分別介紹 net.Server、net.Socket 比較重要的API、屬性、事件。
對于初學者,建議把文中的例子本地跑一遍加深理解。
簡單的 server+client 例子tcp服務端程序如下:
var net = require("net"); var PORT = 3000; var HOST = "127.0.0.1"; // tcp服務端 var server = net.createServer(function(socket){ console.log("服務端:收到來自客戶端的請求"); socket.on("data", function(data){ console.log("服務端:收到客戶端數(shù)據(jù),內(nèi)容為{"+ data +"}"); // 給客戶端返回數(shù)據(jù) socket.write("你好,我是服務端"); }); socket.on("close", function(){ console.log("服務端:客戶端連接斷開"); }); }); server.listen(PORT, HOST, function(){ console.log("服務端:開始監(jiān)聽來自客戶端的請求"); });
tcp客戶端如下:
var net = require("net"); var PORT = 3000; var HOST = "127.0.0.1"; // tcp客戶端 var client = net.createConnection(PORT, HOST); client.on("connect", function(){ console.log("客戶端:已經(jīng)與服務端建立連接"); }); client.on("data", function(data){ console.log("客戶端:收到服務端數(shù)據(jù),內(nèi)容為{"+ data +"}"); }); client.on("close", function(data){ console.log("客戶端:連接斷開"); }); client.end("你好,我是客戶端");
運行服務端、客戶端代碼,控制臺分別輸出如下:
服務端:
服務端:開始監(jiān)聽來自客戶端的請求 服務端:收到來自客戶端的請求 服務端:收到客戶端數(shù)據(jù),內(nèi)容為{你好,我是客戶端} 服務端:客戶端連接斷開
客戶端:
客戶端:已經(jīng)與服務端建立連接 客戶端:收到服務端數(shù)據(jù),內(nèi)容為{你好,我是服務端} 客戶端:連接斷開服務端 net.Server server.address()
返回服務端的地址信息,比如綁定的ip地址、端口等。
console.log( server.address() ); // 輸出如下 { port: 3000, family: "IPv4", address: "127.0.0.1" }server.close(callback])
關(guān)閉服務器,停止接收新的客戶端請求。有幾點注意事項:
對正在處理中的客戶端請求,服務器會等待它們處理完(或超時),然后再正式關(guān)閉。
正常關(guān)閉的同時,callback 會被執(zhí)行,同時會觸發(fā) close 事件。
異常關(guān)閉的同時,callback 也會執(zhí)行,同時將對應的 error 作為參數(shù)傳入。(比如還沒調(diào)用 server.listen(port) 之前,就調(diào)用了server.close())
下面會通過兩個具體的例子進行對比,先把結(jié)論列出來
已調(diào)用server.listen():正常關(guān)閉,close事件觸發(fā),然后callback執(zhí)行,error參數(shù)為undefined
未調(diào)用server.listen():異常關(guān)閉,close事件觸發(fā),然后callback執(zhí)行,error為具體的錯誤信息。(注意,error 事件沒有觸發(fā))
例子1:服務端正常關(guān)閉
var net = require("net"); var PORT = 3000; var HOST = "127.0.0.1"; var noop = function(){}; // tcp服務端 var server = net.createServer(noop); server.listen(PORT, HOST, function(){ server.close(function(error){ if(error){ console.log( "close回調(diào):服務端異常:" + error.message ); }else{ console.log( "close回調(diào):服務端正常關(guān)閉" ); } }); }); server.on("close", function(){ console.log( "close事件:服務端關(guān)閉" ); }); server.on("error", function(error){ console.log( "error事件:服務端異常:" + error.message ); });
輸出為:
close事件:服務端關(guān)閉 close回調(diào):服務端正常關(guān)閉
例子2:服務端異常關(guān)閉
代碼如下
var net = require("net"); var PORT = 3000; var HOST = "127.0.0.1"; var noop = function(){}; // tcp服務端 var server = net.createServer(noop); // 沒有正式啟動請求監(jiān)聽 // server.listen(PORT, HOST); server.on("close", function(){ console.log( "close事件:服務端關(guān)閉" ); }); server.on("error", function(error){ console.log( "error事件:服務端異常:" + error.message ); }); server.close(function(error){ if(error){ console.log( "close回調(diào):服務端異常:" + error.message ); }else{ console.log( "close回調(diào):服務端正常關(guān)閉" ); } });
輸出為:
close事件:服務端關(guān)閉 close回調(diào):服務端異常:Not runningserver.ref()/server.unref()
了解node事件循環(huán)的同學對這兩個API應該不陌生,主要用于將server 加入事件循環(huán)/從事件循環(huán)里面剔除,影響就在于會不會影響進程的退出。
對出學習net的同學來說,并不需要特別關(guān)注,感興趣的自己做下實驗就好。
事件 listening/connection/close/errorlistening:調(diào)用 server.listen(),正式開始監(jiān)聽請求的時候觸發(fā)。
connection:當有新的請求進來時觸發(fā),參數(shù)為請求相關(guān)的 socket。
close:服務端關(guān)閉的時候觸發(fā)。
error:服務出錯的時候觸發(fā),比如監(jiān)聽了已經(jīng)被占用的端口。
幾個事件都比較簡單,這里僅舉個 connection 的例子。
從測試結(jié)果可以看出,有新的客戶端連接產(chǎn)生時,net.createServer(callback) 中的callback回調(diào) 會被調(diào)用,同時 connection 事件注冊的回調(diào)函數(shù)也會被調(diào)用。
事實上,net.createServer(callback) 中的 callback 在node內(nèi)部實現(xiàn)中 也是加入了做為 connection事件 的監(jiān)聽函數(shù)。感興趣的可以看下node的源碼。
var net = require("net"); var PORT = 3000; var HOST = "127.0.0.1"; var noop = function(){}; // tcp服務端 var server = net.createServer(function(socket){ socket.write("1. connection 觸發(fā) "); }); server.on("connection", function(socket){ socket.end("2. connection 觸發(fā) "); }); server.listen(PORT, HOST);
通過下面命令測試下效果
curl http://127.0.0.1:3000
輸出:
1. connection 觸發(fā) 2. connection 觸發(fā)客戶端 net.Socket
在文章開頭已經(jīng)舉過客戶端的例子,這里再把例子貼一下。(備注:嚴格來說不應該把 net.Socket 叫做客戶端,這里方便講解而已)
單從node官方文檔來看的話,感覺 net.Socket 比 net.Server 要復雜很多,有更多的API、事件、屬性。但實際上,把 net.Socket 相關(guān)的API、事件、屬性 進行歸類下,會發(fā)現(xiàn),其實也不是特別復雜。
具體請看下一小節(jié)內(nèi)容。
var net = require("net"); var PORT = 3000; var HOST = "127.0.0.1"; // tcp客戶端 var client = net.createConnection(PORT, HOST); client.on("connect", function(){ console.log("客戶端:已經(jīng)與服務端建立連接"); }); client.on("data", function(data){ console.log("客戶端:收到服務端數(shù)據(jù),內(nèi)容為{"+ data +"}"); }); client.on("close", function(data){ console.log("客戶端:連接斷開"); }); client.end("你好,我是客戶端");API、屬性歸類
以下對net.Socket的API跟屬性,按照用途進行了大致的分類,方便讀者更好的理解。大部分API跟屬性都比較簡單,看下文檔就知道做什么的,這里就先不展開。
連接相關(guān)socket.connect():有3種不同的參數(shù),用于不同的場景;
socket.setTimeout():用來進行連接超時設(shè)置。
socket.setKeepAlive():用來設(shè)置長連接。
socket.destroy()、socket.destroyed:當錯誤發(fā)生時,用來銷毀socket,確保這個socket上不會再有其他的IO操作。
數(shù)據(jù)讀、寫相關(guān)socket.write()、socket.end()、socket.pause()、socket.resume()、socket.setEncoding()、socket.setNoDelay()
數(shù)據(jù)屬性相關(guān)socket.bufferSize、socket.bytesRead、socket.bytesWritten
事件循環(huán)相關(guān)socket.ref()、socket.unref()
地址相關(guān)socket.address()
socket.remoteAddress、socket.remoteFamily、socket.remotePort
socket.localAddress/socket.localPort
事件簡介data:當收到另一側(cè)傳來的數(shù)據(jù)時觸發(fā)。
connect:當連接建立時觸發(fā)。
close:連接斷開時觸發(fā)。如果是因為傳輸錯誤導致的連接斷開,則參數(shù)為error。
end:當連接另一側(cè)發(fā)送了 FIN 包的時候觸發(fā)(讀者可以回顧下HTTP如何斷開連接的)。默認情況下(allowHalfOpen == false),socket會完成自我銷毀操作。但你也可以把 allowHalfOpen 設(shè)置為 true,這樣就可以繼續(xù)往socket里寫數(shù)據(jù)。當然,最后你需要手動調(diào)用 socket.end()
error:當有錯誤發(fā)生時,就會觸發(fā),參數(shù)為error。(官方文檔基本一句話帶過,不過考慮到出錯的可能太多,也可以理解)
timeout:提示用戶,socket 已經(jīng)超時,需要手動關(guān)閉連接。
drain:當寫緩存空了的時候觸發(fā)。(不是很好描述,具體可以看下stream的介紹)
lookup:域名解析完成時觸發(fā)。
相關(guān)鏈接官方文檔:
https://nodejs.org/api/net.ht...
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/80911.html
摘要:是企業(yè)與區(qū)塊鏈相遇的地方。的框架旨在成為開發(fā)區(qū)塊鏈解決方案的支柱。以太坊,主要是針對工程師使用進行區(qū)塊鏈以太坊開發(fā)的詳解。 如果你想將區(qū)塊鏈合并到一個Java項目中,現(xiàn)在我們來看看就是這個細分領(lǐng)域中三個最大的OSS玩家。 好的伙計們,我們都聽說過比特幣,以太坊或其他加密貨幣,其中有一些時髦的名字圍繞著我們常見的新聞,但我們作為Java開發(fā)人員知道如何輕松地與這些區(qū)塊鏈技術(shù)進行交互嗎?以...
摘要:我們目前正處于一個新興的區(qū)塊鏈開發(fā)行業(yè)中。,一種在以太坊開發(fā)人員中流行的新的簡單編程語言,因為它是用于開發(fā)以太坊智能合約的語言。它是全球至少萬開發(fā)人員使用的世界上最流行的編程語言之一。以太坊,主要是針對工程師使用進行區(qū)塊鏈以太坊開發(fā)的詳解。 我們目前正處于一個新興的區(qū)塊鏈開發(fā)行業(yè)中。區(qū)塊鏈技術(shù)處于初期階段,然而這種顛覆性技術(shù)已經(jīng)成功地風靡全球,并且最近經(jīng)歷了一場與眾不同的繁榮。由于許多...
摘要:其中負載均衡那一節(jié),基本上是參考的權(quán)威指南負載均衡的內(nèi)容。開發(fā)指南讀了一半,就是看這本書理解了的事件循環(huán)。哈哈創(chuàng)京東一本騙錢的書。 歡迎大家前往騰訊云+社區(qū),獲取更多騰訊海量技術(shù)實踐干貨哦~ 本文由騰訊IVWEB團隊 發(fā)表于云+社區(qū)專欄作者:link 2014年一月以來,自己接觸web前端開發(fā)已經(jīng)兩年多了,記錄一下自己前端學習路上看過的,以及道聽途說的一些書,基本上按照由淺入深來介紹...
摘要:其中負載均衡那一節(jié),基本上是參考的權(quán)威指南負載均衡的內(nèi)容。開發(fā)指南讀了一半,就是看這本書理解了的事件循環(huán)。哈哈創(chuàng)京東一本騙錢的書。 歡迎大家前往騰訊云+社區(qū),獲取更多騰訊海量技術(shù)實踐干貨哦~ 本文由騰訊IVWEB團隊 發(fā)表于云+社區(qū)專欄作者:link 2014年一月以來,自己接觸web前端開發(fā)已經(jīng)兩年多了,記錄一下自己前端學習路上看過的,以及道聽途說的一些書,基本上按照由淺入深來介紹...
閱讀 3698·2021-11-22 15:24
閱讀 1607·2021-09-26 09:46
閱讀 1919·2021-09-14 18:01
閱讀 2614·2019-08-30 15:45
閱讀 3532·2019-08-30 14:23
閱讀 1881·2019-08-30 12:43
閱讀 2920·2019-08-30 10:56
閱讀 805·2019-08-29 12:20