删除mq示例

wuyouming666

2024-03-19 4601fbc2c8f20497010a7d938a8a051efb88f004

 springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java

@@ -2,13 +2,23 @@


import com.rabbitmq.client.*;



import java.util.HashMap;

import java.util.Map;



public class ModuleA {

    private final static String QUEUE_NAME = "hangzhoumes";

    private static String QUEUE_NAME = "hangzhou2";



    public ModuleA(String QUEUENAME){

        QUEUE_NAME=QUEUENAME;

    }







   public static void main(String[] argv) throws Exception {

        // 创建连接工厂

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("localhost");

      factory.setHost("10.153.19.150");

     //  factory.setHost("localhost");



        try (Connection connection = factory.newConnection();

             //channel 是通过 connection 创建的一个 AMQP 信道对象

@@ -21,7 +31,10 @@
            //4. `false`：指定是否在不再使用时自动删除队列。在这里设置为`false`，表示当没有消费者或者所有消费者断开连接后，队列不会自动删除。

            //5. `null`：指定其他队列属性的参数。在这里设置为`null`，表示没有其他属性需要设置。

            //执行`channel.queueDeclare()`方法后，如果队列不存在，将会创建一个新的队列，如果队列已经存在，则不做任何操作。

            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            Map<String, Object> args = new HashMap<>();

            args.put("x-max-length", 10000);

            channel.queueDeclare(QUEUE_NAME, true, false, false, args);