1.Nodejs提供了net模塊給我們，所以我們創建TCP服務器很簡單：
|
1
2
3
4
5
6
7
8
9
10
|
require('net').createServer(function(socket) { // new connection socket.on('data', function(data) { // got data }); socket.on('end', function(data) { // connection closed }); socket.write('Some string');}).listen(); |
通過var server = require('net').createServer();這行代碼我們可以得到tcp服務器對象的引用。
server對象具注冊了以下幾個監聽事件：
listening,connection,close,error
下面一個例子是在TCP服務器的聲明周期中監聽了如上幾個事件：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
var server = require('net').createServer(); var port = ; server.on('listening', function() { console.log('Server is listening on port', port); }); server.on('connection', function(socket) { console.log('Server has a new connection'); socket.end(); server.close(); }); server.on('close', function() { console.log('Server is now closed'); }); server.on('error', function(err) { console.log('Error occurred:', err.message); }); server.listen(port); |
一旦建立連接成功后，會得到一個socket對象作為回調中的參數，我們可以操作這個socket對象，前面提到過tcp連接的對象是可讀可寫的流。作為一個流對象，因此能夠監聽data,end等事件；作為一個可寫流，具有write()方法。 下面是一個能夠監聽用戶輸入的例子：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
var server = require('net').createServer(function(socket) { console.log('new connection'); socket.setEncoding('utf'); socket.write("Hello! You can start typing. Type 'quit' to exit.\n"); socket.on('data', function(data) { console.log('got:', data.toString()) if (data.trim().toLowerCase() === 'quit') { socket.write('Bye bye!'); return socket.end(); } //反饋回客戶端 socket.write(data); }); socket.on('end', function() { console.log('Client connection ended'); });}).listen(); |
因為socket對象又是一個可讀的流，因此你能夠空氣他的pause()和resume()，或者你可以直接使用pipe()方法輸出一個可寫流：
|
1
2
3
4
|
var ws = require('fs').createWriteStream('helloworld.txt');require('net').createServer(function(socket) { socket.pipe(ws);}).listen(); |
上面的代碼創建了一個可寫流對象，然后將這個可寫流對象輸出到客戶端。在客戶端可以得到一個名為helloworld.txt的文件，
可以用“telnet localhost 4001”來測試該例子。
因為socket對象同時具有可讀流的性質和可寫流的性質，因此上面的例子你可以反過來形成下面這樣的代碼：
|
1
2
3
4
|
require('net').createServer(function(socket) { var rs = require('fs').createReadStream('hello.txt'); rs.pipe(socket);}).listen(); |
上面的代碼將hello.text文件內容輸出到socket對象中返回給客戶端，當內容輸出完成后，tcp連接就會退出，在前面的文章中有說過Pipe的用法，默認情況下在數據讀取完成后就會執行end方法，因此如果不想要這樣的效果并保持連接的話可以在pipe中添加第二個參數：{ end : false }，并重寫end監聽。
2.閑置socket 當有閑置的socket出現的時候我們需要進行相應的清除的工作，由setTimeout方法可以幫我們把閑置的socket對象關閉。
|
1
2
3
4
5
6
|
var timeout = ; // minutesocket.setTimeout(timeout);socket.on('timeout', function() { socket.write('idle timeout, disconnecting, bye!'); socket.end();}); |
下面是一個更簡潔的使用方式：
|
1
2
3
|
socket.setTimeout(60000, function() { socket.end('idle timeout, disconnecting, bye!');}); |
3.保持連接
socket.setKeepAlive(true);
你也可以添加第二個參數在設置可延時時長：
socket.setKeepAlive(true, 10000); // 10 seconds
4.是否使用延時
kernel會在發送tcp數據包之前緩存數據，因此會占據一定的延時，這對于某些小數據包場景來說是有用的，但如果你不希望有這樣的延時的話，那么你可以這樣設置：
socket.setNoDelay(true);
var port = ;
var host = '...';
server.listen(port, host);
listen方法的第二個參數是監聽客戶端的ip地址，如果填寫則只監聽所填寫的ip，否則則監聽所有ip地址，默認情況下不填寫。 關閉服務器連接，我們可以使用close方法，同時也可以對該事件進行監聽。
server.close();
server.on('close', function() {
console.log('server closed!');
});
6.創建一個簡單的TCP聊天室服務器
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
var net = require('net'); var server = net.createServer(); var sockets = []; server.on('connection', function(socket) { console.log('got a new connection'); sockets.push(socket); console.log('sockets length:', sockets.length); socket.on('data', function(data) { console.log('got data:', data.toString()); sockets.forEach(function(otherSocket) { if (otherSocket !== socket) { otherSocket.write(data); } }); }); socket.on('close', function() { console.log('connection closed'); var index = sockets.indexOf(socket); sockets.splice(index, ); console.log('sockets length:', sockets.length); }); }); server.on('error', function(err) { console.log('Server error:', err.message); }); server.on('close', function() { console.log('Server closed'); }); server.listen(); |
