C中的zeromq pub/sub示例(libzmq)

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <zmq.h>

int main()
{
    // 创建上下文
    void* context = zmq_ctx_new();

    // 创建PUB套接字
    void* publisher = zmq_socket(context, ZMQ_PUB);
    zmq_bind(publisher, "tcp://*:5555");

    // 创建SUB套接字
    void* subscriber = zmq_socket(context, ZMQ_SUB);
    zmq_connect(subscriber, "tcp://localhost:5555");
    zmq_setsockopt(subscriber, ZMQ_SUBSCRIBE, "", 0);

    // 发布消息
    char* message = "Hello, World!";
    zmq_send(publisher, message, strlen(message), 0);

    // 接收消息
    char buffer[256];
    zmq_recv(subscriber, buffer, sizeof(buffer), 0);
    printf("Received message: %s\n", buffer);

    // 清理资源
    zmq_close(publisher);
    zmq_close(subscriber);
    zmq_ctx_destroy(context);

    return 0;
}