package com.mes.service;
|
|
import com.rabbitmq.client.Channel;
|
import com.rabbitmq.client.Connection;
|
import com.rabbitmq.client.ConnectionFactory;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
public class ModuleA {
|
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("10.153.19.150");
|
//factory.setHost("localhost");
|
|
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()`方法后，如果队列不存在，将会创建一个新的队列，如果队列已经存在，则不做任何操作。
|
Map<String, Object> args = new HashMap<>();
|
args.put("x-max-length-bytes",20000);
|
// args.put("x-max-length",5000);
|
channel.queueDeclare(QUEUE_NAME, false, false, false, args);
|
|
String message = "你";
|
|
for ( int i=1;i< 5000;i++)
|
{
|
message+="你";
|
|
}
|
|
message+="b";
|
|
|
|
// 将消息发布到指定的队列中。空字符串""表示默认的交换机，QUEUE_NAME指定了目标队列名称，null表示没有指定其他属性，message.getBytes()将消息内容转换为字节数组进行传输。
|
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
|
System.out.println(" [x] Sent '" + message + "'");
|
}
|
}
|
}
|
|
