问 ZeroMQ:即使在设置HWM和bufsize之后也会丢失数据包

EN

我们在ZeroMQ中使用的是一种ZeroMQ可扩展的正式通信模式。发送者应用程序共发送30,000条消息，每个10 of。有很多数据丢失，因此我们在发送方设置了以下内容：

zmq_socket = context.socket(zmq.PUSH)
zmq_socket.setsockopt(zmq.SNDBUF, 10240)
zmq_socket.setsockopt(zmq.SNDHWM, 1)
zmq_socket.bind("tcp://127.0.0.1:4999")

在接收方：

zmq_socket = context.socket(zmq.PULL)
zmqSocket.setReceiveBufferSize(10240);
zmqSocket.setRcvHWM(1);
zmq_socket.connect("tcp://127.0.0.1:4999")

仍然有数据丢失。不知道如何才能避免数据包被悄悄丢弃。

编辑1：

Python的 发件人 代码：

context = zmq.Context()
zmq_socket = context.socket(zmq.PUSH)
zmq_socket.setsockopt(zmq.SNDBUF, 10240)
zmq_socket.setsockopt(zmq.SNDHWM, 1)
zmq_socket.bind("tcp://127.0.0.1:4999")
for file_name in list_of_files:              # Reads data from a list of files:
    while True:                              #       data from a file_name
          with open(os.path.join(self.local_base_dir,file_name), 'r') as sf:
               socket_data = sf.read(5120)
               if socket_data == '':
                  sf.close()
                  break                      #       until EoF
               ret = zmq_socket.send(socket_data)
               if ret == 0:
                  return True
               if ret == -1:
                  print zmq_errno()

接收机 代码

    private ZMQ.Socket zmqSocket = zmqContext.socket(ZMQ.PULL);