java 代码一个交换机同时绑定普通队列和延迟队列不用插件的写法

在 RabbitMQ 中，一个交换机可以同时绑定多个队列。因此，您可以通过以下 Java 代码实现一个交换机同时绑定普通队列和延迟队列的功能，而无需使用插件：

import com.rabbitmq.client.*;

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

public class ExchangeBinding {

    private static final String EXCHANGE_NAME = "delayed_exchange";
    private static final String QUEUE_NAME = "my_queue";
    private static final String DELAYED_QUEUE_NAME = "delayed_queue";
    private static final String DELAYED_EXCHANGE_NAME = "delayed_exchange";
    private static final String ROUTING_KEY = "my_routing_key";
    private static final String DELAYED_ROUTING_KEY = "my_delayed_routing_key";

    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.queueDeclare(QUEUE_NAME, false, false, false, null);

        // 创建延迟队列
        Map<String, Object> arguments = new HashMap<>();
        arguments.put("x-delayed-type", "direct");
        channel.queueDeclare(DELAYED_QUEUE_NAME, false, false, false, arguments);

        // 创建交换机
        Map<String, Object> exchangeArguments = new HashMap<>();
        exchangeArguments.put("x-delayed-type", "direct");
        channel.exchangeDeclare(EXCHANGE_NAME, "x-delayed-message", false, false, exchangeArguments);

        // 将普通队列绑定到交换机上
        channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ROUTING_KEY);

        // 将延迟队列绑定到延迟交换机上
        channel.queueBind(DELAYED_QUEUE_NAME, DELAYED_EXCHANGE_NAME, DELAYED_ROUTING_KEY);

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

在此代码中，我们首先创建了一个普通队列和一个延迟队列。然后，我们创建了一个延迟交换机，并将其类型设置为“x-delayed-message”。接下来，我们将普通队列绑定到交换机上，并将延迟队列绑定到延迟交换机上。最后，我们关闭了通道和连接。

请注意，为了实现延迟队列，我们需要在创建延迟队列时设置x-delayed-type参数为“direct”，并将延迟交换机的类型也设置为“x-delayed-message”。这将确保消息在延迟队列中停留指定的时间后再被发送到普通队列中。