如何在 python 和 php 中有效地使用 ZMQ 发送单个消息

Question

我目前有一个PHP函数：

function sendLocalSocket($message, $port){
    $context = new ZMQContext();
    $socket = $context->getSocket(ZMQ::SOCKET_PUSH);
    $socket->connect("tcp://127.0.0.1:$port");
    $socket->send($message);
}

还有一个python函数：

def create_local_socket(port, pull=False):
    context = zmq.Context()
    if pull:
        # for receiving socket messages
        socket = context.socket(zmq.PULL)
        socket.bind("tcp://127.0.0.1:%d" % port)
    else:
        # for sending socket messages
        socket = context.socket(zmq.PUSH)
        socket.connect("tcp://127.0.0.1:%d" % port)
    return socket

_{然后发送带有create_local_socket(port).send_json()的消息}

不幸的是，这两个函数中的任何一个在快速连续调用时都会开始严重挂起并减慢我系统的其余部分。

我一直在想办法让套接字为永不终止的 python 脚本保持打开状态，但不幸的是对于 PHP，这是在文件上传后调用的。

问题是这些函数被任意调用——php脚本每次上传使用相同的端口但是python脚本使用不同的端口（虽然有重复使用）。

我知道 php 挂起，因为 python ZMQ 侦听器记录了current time - the time the file was uploaded，这需要越来越长的时间，直到上传的积压消失。我也知道侦听器脚本没有挂起，并且在记录接收文件后需要 0.2 秒。 （但这实际上是一个积压！）

我觉得答案是保持这些联系。

---

编辑 1：

尝试：$context = new ZMQContext(1, true); 没有帮助。

Answer 1

鉴于对任一 code-sn-ps 的每次调用都会生成另一个 Context()-实例，这构成了合理使用资源的反模式。

对 Zen-of-Zero 的温和阅读很快就会说明主要原因，为什么要构建（半）持久的信号/消息传递层，因为资源分配/释放总是很昂贵，而且留下这么多未终止的实例很快就会耗尽所有可用资源。

ZeroMQ 工具远非一次性使用。效率与最小化的资源相关开销齐头并进，因此最好重新设计临时创建从未释放的资源池，而是在这些工具需要已经处于活动状态并准备好为广告服务之前准备好所有需要的工具。临时请求。

需要对产品进行适当的重构。

---

虽然documentation reports 一些持久性辅助了作案手法，但在进入这个方向之前，应该仔细审查其成本/收益，因为 Zen-of-Zero 实际上正在考虑为distributed-system 共享一种相当反模式的任何形式设计实践，加上警告：

注意

请务必记住，不小心使用持久性套接字可能会耗尽机器上可用的文件句柄。

function sendLocalSocket( $message,                 //  IS to be get delivered
                          $port                     // WAS reported to be
                          ){                        //     all the time the same 
    $context = new ZMQContext( 2, true );           // MAY try persistent CTX
    $socket = $context->getSocket( ZMQ::SOCKET_PUSH,
                                  "persistLoggerID" // MAY use persistent SOCK
                                   );
    $socket->connect(    "tcp://127.0.0.1:$port" ); // MAY use less expensive TC
    $socket->send(       $message,
                          ZMQ::MODE_NOBLOCK         // USE non-blocking mode
                          );
    $socket->disconnect( "tcp://127.0.0.1:$port" ); // USE .disconnect()
}

---

最后说明

任何应用程序的质量、稳健性和性能都取决于语言和特定语言的 ZeroMQ 绑定在尊重本机 API 和反映使用本机 DLL 服务的最佳实践方面的能力。任何“抽象”和/或“自动化”步骤，会减少设计人员对范围的控制以及在本机 API 级别上其他应有步骤的顺序可能看起来很舒服，但这些也减少了设计健壮和高性能部署的选项，因为某些原生 API 调整选项主要不需要在用户应用程序级别可用，一旦被特定语言的 ZeroMQ 绑定抽象遮蔽。