Python ZeroMQ PUSH/PULL——丢失消息？

我正在尝试使用python with zeroMQ in PUSH / PULL模式，发送大小的消息4[MB]每隔几秒钟。

由于某种原因，虽然看起来所有消息都已发送，但服务器似乎只收到了其中一些消息。我在这里缺少什么？

这是客户端的代码——client.py

import zmq
import struct

# define a string of size 4[MB] 
msgToSend = struct.pack('i', 45) * 1000 * 1000 

context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.connect("tcp://127.0.0.1:5000")

# print the message size in bytes
print len(msgToSend)

socket.send(msgToSend)

print "Sent message"

这是服务器的代码——server.py

import zmq
import struct

context = zmq.Context()
socket = context.socket(zmq.PULL)
socket.bind("tcp://127.0.0.1:5000")

while True:
    # receive the message
    msg = socket.recv()

    print "Message Size is: {0} [MB]".format( len(msg) / (1000 * 1000) )

我缺少什么？如何保证消息始终发送且不丢失？

如果重要的话，我正在使用Ubuntu 10.0432 位、Core Duo 机器，具有 2[GB] RAM。

NOTE:我试过the same示例使用RabbitMQ一切都运行良好——没有消息丢失。我很困惑，因为我经常听到赞美zeroMQ。为什么失败在哪里RabbitMQ成功？

问题是，当程序退出时，套接字会立即关闭，并以有效 LINGER 为 0 进行垃圾收集（即，它会丢弃所有未发送的消息）。对于较大的消息来说这是一个问题，因为发送它们所需的时间比垃圾收集套接字所需的时间要长。

您可以通过放置一个来避免这种情况sleep(0.1)就在程序退出之前（以延迟套接字和上下文被垃圾收集）。

socket.setsockopt(zmq.LINGER, -1)（这是默认的）应该避免这个问题，但由于某种原因我没有时间调查它并没有。