我正在尝试创建一个分布式信息系统,该系统使用对等架构和多播通信。
首先我开始实现多播通信。我从来没有这样做过,所以我遇到了一些很难理解为什么它不能正常工作的问题。
这是我设法做到的:
服务器
var SRC_PORT = 6025;
var PORT = 6024;
var MULTICAST_ADDR = '239.255.255.250';
var dgram = require('dgram');
var server = dgram.createSocket("udp4");
server.bind(SRC_PORT, function () {
setInterval(multicastNew, 4000);
});
function multicastNew() {
var message = new Buffer("Multicast message!");
server.send(message, 0, message.length, PORT , MULTICAST_ADDR, function () {
console.log("Sent '" + message + "'");
});
}
客户
var PORT = 6024;
var MULTICAST_ADDR = '239.255.255.250';
var dgram = require('dgram');
var client = dgram.createSocket('udp4');
client.on('listening', function () {
client.setBroadcast(true);
var address = client.address();
console.log('UDP Client listening on ' + address.address + ":" + address.port);
});
client.on('message', function (message, rinfo) {
console.log('Message from: ' + rinfo.address + ':' + rinfo.port + ' - ' + message);
});
client.bind(PORT, function () {
client.addMembership(MULTICAST_ADDR);
});
当我启动服务器和客户端时,一切正常。来自 server.js 的消息成功发送到 client.js。
问题
当我想要多个客户端(节点)时会出现问题。将来我想向所有客户端(节点)提出请求,我犯了什么错误,不允许使用多播从所有客户端发送一些信息。
使用上面的代码,我无法同时打开 2 个客户端来接收来自服务器的消息。
这是尝试连接超过 1 个客户端时的错误:
events.js:85
throw er; // Unhandled 'error' event
^
Error: bind EADDRINUSE
at exports._errnoException (util.js:746:11)
at dgram.js:224:28
at dns.js:85:18
at process._tickCallback (node.js:355:11)
at Function.Module.runMain (module.js:503:11)
at startup (node.js:129:16)
at node.js:814:3
我知道问题是我两次使用相同的代码(client.js),具有相同的端口和其他参数。为了在更多客户端上使用多播发送(通过 server.js)和接收成功消息,我犯了什么错误?