摘要：創(chuàng)建服務(wù)器方法返回被創(chuàng)建的服務(wù)器參數(shù)參數(shù)值為一個(gè)對(duì)象可以在給兌現(xiàn)各種使用一個(gè)布爾類型的屬性當(dāng)為時(shí)當(dāng)服務(wù)器接收到客戶端發(fā)送的一個(gè)包時(shí)將會(huì)回發(fā)一個(gè)包當(dāng)為時(shí)服務(wù)器接收到客戶端發(fā)送的包時(shí)不回發(fā)包這使得服務(wù)器可以繼續(xù)向客戶端發(fā)送數(shù)據(jù)但是不會(huì)繼續(xù)接收客

let server = net.createServer([options], [connectionListener]);

createServer方法返回被創(chuàng)建的TCP服務(wù)器

options參數(shù)

options參數(shù)值為一個(gè)對(duì)象,可以在給兌現(xiàn)各種使用一個(gè)布爾類型的allowHalfOpen屬性,當(dāng)為false時(shí),當(dāng)TCP服務(wù)器接收到客戶端發(fā)送的一個(gè)FIN包時(shí)將會(huì)回發(fā)一個(gè)FIN包.當(dāng)為true時(shí),TCP服務(wù)器接收到客戶端發(fā)送的FIN包時(shí)不回發(fā)FIN包,這使得TCP服務(wù)器可以繼續(xù)向客戶端發(fā)送數(shù)據(jù),但是不會(huì)繼續(xù)接收客戶端發(fā)送的數(shù)據(jù),必須調(diào)用end方法來關(guān)閉該socket連接.

connectionListener參數(shù)用于指定客戶端與服務(wù)器端建立起來時(shí)所要調(diào)用的回調(diào)函數(shù).

const net = require("net");
let server = net.createServer(false, function (socket) {});

當(dāng)客戶端與服務(wù)器建立連接時(shí),觸發(fā)connection事件,我們可以通過對(duì)connection事件進(jìn)行監(jiān)聽,并且指定該事件的返回函數(shù)的方法來指定當(dāng)客戶端與服務(wù)器建立連接時(shí)所需要執(zhí)行的處理

server.on("connection", function(socket){})

回調(diào)函數(shù)中的參數(shù)為該TCP服務(wù)器監(jiān)聽的socktet端口對(duì)象

在創(chuàng)建了TCP服務(wù)器之后,可以用listen方法通知服務(wù)器開始監(jiān)聽客戶端連接,有三種指定的方法

server.listen(port, [host], [backlog], [callback]);

port為必須要指定的參數(shù),為0時(shí)將為TCP分配一個(gè)隨機(jī)端口號(hào).

host為指定需要監(jiān)聽的IP地址或主機(jī)名,如果省略,服務(wù)器將錦亭來自任何IPv4地址的客戶端連接

backlog為一個(gè)整數(shù)值,用于指定位于等待隊(duì)列中的客戶端連接的最大數(shù)量,一旦超過這個(gè)長(zhǎng)度,TCP服務(wù)器將開始拒絕來自新的客戶端的連接請(qǐng)求,參數(shù)值默認(rèn)為511

當(dāng)對(duì)TCP服務(wù)器制定了需要監(jiān)聽的地址和端口后,服務(wù)器將立即開始監(jiān)聽來自于該地址及端口的客戶端連接,這時(shí)觸發(fā)該服務(wù)器的listening事件,可使用listen方法的callback參數(shù)來指定listening事件觸發(fā)時(shí)調(diào)用的回調(diào)函數(shù),該回調(diào)函數(shù)中不使用任何參數(shù)

server.listen(path, [callback]);

這種形式的listen方法用于通知一個(gè)使用unix端口的服務(wù)器開始監(jiān)聽來自于路徑的客戶端連接.

path為指定的需要監(jiān)聽的路徑,當(dāng)對(duì)使用unix端口的服務(wù)器指定了需要監(jiān)聽的路徑后,服務(wù)器將立即開始監(jiān)聽來自于該路徑的客戶端連接.

