node.js中的Socket.IO使用实例_node.js(2)
2).进入一个房间(非常好用!相当于一个命名空间,可以对一个特定的房间广播而不影响在其他房间或不在房间的客户端):socket.join('your room name');
3).向一个房间广播消息(发送者收不到消息):socket.broadcast.to('your room name').emit('broadcast room message');
4).向一个房间广播消息(包括发送者都能收到消息)(这个API属于io.sockets):io.sockets.in('another room name').emit('broadcast room message');
5).强制使用WebSocket通信:(客户端)socket.send('hi'),(服务器)用socket.on('message', function(data){})来接收。
5. 使用Socket.IO构建一个聊天室
最后,我们通过一个简单的实例来结束本篇。用Socket.IO构建一个聊天室就是50行左右的代码的事情,实时聊天效果也非常好。以下贴出关键代码:
Server(socketChat.js)
//一个客户端连接的字典,当一个客户端连接到服务器时,
//会产生一个唯一的socketId,该字典保存socketId到用户信息(昵称等)的映射
var connectionList = {};
exports.startChat = function (io) {
io.sockets.on('connection', function (socket) {
//客户端连接时,保存socketId和用户名
var socketId = socket.id;
connectionList[socketId] = {
socket: socket
};
//用户进入聊天室事件,向其他在线用户广播其用户名
socket.on('join', function (data) {
socket.broadcast.emit('broadcast_join', data);
connectionList[socketId].username = data.username;
});
//用户离开聊天室事件,向其他在线用户广播其离开
socket.on('disconnect', function () {
if (connectionList[socketId].username) {
socket.broadcast.emit('broadcast_quit', {
username: connectionList[socketId].username
});
}
delete connectionList[socketId];
});
//用户发言事件,向其他在线用户广播其发言内容
socket.on('say', function (data) {
socket.broadcast.emit('broadcast_say',{
username: connectionList[socketId].username,
text: data.text
});
});
})
};
Client(socketChatClient.js)
var socket = io.connect('http://localhost');
//连接服务器完毕后,马上提交一个“加入”事件,把自己的用户名告诉别人
socket.emit('join', {
username: 'Username hehe'
});
//收到加入聊天室广播后,显示消息
socket.on('broadcast_join', function (data) {
console.log(data.username + '加入了聊天室');
});
//收到离开聊天室广播后,显示消息
socket.on('broadcast_quit', function(data) {
console.log(data.username + '离开了聊天室');
});
//收到别人发送的消息后,显示消息
socket.on('broadcast_say', function(data) {
console.log(data.username + '说: ' + data.text);
});