Moz*_*art 13 javascript sockets offline node.js
+的NodeJS Socketio
var clients = {};
io.sockets.on('connection', function (socket) {
socket.on('online', function (data) {
if (!clients[data.username]) {
clients[data.username] = socket;
}
io.sockets.emit('message', data.user + 'online now');
});
socket.on('say', function (data) {
if (data.to == 'all') {
io.sockets.emit('message', data.message);
} else { //to specific client
clients[data.to].emit('message', data.message);
}
});
});
Run Code Online (Sandbox Code Playgroud)
客户端B首先连接到一个地方的服务器.在客户端B离线期间,客户端A向客户端B发送消息.然后客户端B再次连接到另一个地方的服务器,客户端B需要从客户端A接收这些消息.使它工作?
Mat*_*att 12
如果我考虑哪个db及其配置和客户端,我必须编写的代码量相当大,以创建解决方案.您基本上必须将消息保存在数据库中.当消息进入时,您必须写入对话对象(或代表客户端之间聊天消息的任何内容).
socket.on('say', function (data) {
// pseudo code to save conversation
// var conversation = db.getConversation();
// conversation.addMessage(data.message);
// conversation.save();
if (data.to == 'all') {
io.sockets.emit('message', data.message);
} else { //to specific client
clients[data.to].emit('message', data.message);
}
});
Run Code Online (Sandbox Code Playgroud)
然后,当客户端加入时,您必须从数据库中获取所有消息.
socket.on('online', function (data) {
if (!clients[data.username]) {
clients[data.username] = socket;
}
// pseudo code to get messages and display to user on first load
// var conversation = db.getConversation();
// var messages = conversation.getLast10Messages();
// messages.forEach(function(message) {
// clients[data.username].emit('message', message);
// });
io.sockets.emit('message', data.user + 'online now');
});
Run Code Online (Sandbox Code Playgroud)
归档时间: |
|
查看次数: |
6861 次 |
最近记录: |