赞
踩
使用消息队列进行微服务之间通信,使用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 &
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。