我正在学习 ZeroMQ,刚刚完成了教程和一些示例。我使用 Node.js 作为我的主要环境(最终用 Python 来取代我的工作人员)。
尝试弄清楚如何创建一个完全异步的消息传递系统,该系统将允许我的 API 将任务(通过 REQ
套接字)推送到路由器,有一个经销商将消息传递给工作人员,处理消息并将其结果发送回我的客户(这是一个 Express 路线)。
我相信这个模式会像这样工作(尚未测试或正确实现代码,所以请将其作为概念大纲):
路由器.js
const zmq = require('zmq');;
const frontend = zmq.socket('router');
const backend = zmq.socket('dealer');
frontend.on('message', function() {
var args = Array.apply(null, arguments);
backend.send(args);
});
backend.on('message', function() {
var args = Array.apply(null, arguments);
frontend.send(args);
});
frontend.bindSync('tcp://*:5559');
backend.bindSync('tcp://*:5560');
客户端.js
var zmq = require('zmq'),
var express = require('express');
var app = express();
app.post('send', function(req, res) {
var client = zmq.socket('req');
// listen for responses from the server
client.on('message', function(data) {
console.log(data);
client.close();
});
// connect to the server port
client.connect('tcp://0.0.0.0:5454');
client.send('Request from ' + process.id);
});
app.listen('80');
worker.js
var zmq = require('zmq');
var server = zmq.socket('rep');
server.on('message', function(d){
server.send('Response from ' + process.id);
});
// bind to port 5454
server.bind('tcp://0.0.0.0:5454', function(err){
if (err){
console.error("something bad happened");
console.error( err.msg );
console.error( err.stack );
process.exit(0);
}
});
我不完全理解的是ROUTER/DEALER
是否会处理将响应工作程序发送到正确的客户端。此外,在这种情况下,经销商会处理公平排队,因为我希望我的工作在 worker 之间均匀分配。
我的客户端可以分布在许多不同的盒子(负载均衡器 API 服务器)中,我的路由器将位于其自己的服务器上,并且工作人员也将分布在多个盒子中。
最佳答案
在任何生产级应用中忘记REQ/REP
,可能会陷入相互死锁
您可能会在 REQ/REP
正式可扩展通信模式中有关高风险相互 FSM-FSM 死锁的许多其他帖子中找到此主题。
请确保,XREQ/XREP == DEALER/ROUTER
(自 2011 年以来)
源代码消除了这背后的所有隐藏魔法,XREQ == DEALER
和 XREP == ROUTER
+++b/include/zmq.h
...
-#define ZMQ_XREQ 5
-#define ZMQ_XREP 6
+#define ZMQ_DEALER 5
+#define ZMQ_ROUTER 6
...
+#define ZMQ_XREQ ZMQ_DEALER /* Old alias, remove in 3.x */
+#define ZMQ_XREP ZMQ_ROUTER /* Old alias, remove in 3.x */
关于zeromq - REQ/REP & DEALER/ROUTER 用于双向异步工作处理,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44535162/