java 代码一个交换机同时绑定普通队列和延迟队列

下面是一个使用 Java 和 RabbitMQ 客户端库实现同时绑定普通队列和延迟队列的交换机的示例代码：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeoutException;

public class ExchangeWithQueues {

    private static final String EXCHANGE_NAME = "my_exchange";
    private static final String QUEUE_NAME = "my_queue";
    private static final String DELAYED_QUEUE_NAME = "my_delayed_queue";
    private static final String DELAYED_EXCHANGE_NAME = "my_delayed_exchange";

    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");

        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        // Declare the exchange
        channel.exchangeDeclare(EXCHANGE_NAME, "direct");

        // Declare the normal queue
        channel.queueDeclare(QUEUE_NAME, true, false, false, null);

        // Bind the normal queue to the exchange
        channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "my_routing_key");

        // Declare the delayed queue with arguments for the delay time
        Map<String, Object> arguments = new HashMap<>();
        arguments.put("x-delayed-type", "direct");
        channel.queueDeclare(DELAYED_QUEUE_NAME, true, false, false, arguments);

        // Declare the delayed exchange with the delayed plugin
        channel.exchangeDeclare(DELAYED_EXCHANGE_NAME, "x-delayed-message", true, false, null);

        // Bind the delayed queue to the delayed exchange
        channel.queueBind(DELAYED_QUEUE_NAME, DELAYED_EXCHANGE_NAME, "my_routing_key");

        // Bind the exchange to the delayed exchange with the delayed plugin
        channel.exchangeBind(EXCHANGE_NAME, DELAYED_EXCHANGE_NAME, "my_routing_key");

        channel.close();
        connection.close();
    }
}

这个代码示例演示了如何创建一个名为 "my_exchange" 的直连交换机，并在该交换机上同时绑定一个普通队列 "my_queue" 和一个延迟队列 "my_delayed_queue"。为了创建延迟队列，我们使用了 RabbitMQ 的 x-delayed-message 插件。在此示例中，我们将延迟时间设置为消息发布后 5000 毫秒，但你可以根据需要进行更改。