package com.example.springboot.component;

import com.rabbitmq.client.*;

public class ModuleA {
    private final static String QUEUE_NAME = "hangzhoumes";

   public static void main(String[] argv) throws Exception {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("10.153.19.150");

        try (Connection connection = factory.newConnection();
             //channel 是通过 connection 创建的一个 AMQP 信道对象
             Channel channel = connection.createChannel()) {
            // `channel.queueDeclare(QUEUE_NAME, false, false, false, null);` 是用来声明一个队列的方法
            //该方法有五个参数：
            //1. `QUEUE_NAME`：指定队列的名称，这里使用了之前声明的常量`"module_queue"`作为队列名称。
            //2. `false`：指定队列是否为持久化的。在这里设置为`false`，表示不将队列持久化到磁盘，一旦RabbitMQ服务停止或崩溃，队列将会丢失。
            //3. `false`：指定是否只允许当前连接声明此队列。在这里设置为`false`，表示可允许其他连接也声明同名的队列。
            //4. `false`：指定是否在不再使用时自动删除队列。在这里设置为`false`，表示当没有消费者或者所有消费者断开连接后，队列不会自动删除。
            //5. `null`：指定其他队列属性的参数。在这里设置为`null`，表示没有其他属性需要设置。
            //执行`channel.queueDeclare()`方法后，如果队列不存在，将会创建一个新的队列，如果队列已经存在，则不做任何操作。
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);



            String message = "你好模块A2";

            for ( int i=1;i< 10000;i++)
            {
                message+="你好模块A2";

            }

            message+="b";



            //  将消息发布到指定的队列中。空字符串""表示默认的交换机，QUEUE_NAME指定了目标队列名称，null表示没有指定其他属性，message.getBytes()将消息内容转换为字节数组进行传输。
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
        }
    }
}