ZeroMQpub-sub发送最后一条消息给新订阅者

在ZeroMQ pub-sub模式中，新订阅者无法接收到之前已经发布的消息。如果想要新订阅者能够接收到之前已经发布的消息，则需要在发布者端进行特殊处理。

具体来说，需要在发布者端保存最后一条已发布的消息，当新订阅者连接时，再将这条消息发送给它。

以下是一个简单的Python示例代码，实现了此功能：

import zmq

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5555")

last_msg = ""

while True:
    msg = input("Enter a message: ")
    socket.send(bytes(msg, 'utf-8'))
    last_msg = msg  # 保存最后一条消息

    # 获取所有订阅者，将最后一条消息发送给新的订阅者
    subscribers = socket.getsockopt(zmq.SUBSCRIBE)
    new_subscribers = socket.recv_multipart(flags=zmq.NOBLOCK)
    for subscriber in new_subscribers[1:]:
        socket.send_multipart([subscriber, bytes(last_msg, 'utf-8')])

在上述示例代码中，最后一条消息保存在变量last_msg中。当新订阅者连接时，将其添加到订阅者列表中，然后遍历所有订阅者，将最后一条消息单独发送给新的订阅者。此处使用recv_multipart和send_multipart减少网络开销。

当然，以上示例仅限于单个发布者，多个发布者需要更加复杂的处理方式。