~~~ var app = require("http").createServer(handler); var io = require("socket.io")(app); var fs = require("fs"); app.listen(8080); function handler(req, res) { fs.readFile(__dirname+'/index.html', function (err, data) { if(err){ res.writeHead(500); return res.end('Error loading index.html'); } res.writeHead(200); res.end(data); }); } io.on('connection', function (socket) { console.log("有客户端来了...."+ socket.id ) //监听消息 socket.on('msg', function (data) { console.log("客户端"+socket.id+": "+data) }) //给客户端发送消息 socket.emit('msg', "hello 客户端"+socket.id) //给指定客户端发送消息 //1.0之前 // io.sockets.socket(socket.id).emit('msg', "给"+socket.id+"发送消息"); //1.0之后 io.sockets.connected[socket.id].emit('message','surprise'); //给所有客户端广播消息 io.sockets.emit('msg', "给所有客户端广播消息"); //给除自己以外的客户端广播消息 socket.broadcast.emit('msg', "客户端"+socket.id+" 上线了 "); }); ~~~