javascript node.js v0.4.x和v0.6.x之间广播和多播兼容性的简单测试用例

Posted 2021-05-04

var dgram = require('dgram');
var socket = dgram.createSocket('udp4');

var testMessage = "[hello world] pid: " + process.pid;
var multicastAddress = '239.1.2.3'
var multicastPort = 5554

socket.addMembership(multicastAddress);
socket.bind(multicastPort, '0.0.0.0');

socket.on("message", function ( data, rinfo ) {
	console.log("Message received from ", rinfo.address, " : ", data.toString());
});

setInterval(function () {
	socket.send(new Buffer(testMessage), 
			0, 
			testMessage.length, 
			multicastPort, 
			multicastAddress, 
			function (err) {
				if (err) console.log(err);
				
				console.log("Message sent");
			}
	);
}, 1000);

var dgram = require('dgram');
var socket = dgram.createSocket('udp4');

var testMessage = "[hello world] pid: " + process.pid;
var broadcastAddress = '255.255.255.255';
var broadcastPort = 5555;

socket.setBroadcast(true);
socket.bind(broadcastPort, '0.0.0.0');

socket.on("message", function ( data, rinfo ) {
	console.log("Message received from ", rinfo.address, " : ", data.toString());
});

setInterval(function () {
	socket.send(new Buffer(testMessage), 
			0, 
			testMessage.length, 
			broadcastPort, 
			broadcastAddress, 
			function (err) {
				if (err) console.log(err);
				
				console.log("Message sent");
			}
	);
}, 1000);