zmq pull push模式 不定条数据发收

在 ZeroMQ 中，使用 Pull-Push 模式时，可以通过以下步骤发送不定条数据：

1. 创建 Push Socket，并使用 `bind()` 方法绑定到指定的地址和端口号。
2. 创建 Pull Socket，并使用 `connect()` 方法连接到 Push Socket 绑定的地址和端口号。
3. 在 Push Socket 上使用 `send_multipart()` 方法发送多个部分的消息。
4. 在 Pull Socket 上使用 `recv_multipart()` 方法接收多个部分的消息。

以下是一个简单的 Python 代码示例，演示了如何使用 ZeroMQ 的 Pull-Push 模式发送和接收不定条数据：

import zmq

context = zmq.Context()

# 创建 Push Socket，并绑定到指定的地址和端口号
push_socket = context.socket(zmq.PUSH)
push_socket.bind("tcp://*:5555")

# 创建 Pull Socket，并连接到 Push Socket 绑定的地址和端口号
pull_socket = context.socket(zmq.PULL)
pull_socket.connect("tcp://localhost:5555")

# 发送不定条消息
messages = ["Message 1", "Message 2", "Message 3"]
for message in messages:
    message_parts = [message.encode('utf-8')]
    push_socket.send_multipart(message_parts)

# 接收不定条消息
while True:
    message_parts = pull_socket.recv_multipart()
    message = message_parts[0].decode('utf-8')
    print("Received message: {}".format(message))
    if message == "Message 3":
        break

在此示例中，我们使用 Push Socket 发送了 3 条消息，并使用 Pull Socket 接收了相同数量的消息。使用 `send_multipart()` 方法可以发送多个部分的消息，而使用 `recv_multipart()` 方法则可以接收多个部分的消息。在此示例中，我们使用一个简单的循环来发送和接收消息，直到接收到了最后一条消息。