這時(shí)觸發(fā)該服務(wù)器的listening事件,可以使用listen方法的callback參數(shù)來指定listening事件觸發(fā)時(shí)調(diào)用的回調(diào)函數(shù),該回調(diào)函數(shù)不需要使用任何參數(shù).

server.listen(handle, [callback]);

這種形式的listen方法用于通知一個(gè)TCP服務(wù)器開始監(jiān)聽一個(gè)指定socket句柄的客戶端來接該方法使用兩個(gè)參數(shù)

(該句柄可以為一個(gè)TCP服務(wù)器對(duì)象,也可以為一個(gè)文件描述符,在WINDOWS操作系統(tǒng)中不支持對(duì)文件描述符的監(jiān)聽)

第一個(gè)參數(shù)用于執(zhí)行需要監(jiān)聽的socket句柄.當(dāng)對(duì)TCP服務(wù)器指定了需要監(jiān)聽的socket句柄后,服務(wù)器端將立即開始監(jiān)聽來自于該socket句柄的客戶端連接,這時(shí)觸發(fā)該服務(wù)器的listening事件

可以使用listen方法的callback參數(shù)來指定listening事件觸發(fā)時(shí)調(diào)用的回調(diào)函數(shù),該回調(diào)函數(shù)不需要任何參數(shù).

如果不在上述三種形式的listen方法中使用callback參數(shù),可以通過監(jiān)聽TCP服務(wù)器對(duì)象的listening事件,并且指定該事件觸發(fā)時(shí)調(diào)用的回調(diào)函數(shù)的方法來指定TCP服務(wù)器開始監(jiān)聽時(shí)所需要執(zhí)行的處理server.on("listening", function(){})

對(duì)TCP服務(wù)器指定需要監(jiān)聽的地址及端口時(shí),如果該地址及端口已經(jīng)被占用,將產(chǎn)生一個(gè)錯(cuò)誤代碼為EADDRINUSE的錯(cuò)誤(表示用于監(jiān)聽的地址和端口被占用),同是將觸發(fā)TCP服務(wù)器一個(gè)error事件,可以通過對(duì)error事件設(shè)置回調(diào)函數(shù)的方法指定該錯(cuò)誤產(chǎn)生時(shí)需要執(zhí)行的處理.

const net = require("net");
let server = net.createServer(false, function (socket) {
    // 這里的socket參數(shù)就是一個(gè)socket對(duì)象
});
server.on("error", function (e) {
    if (e.code === "EADDRINUSE") {
        console.log("該地址及端口被占用,請(qǐng)修正")
    }
});

創(chuàng)建了TCP服務(wù)器之后,可以是使用TCP服務(wù)器的address方法來查看該服務(wù)器所監(jiān)聽的地址信息

let address = server.address();

該方法返回一個(gè)對(duì)象,其中具有以下的屬性

port:TCP服務(wù)器監(jiān)聽的socket端口號(hào)

address:TCP服務(wù)器監(jiān)聽的地址,如127.0.0.1

family:一個(gè)標(biāo)識(shí)了TCP服務(wù)器所監(jiān)聽的地址的是IPv4地址還是IPv6地址的字符串,例如IPv4

使用TCP服務(wù)器的getConnections方法查看當(dāng)前與TCP服務(wù)器建立連接的客戶端連接數(shù)量server.getConnections(callback(err, count))

TCP服務(wù)器server對(duì)象的maxConnections屬性將TCP對(duì)象的最大連接數(shù)設(shè)置為2,同時(shí)在控制臺(tái)中輸出設(shè)置后的maxConnections屬性值,當(dāng)當(dāng)前客戶端與服務(wù)器連接數(shù)等于該值時(shí),不再接受新的客戶端連接請(qǐng)求.

每當(dāng)有客戶端與服務(wù)器端建立連接后,第一個(gè)命令行窗口中都將顯示當(dāng)前存在的客戶端與TCP服務(wù)器之間的連接數(shù)量.

