1 exports.inherits = function(ctor, superCtor) {
 2   ctor.super_ = superCtor;
 3   ctor.prototype = Object.create(superCtor.prototype, {
 4     constructor: {
 5       value: ctor,
 6       enumerable: false,
 7       writable: true,
 8       configurable: true
 9     }
10   });
11 };

 1 var net = require('net') ;
 2 var server = net.createServer(function(c) { // Connection监听器
 3   console.log("服务器已连接") ;
 4   c.on("end", function() {
 5     console.log("服务器已断开") ;
 6   }) ;
 7   c.write("Hello,Bigbear !\r\n") ;
 8   c.pipe(c) ;
 9 }) ;
10 server.listen(8124, function() { // Listening监听器
11   console.log("服务器已绑定") ;
12 }) ;

 1 var net = require('net') ;
 2 var client = net.connect({
 3     port: 8124
 4 },function(){ // connect监听器
 5   console.log("客户端已连接") ;
 6   client.write('Hello,Baby !\r\n') ;
 7 });
 8 client.on("data", function(data) {
 9   console.log(data.toString()) ;
10   client.end() ;
11 });
12 client.on("end", function(){
13   console.log("客户端断开连接") ;
14 }) ;

 1 //  Sever --> Client 的单向通讯
 2 var net = require('net');
 3
 4 var chatServer = net.createServer();
 5
 6 chatServer.on('connection', function(client) {
 7   client.write('Hi!\n'); // 服务端向客户端输出信息，使用 write() 方法
 8   client.write('Bye!\n');
 9
10   client.end(); // 服务端结束该次会话
11 });
12
13 chatServer.listen(9000);

 1 // 在前者的基础上，实现 Client --> Sever 的通讯，如此一来便是双向通讯
 2 var net = require('net');
 3 var chatServer = net.createServer(),
 4     clientList = [];
 5
 6 chatServer.on('connection', function(client) {
 7   // JS 可以为对象自由添加属性。这里我们添加一个 name 的自定义属性，用于表示哪个客户端（客户端的地址+端口为依据）
 8   client.name = client.remoteAddress + ':' + client.remotePort;
 9   client.write('Hi ' + client.name + '!\n');
10   clientList.push(client);
11   client.on('data', function(data) {
12      broadcast(data, client);// 接受来自客户端的信息
13   });
14 });
15 function broadcast(message, client) {
16     for(var i=0;i<clientList.length;i+=1) {
17       if(client !== clientList[i]) {
18         clientList[i].write(client.name + " says " + message);
19       }
20     }
21 }
22 chatServer.listen(9000);

 1 chatServer.on('connection', function(client) {
 2   client.name = client.remoteAddress + ':' + client.remotePort
 3   client.write('Hi ' + client.name + '!\n');
 4
 5   clientList.push(client)
 6
 7   client.on('data', function(data) {
 8     broadcast(data, client)
 9   })
10
11   client.on('end', function() {
12     clientList.splice(clientList.indexOf(client), 1); // 删除数组中的制定元素。
13   })
14 })

 1 function broadcast(message, client) {
 2   var cleanup = []
 3   for(var i=0;i<clientList.length;i+=1) {
 4     if(client !== clientList[i]) {
 5
 6       if(clientList[i].writable) { // 先检查 sockets 是否可写
 7         clientList[i].write(client.name + " says " + message)
 8       } else {
 9         cleanup.push(clientList[i]) // 如果不可写，收集起来销毁。销毁之前要 Socket.destroy() 用 API 的方法销毁。
10         clientList[i].destroy()
11       }
12
13     }
14   }  //Remove dead Nodes out of write loop to avoid trashing loop index
15   for(i=0;i<cleanup.length;i+=1) {
16     clientList.splice(clientList.indexOf(cleanup[i]), 1)
17   }
18 }

client.on('error', function(e) {console.log(e);
});