ｒａｂｂｉｔｍｑ绑定多个队列写法

在 RabbitMQ 中，我们可以通过将多个队列绑定到同一个交换机上来实现一些特定的功能，比如消息广播或者消息负载均衡等。

在代码实现上，我们可以使用 RabbitMQ 的 Java 客户端库来创建多个队列并将其绑定到同一个交换机上。以下是一个简单的示例代码：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class MultipleQueuesBindingExample {

    private static final String EXCHANGE_NAME = "my_exchange";
    private static final String QUEUE_NAME_1 = "my_queue_1";
    private static final String QUEUE_NAME_2 = "my_queue_2";

    public static void main(String[] args) throws IOException, TimeoutException {

        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("guest");
        factory.setPassword("guest");

        // 创建连接
        Connection connection = factory.newConnection();

        // 创建通道
        Channel channel = connection.createChannel();

        // 声明交换机
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");

        // 声明队列1
        channel.queueDeclare(QUEUE_NAME_1, false, false, false, null);

        // 声明队列2
        channel.queueDeclare(QUEUE_NAME_2, false, false, false, null);

        // 绑定队列1到交换机
        channel.queueBind(QUEUE_NAME_1, EXCHANGE_NAME, "");

        // 绑定队列2到交换机
        channel.queueBind(QUEUE_NAME_2, EXCHANGE_NAME, "");

        // 关闭连接和通道
        channel.close();
        connection.close();
    }
}

以上代码中，我们首先创建了一个名为 `my_exchange` 的 fanout 类型的交换机，然后分别创建了两个队列 `my_queue_1` 和 `my_queue_2`，最后将这两个队列都绑定到了 `my_exchange` 交换机上。

需要注意的是，在绑定队列到交换机的时候，我们传递了一个空字符串 `""` 作为 routing key。这是因为在 fanout 类型的交换机中，消息会被广播到所有绑定的队列中，而不需要指定具体的 routing key。

当需要向这两个队列发送消息时，只需要向 `my_exchange` 交换机发送消息即可，消息会自动被广播到所有绑定的队列中。