如何使用 setInterval 从 zmq 套接字发布随机消息?
How to publish randomized messages from zmq socket using setInterval?
下面的代码是为了模拟zmq socket发送硬编码写的myData
。
如何让 setInterval 函数随机发送 myData
和 myData2
?这将帮助我模拟来自多个来源的消息(例如:services
、IOT devices
)由同一个套接字实例
发布
var zmq = require('zmq');
var socket = zmq.socket('pub');
//simulated message
var myData = {
"vmId" : "abc",
"vmName" : "myVm"
}
var myData2 = {
"vmId" : "xyz",
"vmName" : "myVm_2"
}
socket.bindSync('tcp://localhost:3000');
setInterval(function(){
socket.send(['notify_message', JSON.stringify(myData)]);
}, 1000);
使用Math.random()
:
setInterval(function() {
socket.send(['notify_message',
JSON.stringify(Math.random() < 0.5 ? myData : myData2)]);
}, 1000);
下面的代码是为了模拟zmq socket发送硬编码写的myData
。
如何让 setInterval 函数随机发送 myData
和 myData2
?这将帮助我模拟来自多个来源的消息(例如:services
、IOT devices
)由同一个套接字实例
var zmq = require('zmq');
var socket = zmq.socket('pub');
//simulated message
var myData = {
"vmId" : "abc",
"vmName" : "myVm"
}
var myData2 = {
"vmId" : "xyz",
"vmName" : "myVm_2"
}
socket.bindSync('tcp://localhost:3000');
setInterval(function(){
socket.send(['notify_message', JSON.stringify(myData)]);
}, 1000);
使用Math.random()
:
setInterval(function() {
socket.send(['notify_message',
JSON.stringify(Math.random() < 0.5 ? myData : myData2)]);
}, 1000);