2

我一直在尝试在本地计算机和远程服务器之间使用 zeromq 建立一个简单的“管道”。我在本地计算机上测试了脚本，它运行良好，但是当我尝试使用远程计算机作为终端（带有 SOCKET_PULL 的计算机）时，我开始遇到问题。任何进程发送的第一条消息总是丢失。

代码很简单，

推送（sender.php）：

<?php
//Use the specified port or 5555 for sending jobs
$port = $_SERVER['argc'] > 1 ? $_SERVER['argv'][1] : '5555';
$jobN = $_SERVER['argc'] > 2 ? $_SERVER['argv'][2] : '';


$context = new ZMQContext();

//  Socket to send messages on
$sender = new ZMQSocket($context, ZMQ::SOCKET_PUSH);

//If I want to connect to the server I use this line
$sender->connect("tcp://my-server-address.com:$port");

//If I want to connect to localhost I use this line
//$sender->connect("tcp://localhost:$port");

$sender->send('job-1' . ($jobN ? " $jobN" : ''));
$sender->send('job-2' . ($jobN ? " $jobN" : ''));
$sender->send('job-3' . ($jobN ? " $jobN" : ''));
$sender->send('job-4' . ($jobN ? " $jobN" : ''));
$sender->send('job-5' . ($jobN ? " $jobN" : ''));
$sender->send('job-6' . ($jobN ? " $jobN" : ''));
$sender->send('job-7' . ($jobN ? " $jobN" : ''));
$sender->send('job-8' . ($jobN ? " $jobN" : ''));
$sender->send('job-9' . ($jobN ? " $jobN" : ''));
$sender->send('job-10' . ($jobN ? " $jobN" : ''));
echo 'done';

接收器（worker.php）

<?php
//Use the specified port or 5556 for getting finished jobs
$port = $_SERVER['argc'] > 1 ? $_SERVER['argv'][1] : '5555';

//  Prepare our context and socket
$context = new ZMQContext();
$receiver = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$receiver->bind("tcp://*:$port");

$count = 1;
while(true) {
    $string = $receiver->recv();
    echo "Received $string $count\n";
    $count += 1;
}

如果我在本地运行代码（一个终端中的“php worker.php”和另一个终端中的“php sender.php”）。

我明白了

Received job-1 1
Received job-2 2
Received job-3 3
Received job-4 4
Received job-5 5
Received job-6 6
Received job-7 7
Received job-8 8
Received job-9 9
Received job-10 10

但是如果我使用遥控器（本地 mu 中的发送者和遥控器中的接收者），我会得到

Received job-2 1
Received job-3 2
Received job-4 3
Received job-5 4
Received job-6 5
Received job-7 6
Received job-8 7
Received job-9 8
Received job-10 9

难道我做错了什么？？

注意：我不能锁定发送者（并且 SOCKET_REQ 锁定执行等待回复）。无论如何，0mq 应该在没有锁的情况下工作。注意：我的本地是一台 mac 计算机，服务器是一个带有 ubuntu 的亚马逊实例（我认为这不会影响，但我正在写它以防万一）。

编辑：澄清一下，我不想通过互联网发送数据，我只是想在遇到这个问题时以高延迟测试 zeromq。

4

2 回答 2

7

问题是 Pieter 的文档所称的“慢加入者”。这是错误的名称，因为它暗示订阅者/听众是问题的根源。不是这种情况。

问题很可能出在出版商方面。您在发布者连接之前发送消息。

怎么会这样？zmq_connect 或 zmq_bind 返回，因此您必须做好准备。 不，你不是。

显然，当连接/绑定返回时，连接/发布设置未完成。函数返回后一段时间，连接完成。

那么你如何解决这个问题呢？简单的方法是等待。这样做的问题是您不知道要等待多长时间，而实际时间取决于特定的网络情况和所涉及的硬件。

一种更好但更复杂的方法是为您的发布者地址设置一个本地订阅者，并重复发布一条管理消息，一旦收到该消息，您就会知道您已准备就绪。

于 2013-03-02T14:41:02.847 回答
4

解决了这个问题，我在本地和服务器上安装了不同版本的 zeromq。如果您遇到相同的错误，请检查版本。

注意：Zeromq 确实适用于互联网。唯一的事情（至少在 php 中）是您需要确保在关闭进程之前完全发送了消息。在我的测试中，我在不同的计算机之间发送了数次 75000 条随机大小（平均大小：1MB）的消息，并且我得到了预期的所有消息。

于 2012-07-25T16:59:41.897 回答