Rabbitmq向只有一个服务发送消息

我们可以通过设置Exchange和Queue的路由键来实现将消息发送给特定的服务。

首先，我们需要创建一个Exchange和一个Queue，并将它们的路由键设置为对应的服务名称。这里以Java代码为例：

// 创建Exchange
channel.exchangeDeclare("my_exchange", BuiltinExchangeType.DIRECT);
// 创建Queue
channel.queueDeclare("my_queue", false, false, false, null);
// 将Queue绑定到Exchange上，并设置路由键
channel.queueBind("my_queue", "my_exchange", "service1");

在发送消息时，我们需要将消息的路由键设置为对应的服务名称，这样消息就会被路由到对应的Queue上。

// 发送消息
byte[] messageBytes = "Hello, Service 1!".getBytes();
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().build();
channel.basicPublish("my_exchange", "service1", props, messageBytes);

这样，我们就可以将消息发送给只有一个服务了。需要发送给其他服务时，只需要将路由键设置为对应的服务名称即可。