zeromq - 总是丢失第一条消息

Question

我一直在尝试在本地计算机和远程服务器之间使用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.

Answer 1

问题是Pieter的文档称之为"慢速木匠".这是错误名称,因为它暗示订阅者/侦听者是问题的根源.不是这种情况.

问题最有可能发生在发行商方面.您在发布者连接之前发送消息.

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

显然,当connect/bind返回时,连接/发布设置不完整.函数返回后,连接完成一段时间.

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

一种更好的方式,但更多地参与,是建立一个本地用户为你的发布者地址,反复发布,曾经收到让你知道你是,准备一个管理消息.