Nodejs創建TCP服務器

1.Nodejs提供了net模塊給我們，所以我們創建TCP服務器很簡單：

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(4001);

通過var server = require('net').createServer();這行代碼我們可以得到tcp服務器對象的引用。
server對象具注冊了以下幾個監聽事件：
listening,connection,close,error
下面一個例子是在TCP服務器的聲明周期中監聽了如上幾個事件：

var server = require('net').createServer();
var port = 4001;
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()方法。
下面是一個能夠監聽用戶輸入的例子：

var server = require('net').createServer(function(socket) {
    console.log('new connection');
    socket.setEncoding('utf8');
    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(4001);

因為socket對象又是一個可讀的流，因此你能夠空氣他的pause()和resume()，或者你可以直接使用pipe()方法輸出一個可寫流：

var ws = require('fs').createWriteStream('helloworld.txt');
require('net').createServer(function(socket) {
    socket.pipe(ws);
}).listen(4001);

上面的代碼創建了一個可寫流對象，然后將這個可寫流對象輸出到客戶端。在客戶端可以得到一個名為helloworld.txt的文件，
可以用“telnet localhost 4001”來測試該例子。
因為socket對象同時具有可讀流的性質和可寫流的性質，因此上面的例子你可以反過來形成下面這樣的代碼：

require('net').createServer(function(socket) {
    var rs = require('fs').createReadStream('hello.txt');
    rs.pipe(socket);
}).listen(4001);

上面的代碼將hello.text文件內容輸出到socket對象中返回給客戶端，當內容輸出完成后，tcp連接就會退出，在前面的文章中有說過Pipe的用法，默認情況下在數據讀取完成后就會執行end方法，因此如果不想要這樣的效果並保持連接的話可以在pipe中添加第二個參數：{ end : false }，並重寫end監聽。

 

2.閑置socket
當有閑置的socket出現的時候我們需要進行相應的清除的工作，由setTimeout方法可以幫我們把閑置的socket對象關閉。

var timeout = 60000; // 1 minute
socket.setTimeout(timeout);
socket.on('timeout', function() {
    socket.write('idle timeout, disconnecting, bye!');
    socket.end();
});

下面是一個更簡潔的使用方式：

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);

5.監聽關閉連接

var port = 4001;
var host = '0.0.0.0';
server.listen(port, host);

listen方法的第二個參數是監聽客戶端的ip地址，如果填寫則只監聽所填寫的ip，否則則監聽所有ip地址，默認情況下不填寫。
關閉服務器連接，我們可以使用close方法，同時也可以對該事件進行監聽。

server.close();
server.on('close', function() {
    console.log('server closed!');
});

 

6.創建一個簡單的TCP聊天室服務器

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, 1);
        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(4001);

 7.常用插件

7.1開發中可以安裝supervisor來提高調試效率，這個插件可以保證我們每次修改完代碼后都無需重新手動啟動nodejs服務器，由supervisor幫我們自動搞定。

npm install -g supervisor

安裝完成后可以： supervisor bin/www

7.2在服務器環境中部署nodejs，我們不希望程序會斷掉，因此，就需要一個能自動重啟的服務來幫我們實現這一功能。

$ sudo npm install forever -g #安裝 $ forever start app.js #啟動 $ forever stop app.js #關閉 $ forever start -l forever.log -o out.log -e err.log app.js #輸出日志和錯誤