ZeroMQ + ReactPHP：多个生产者（推）和多个消费者（拉）

Question

我正在使用 reactphp/zmq。

我怎样才能在多个拉式工作器中有多个推式工作器，这可能吗？

A only 可以有 multi pull 和 single push，如 README 的例子：

$push->connect()
$pull->bind()

或者单拉多推：

$push->bind()
$pull->connect()

当我尝试将两者都设置为 connect 时，拉动没有收到消息。

否则，尝试使用 bind 启动多个进程会抛出：

ZMQSocketException: Failed to bind the ZMQ: Address in use

我应该有一个中间件吗？

(5555)                      (5556)
push -|  (5555) > (5556)   |- pull
push -|-> pull  &  push <- |- pull
push -|   bind  /  bind    |- pull
connect                    connect

Answer 1

(5555)                      (5556)
push -|  (5555) > (5556)   |- pull
push -|-> pull  &  push <- |- pull
push -|   bind  /  bind    |- pull
connect                    connect

这和ZMQPoll的思路很像。不好你不需要使用 reactphp/zmq

您可以运行使用 ZMQPoll 进行处理。本进程可以绑定在5555和5556上，其他进程可以推送和拉取消息。

my example how it can be work

more examples on official ZMQ site

PHP example poller from official site

UPD: 如果您需要其他解决方案，look at ZMQProxy