7

我正在构建一个基础设施（用 C 语言），其中几个单独的服务通过 ZeroMQ 进行通信。现在，为了让这一切运行得又快又顺畅，我希望 ZeroMQ 异步运行。
我知道 ZeroMQ 的 IO 线程已经分开了，但是我想同时执行多个任务。

目前，我的模式如下所示：

Client -> REQ     |  /\
Router -> ROUTER  |   |
---   proxy   --- |   |
Dealer -> DEALER  |   |
Workers-> REP     \/--|

但是，这需要我设计一个阻塞的、同步的 worker。使这种异步的唯一方法是增加工人（线程）的数量，但这对我来说似乎不是很有可扩展性。

此外，worker 执行的任务本身是异步的（使用它们自己的事件循环）。所以基本上，我希望实现这样的目标：

void *socket = zmq_socket(context, ZMQ_REP);
zsocket_connect(socket, "inproc://backend");

while (1) {
    zmq_msg_t request;
    zmq_msg_init(&request);
    zmq_msg_recv(&request, socket, 0);
    zmq_msg_close(&request);

    do_something(callback, socket);
}

do_something然后将执行一些操作，完成后，回调函数被调用。

void callback(void *data, void *socket) {
    zmq_msg_t reply;
    zmq_msg_init_size(&reply, 5);
    memcpy(zmq_msg_data(&reply), "World", 5);
    zmq_msg_send(&reply, socket, 0);
    zmq_msg_close(&reply);
}

现在，有什么方法可以实现这一点（即结合两个事件循环）？

我已经查看了 DEALER (client) -> ROUTER -> DEALER -> DEALER (worker)，但这似乎也不起作用，因为它仍然会阻止工作端的并发任务。

4

1 回答 1

2

（客户端）经销商<->路由器|<->| ROUTER <-> DEALER (worker) 在这种连接模式中，没有任何东西会阻塞，因此您可以根据需要交错接收和发送。

于 2015-09-08T14:23:28.723 回答