PROSAGA码农传奇-zeromq-如何在单个ZMQ发送请求中发送图像（ndarray）和字符串数据

<div class =“post-text”itemprop =“text”>
  
    我猜你在找
    <a href="http://zguide.zeromq.org/php:chapter2#toc11" rel="nofollow noreferrer">
      多部分消息
    </A>
    ，允许您从几个帧组成一个消息。
Python实现
     <code>
 pyzmq
 </code>
     已经为我们提供了一个很好的多部分消息包装器。这是一个例子
    的
      服务器
    </强>
     发送多部分消息：
  
   <pre>
 <code>
 context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5555")

time.sleep(0.2)  # wait for socket to be properly bound

socket.send_multipart([b"first part", b"second part"])

</code>
 </pre>
  
    而且
    的
      客户
    </强>
     收到多部分消息：
  
   <pre>
 <code>
 context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.setsockopt(zmq.SUBSCRIBE, b"")
socket.connect("tcp://localhost:5555")

print(socket.recv_multipart())

</code>
 </pre>
  
    使用多部分消息时请考虑以下事项：
  
  <UL>
    <LI>
      所有消息部分将仅在您发送最终部分后发送。
    </LI>
    <LI>
      接收器将始终接收所有消息部分或根本不接收任何消息部分。
    </LI>
  </UL>
  <HR />
  
    在您的具体示例中，您已经在编写了多部分消息
     <code>
 send_array
 </code>
     通过使用标志功能
     <code>
 zmq.SNDMORE
 </code>
    。我们可以通过添加字符串数据来扩展您的示例
     <code>
 zmq.SNDMORE
 </code>
     旗。这里是
    的
      服务器
    </强>
     侧：
  
   <pre>
 <code>
 def send_array_and_str(socket, img, string, flags=0):
 md = dict(dtype = str(img.dtype), shape=img.shape)

socket.send_string(string, flags | zmq.SNDMORE)
    socket.send_json(md, flags | zmq.SNDMORE)
    return socket.send(img, flags)

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5667")
time.sleep(0.2)

my_ndarray = np.array([1, 2, 3])
my_string = "Hello World"
send_array_and_str(socket, my_ndarray, my_string)

</code>
 </pre>
  
    而且
    的
      客户
    </强>
     接收邮件的代码：
  
   <pre>
 <code>
 def recv_array_and_str(socket, flags=0, copy=True, track=False):
 string = socket.recv_string(flags=flags)
 md = socket.recv_json(flags=flags)
 msg = socket.recv(flags=flags, copy=copy, track=track)

img = np.frombuffer(bytes(memoryview(msg)), dtype=md['dtype'])
    return string, img.reshape(md['shape'])

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.setsockopt(zmq.SUBSCRIBE, b"")
socket.connect("tcp://localhost:5667")

print(recv_array_and_str(socket))

</code>
 </pre>
  
    此代码基于示例
    <a href="https://pyzmq.readthedocs.io/en/latest/serialization.html" rel="nofollow noreferrer">
      使用PyZMQ序列化消息
    </A>
     并适用于Python 3.对于Python 2，请考虑使用
     <code>
 buffer(msg)
 </code>
     代替
     <code>
 bytes(memoryview(msg))
 </code>
    。
  
</DIV>