在一個(gè)新的命令行窗口中建立與被創(chuàng)建的TCP服務(wù)器之間的連接,TCP服務(wù)器將不再接收該連接,第一個(gè)命令行窗口中不會(huì)有任何變化.

可以使用TCP服務(wù)器的close方法顯式指定服務(wù)器拒絕所有新的客戶端連接

server.close([callback()])

在使用close方法時(shí),并不會(huì)斷開所有現(xiàn)存的客戶端連接.當(dāng)這些客戶端連接被關(guān)閉時(shí),TCP服務(wù)器將會(huì)自動(dòng)關(guān)閉,同時(shí)觸發(fā)TCP服務(wù)器的close事件，close的回調(diào)函數(shù)是否有參數(shù)都可以.

在Node.js中,使用net.Socket代表一個(gè)socket端口對(duì)象,在使用createServer方法的connectionListener參數(shù)所指定的回調(diào)函數(shù)(當(dāng)客戶端與服務(wù)器端建立連接時(shí)調(diào)用)的參數(shù)值,即為一個(gè)被自動(dòng)創(chuàng)建的net.Socket對(duì)象(代表的服務(wù)器所監(jiān)聽的端口對(duì)象),在對(duì)TCP服務(wù)器所指定的connection事件回調(diào)函數(shù)的參數(shù)值同樣為一個(gè)被自動(dòng)創(chuàng)建的net.Socket對(duì)象(代表TCP服務(wù)器所監(jiān)聽的端口對(duì)象)

與TCP服務(wù)器獨(dú)享的address方法相類似,可以利用socket端口對(duì)象的address方法獲取該socket端口對(duì)象相關(guān)的地址信息

let address = socket.address();

該方法返回一個(gè)對(duì)象,其中具有以下的屬性

port:TCP服務(wù)器監(jiān)聽的socket端口號(hào)

address:TCP服務(wù)器監(jiān)聽的地址,如127.0.0.1

family:一個(gè)標(biāo)識(shí)了TCP服務(wù)器所監(jiān)聽的地址的是IPv4地址還是IPv6地址的字符串,例如IPv4

socket端口對(duì)象可被用來讀取客戶端發(fā)送的流數(shù)據(jù),每次接收到客戶端發(fā)送的流數(shù)據(jù)時(shí)觸發(fā)data事件,可通過對(duì)該事件進(jìn)行監(jiān)聽并且指定回調(diào)函數(shù)的方法來指定當(dāng)服務(wù)器端監(jiān)聽的socket端口對(duì)象接收到客戶端發(fā)送的數(shù)據(jù)時(shí)所需要執(zhí)行的處理.

socket.on("data", function (data) {});

在該回調(diào)函數(shù)中,使用給一個(gè)參數(shù),參數(shù)值為一個(gè)Buffer對(duì)象(在未使用socket端口對(duì)象的setEncoding方法指定編碼時(shí))或者一個(gè)字符串對(duì)象(在使用socket端口對(duì)象的setEncoding方法指定編碼方式后)
data獲取到的是一個(gè)存放了服務(wù)到的數(shù)據(jù)的緩存區(qū)對(duì)象,如果我們?cè)趯?duì)data事件進(jìn)行監(jiān)聽之后使用編碼格式,將在控制臺(tái)中以字符串形式輸出讀取到的數(shù)據(jù).

const net = require("net");
let server = net.createServer(false, function (socket) {
    socket.setEncoding("utf8");
    socket.on("data", function (data) {
        console.log(data);
    });
});

const net = require("net");
let server = net.createServer(false, function (socket) {
    socket.on("data", function (data) {
        console.log(data.toString());
    });
});

可以通過socket對(duì)象的pipe方法將客戶端發(fā)送的流數(shù)據(jù)寫到文件等其他目標(biāo)對(duì)象中

socket.pipe(destination, [options]);

