当前位置:   article > 正文

C++微服务中使用消息队列中间件RabbitMQ通信案例_rabbitmq c++

rabbitmq c++

使用消息队列进行微服务之间通信,使用RabbitMQ作为消息队列中间件,C++编写代码

1. 发送消息的微服务(sender-service):
```cpp
#include <amqp.h>
#include <amqp_framing.h>

int main() {
    amqp_connection_state_t conn;
    conn = amqp_new_connection();

    amqp_socket_t *socket = amqp_tcp_socket_new(conn);
    amqp_socket_open(socket, "localhost", 5672);

    amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest");
    amqp_channel_open(conn, 1);
    amqp_get_rpc_reply(conn);

    const char *exchange = "my_exchange";
    const char *routingKey = "my_routing_key";
    const char *message = "Hello, receiver!";

    amqp_basic_properties_t props;
    props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
    props.content_type &

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/神奇cpp/article/detail/739090
推荐阅读
相关标签
  

闽ICP备14008679号