ZeroMQ与子进程的双向异步通信

2 回答

• 1

  使用单独的套接字进行信令和消息传递总是更好

  虽然 Poller -instance会有所帮助，但主要步骤是使用单独的套接字进行信令，而另一个套接字用于数据流 . 总是 . 关键是，在这种设置中， Poller.poll() 和事件循环都可以保持特定于套接字，并且在实时受控代码执行期间花费的时间不超过预定义的时间 .

  因此，不要犹豫，设置一个更丰富的信令/消息传递基础设施作为一个环境，你只会享受增加的控制简单性，关注点分离和意图清晰度 .

  ZeroMQ是一个很好的工具 - 包括每插槽IO线程亲和性，所以确实可以在您的指尖轻松实现细粒度性能调整 .

  回复于 2024-04-27T02:36:01+08:00
• 0

  我认为如果想出一个解决方案，但我不知道是否有更好的（更高效，更安全......）方式 . client 向 server 发出请求，该请求产生 N 进程 worker 以参加请求 .

  这是 worker.py 的相关摘录：

  for i in range(start_counter,10):
      # Check if there is any message from server
      while True:
          try:
              msg = worker.recv(zmq.DONTWAIT)
              print("Received {} from server".format(msg))
          except zmq.Again:
              break
  
      # Send data to server
      worker.send(b"Message {} from {}".format(i, worker_id))
  
      # Take some sleep
      time.sleep(random.uniform(0.3, 1.1))
  

  通过这种方式， worker a）不需要单独的套接字，并且b）不需要单独的线程来处理来自 server 的消息 .

  在实际实现中， worker 必须将100字节的128字节消息流式传输到 server ， server 必须接收大量此消息（许多客户端询问每个需要3-10 worker 的请求） . 如果以这种方式实施，这种方法会遭受性能损失吗？

  回复于 2024-04-27T02:36:01+08:00