带有节点群集模块的Socket.io
我希望使用Node集群模块和socket.io运行Node.js应用程序。我使用sticky-session设置了它，它可以工作，但我的问题如下：
例如，如果我连接到worker 5。
例如，另一个人连接到worker 4。
当我发送一条消息时，只有同一个worker上的其他人会收到消息，但我希望如果我在一个worker上发送一条消息，它也会发送给其他每个worker。
下面是我的服务器代码。
var sticky = require('sticky-session'),
http = require('http'),
express = require('express'),
socketIO = require('socket.io'),
cluster = require('cluster'),
port = process.env.PORT || 3003;
var app = express(), io;
server = http.Server(app);
app.get('/', function(req, res) {
res.sendfile('index.html');
});
io = socketIO(server);
let totalUsers = 0;
io.on('connection', function(socket) {
socket.on('chat message', function(msg) {
console.log("got request");
io.emit('chat message', msg+" send by worker "+cluster.worker.id);
});
});
if(!sticky.listen(server,port))
{
server.once('listening', function() {
console.log('Server started on port '+port);
});
if (cluster.isMaster) {
console.log('Master server started on port '+port);
}
}
else {
console.log('- Child server started on port '+port+' case worker id='+cluster.worker.id);
}下面是我的客户端代码
<!doctype html>
<html>
<head>
<title>Socket.IO chat</title>
<style>
* { margin: 0; padding: 0; box-sizing: border-box; }
body { font: 13px Helvetica, Arial; }
form { background: #000; padding: 3px; position: fixed; bottom: 0; width: 100%; }
form input { border: 0; padding: 10px; width: 90%; margin-right: .5%; }
form button { width: 9%; background: rgb(130, 224, 255); border: none; padding: 10px; }
#messages { list-style-type: none; margin: 0; padding: 0; }
#messages li { padding: 5px 10px; }
#messages li:nth-child(odd) { background: #eee; }
#messages { margin-bottom: 40px }
</style>
</head>
<body>
<ul id="messages"></ul>
<form action="">
<input id="m" autocomplete="off" /><button>Send</button>
</form>
<script src="https://cdn.socket.io/socket.io-1.2.0.js"></script>
<script src="https://code.jquery.com/jquery-1.11.1.js"></script>
<script>
$(function () {
var socket = io();
$('form').submit(function(){
socket.emit('chat message', $('#m').val());
$('#m').val('');
return false;
});
socket.on('chat message', function(msg){
$('#messages').append($('<li>').text(msg));
window.scrollTo(0, document.body.scrollHeight);
});
});
</script>
</body>
</html>回答 2
Stack Overflow用户
发布于 2018-02-27 15:03:58
socket.emit('chat message'，$('#m').val())；相反，您希望使用此io.socket.emit('chat message'，$(‘#m’).val())发送到所有套接字；或者使用socket.broadcast.emit()
Stack Overflow用户
发布于 2018-02-27 15:09:59
socket.io本身不支持集群。要获得适当的集群支持，以便您可以向所有集群上的所有用户或任何单个用户发出消息，而不管他们在哪个集群上，您需要使用诸如redis适配器之类的东西来记录所有用户在所有集群都可以访问的socket.io内存数据库中的集群。
粘性会话将给定的客户端保持在同一集群上，但它们不能解决与不同集群上的套接字通信相关的任何问题。这就是redis适配器为您做的事情。
在这里的socket.io文档中描述了如何配置redis适配器：https://socket.io/docs/using-multiple-nodes/
https://stackoverflow.com/questions/49002856
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号