CC++ 远程消息队列的建议

使用C/C++进行远程消息队列的建议

cpp
#include 
#include 
int main() {
    zmq::context_t context(1);
    zmq::socket_t socket(context, zmq::socket_type::req);
    socket.connect("tcp://localhost:5555");
    std::string message = "Hello from C++";
    zmq::message_t request(message.size());
    memcpy(request.data(), message.data(), message.size());
    socket.send(request, zmq::send_flags::none);
    zmq::message_t reply;
    socket.recv(reply, zmq::recv_flags::none);
    std::string replyMessage(static_cast(reply.data()), reply.size());
    std::cout << "Received reply: " << replyMessage << std::endl;
    return 0;
}

cpp
#include 
#include 
int main() {
    amqp_connection_state_t conn = amqp_new_connection();
    amqp_socket_t* socket = amqp_tcp_socket_new(conn);
    amqp_socket_open(socket, "localhost", 5672);
    amqp_channel_open(conn, 1);
    amqp_get_rpc_reply(conn);
    amqp_basic_properties_t props;
    props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
    props.content_type = amqp_cstring_bytes("text/plain");
    props.delivery_mode = 2;
    std::string message = "Hello from C++";
    amqp_bytes_t messageBytes = amqp_cstring_bytes(message.c_str());
    amqp_basic_publish(conn, 1, amqp_cstring_bytes(""), amqp_cstring_bytes("queue_name"), 0, 0, &props, messageBytes);
    amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS);
    amqp_connection_close(conn, AMQP_REPLY_SUCCESS);
    amqp_destroy_connection(conn);
    return 0;
}

cpp
struct Message {
    std::string topic;
    std::string content;
    // 可以添加其他字段
};

cpp
#include 
#include 
#include 
int main() {
    zmq::context_t context(1);
    zmq::socket_t socket(context, zmq::socket_type::req);
    socket.connect("tcp://localhost:5555");
    std::string message = "Hello from C++";
    zmq::message_t request(message.size());
    memcpy(request.data(), message.data(), message.size());
    while (true) {
        // 发送心跳消息
        socket.send(request, zmq::send_flags::none);
        // 等待消息确认
        zmq::message_t reply;
        if (socket.recv(reply, zmq::recv_flags::none)) {
            std::string replyMessage(static_cast(reply.data()), reply.size());
            std::cout << "Received reply: " << replyMessage << std::endl;
            break;
        } else {
            // 处理连接错误或超时
            std::cerr << "Error: failed to receive reply" << std::endl;
        }
    }
    return 0;
}

cpp
#include 
#include 
#include 
int main() {
    zmq::context_t context(1);
    zmq::socket_t socket(context, zmq::socket_type::req);
    socket.connect("tcp://localhost:5555");
    std::vector messages = {"Hello", "from", "C++"};
    std::vector requests;
    for (const auto& message : messages) {
        zmq::message_t request(message.size());
        memcpy(request.data(), message.data(), message.size());
        requests.push_back(std::move(request));
    }
    socket.send(requests, zmq::send_flags::none);
    for (const auto& request : requests) {
        zmq::message_t reply;
        socket.recv(reply, zmq::recv_flags::none);
        std::string replyMessage(static_cast(reply.data()), reply.size());
        std::cout << "Received reply: " << replyMessage << std::endl;
    }
    return 0;
}