destination參數(shù)為必須輸入?yún)?shù),options參數(shù)為可選參數(shù).destination參數(shù)值必須為一個(gè)可用于寫入流數(shù)據(jù)的對(duì)象.options參數(shù)值為一個(gè)對(duì)象,可以在該對(duì)象中使用一個(gè)布爾類型的end屬性,如果該屬性值為true,則當(dāng)數(shù)據(jù)全被讀取完畢時(shí)立即結(jié)束寫操作,如果該屬性值為false,目標(biāo)對(duì)象中可以被繼續(xù)寫入新的數(shù)據(jù),該屬性的默認(rèn)值為true;

const net = require("net");
let file = require("fs").createWriteStream("./message.txt");
let server = net.createServer();
server.on("connection", function (socket) {
    socket.pipe(file, {
        end: false
    });
    socket.on("end", function () {
        file.end("byebye");
    });
});
server.listen(9999, "localhost");

使用unpipe方法取消目標(biāo)對(duì)象的寫入操作

socket.unpipe([destination]);

可以使用socket端口對(duì)象的pause方法暫停data事件的觸發(fā),這時(shí)服務(wù)器端將把每一個(gè)客戶端發(fā)送的數(shù)據(jù)暫存在一個(gè)多帶帶的緩存區(qū)中.
socket.pause();
在使用了pause方法暫停data事件的觸發(fā)后,可以使用socket端口對(duì)象的resume方法恢復(fù)data事件的觸發(fā),這時(shí)將讀取被緩存的該客戶端的數(shù)據(jù).
socket.resume();

通過監(jiān)聽socket端口對(duì)象的timeout事件并且指定該事件回調(diào)函數(shù)的方法來指定當(dāng)客戶端連接超時(shí)時(shí)所需要執(zhí)行的處理

const net = require("net");
let server = net.createServer();
server.on("connection", function (socket) {
    socket.setTimeout(10 * 1000);
    socket.pause();
    socket.on("timeout", function () {
        socket.resume();
        socket.pipe(file);
    });
    socket.on("data", function (data) {
        socket.pause();
    });
});

const net = require("net");
let server = net.createServer(function (socket) {
    console.log(socket);
    let address = socket.address();
    console.log("socket端口對(duì)象的地址信息為%j", address);
    // socket端口對(duì)象的地址信息為{"address":"127.0.0.1","family":"IPv4","port":2596}
    socket.setEncoding("utf8");
    socket.on("data", function (data) {
        console.log(data);
        console.log("已接收到的字節(jié)數(shù)據(jù)長(zhǎng)度", socket.bytesRead);
        /**
         * GET / HTTP/1.1
         * User-Agent: curl/7.29.0
         * Host: localhost:2596
         * Accept:      // 屬性值為"星號(hào)斜線星號(hào)"，因?yàn)闀?huì)與注釋沖突，所以沒寫
         *
         *
         * 已接收到的字節(jié)數(shù)據(jù)長(zhǎng)度 78
         * */
    });
    // 可以通過socket對(duì)象的pipe方法將客戶端發(fā)送的流數(shù)據(jù)寫到文件等其他目標(biāo)對(duì)象中
    socket.pipe(file);
    socket.on("end", function () {
        console.log("客戶端連接已關(guān)閉");
        // 當(dāng)客戶端連接關(guān)閉時(shí)，輸出"客戶端連接已關(guān)閉"
    })
});

server.getConnections(function (err, count) {
    console.log("當(dāng)前存在" + count + "個(gè)客戶端連接");
    server.maxConnections = 2;// 設(shè)置最大連接為2
    console.log("客戶端與服務(wù)器端已建立連接");
});

server.close(function () {
    console.log("TCP服務(wù)器被關(guān)閉");
});

server.on("error", function (e) {
    if (e.code === "EADDRINUSE") {
        console.log("該地址及端口被占用，請(qǐng)修正")
    }
});

let address = server.address();

server.listen(2596, "localhost", 256, function () {
    console.log("服務(wù)器開始監(jiān)聽");
});