学习NodeJS第八天：Socket通讯实例

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

telnet 127.0.0.1 9000 

// 在前者的基础上，实现 Client --> Sever 的通讯，如此一来便是双向通讯 
var net = require('net'); 
var chatServer = net.createServer(),  
 clientList = []; 
  
chatServer.on('connection', function(client) { 
 // JS 可以为对象自由添加属性。这里我们添加一个 name 的自定义属性，用于表示哪个客户端（客户端的地址+端口为依据） 
 client.name = client.remoteAddress + ':' + client.remotePort; 
 client.write('Hi ' + client.name + '!\n'); 
 clientList.push(client); 
 client.on('data', function(data) {  
  broadcast(data, client);// 接受来自客户端的信息 
 }); 
}); 
function broadcast(message, client) { 
 for(var i=0;i

chatServer.on('connection', function(client) { 
 client.name = client.remoteAddress + ':' + client.remotePort 
 client.write('Hi ' + client.name + '!\n'); 
 
 clientList.push(client) 
 
 client.on('data', function(data) { 
 broadcast(data, client) 
 }) 
 
 client.on('end', function() { 
 clientList.splice(clientList.indexOf(client), 1); // 删除数组中的制定元素。这是 JS 基本功哦~ 
 }) 
}) 

function broadcast(message, client) { 
 var cleanup = [] 
 for(var i=0;i

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

var http = require('http'), 
io = require('socket.io'), 
fs = require('fs'); 
 
// 虽然我们这里使用了同步的方法，那会阻塞 Node 的事件循环，但是这是合理的，因为 readFileSync() 在程序周期中只执行一次，而且更重要的是，同步方法能够避免异步方法所带来的“与 SocketIO 之间额外同步的问题”。当 HTML 文件读取完毕，而且服务器准备好之后，如此按照顺序去执行就能让客户端马上得到 HTML 内容。 
var sockFile = fs.readFileSync('socket.html'); 
 
// Socket 服务器还是构建于 HTTP 服务器之上，因此先调用 http.createServer() 
server = http.createServer(); 
server.on('request', function(req, res){ 
 // 一般 HTTP 输出的格式 
 res.writeHead(200, {'content-type': 'text/html'}); 
 res.end(sockFile); 
}); 
 
server.listen(8080); 
 
var socket = io.listen(server); // 交由 Socket.io 接管 
 
// Socket.io 真正的连接事件 
socket.on('connection', function(client){ 
 console.log('Client connected'); 
 client.send('Welcome client ' + client.sessionId); // 向客户端发送文本 
}); 

var sockFile = fs.readFileSync('socket.html'); 
 
server = http.createServer(); 
server.on('request', function(req, res){ 
 res.writeHead(200, {'content-type': 'text/html'}); 
 res.end(sockFile); 
}); 
 
server.listen(8080); 
 
var socket = io.listen(server); 
 
socket.of('/upandrunning') 
 .on('connection', function(client){ 
 console.log('Client connected to Up and Running namespace.'); 
 client.send("Welcome to 'Up and Running'"); 
}); 
 
socket.of('/weather') 
 .on('connection', function(client){ 
 console.log('Client connected to Weather namespace.'); 
 client.send("Welcome to 'Weather Updates'"); 
});