Руководство по ZMQ

zmq_msg_recv(&message, responder, 0);
printf("Получено сообщение Hello\n");

char *reply = "World";
zmq_msg_send(&message, responder, 0);
zmq_msg_close(&message);

zmq_msg_init_size(&message, strlen(reply));
memcpy(zmq_msg_data(&message), reply, strlen(reply));
zmq_msg_send(&message, responder, 0);
zmq_msg_close(&message);
}

zmq_close(responder);
zmq_ctx_destroy(context);
return 0;
}

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

int main() {
    void *context = zmq_ctx_new();
    void *requester = zmq_socket(context, ZMQ_REQ);
    int rc = zmq_connect(requester, "tcp://localhost:5555");
    if (rc != 0) {
        fprintf(stderr, "Не удалось подключиться к сокету\n");
        return -1;
    }

    for (int request_nbr = 0; request_nbr != 10; request_nbr++) {
        zmq_msg_t message;
        zmq_msg_init_size(&message, 5);
        memcpy(zmq_msg_data(&message), "Hello", 5);
        zmq_msg_send(&message, requester, 0);
        zmq_msg_close(&message);

        zmq_msg_init(&message);
        zmq_msg_recv(&message, requester, 0);
        printf("Получено World %d\n", request_nbr);
        zmq_msg_close(&message);
    }

    zmq_close(requester);
    zmq_ctx_destroy(context);
    return 0;
}