| | |
|---|
| | | 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;
|
|---|
| | | import com.mes.common.RabbitMQUtils;
|
|---|
| | |
|
|---|
| | | public class ModuleA {
|
|---|
| | | private static String QUEUE_NAME = "hangzhou2";
|
|---|
| | | private static RabbitMQUtils receiver;
|
|---|
| | |
|
|---|
| | | public ModuleA(String QUEUENAME){
|
|---|
| | | QUEUE_NAME=QUEUENAME;
|
|---|
| | | public ModuleA(String QUEUENAME) {
|
|---|
| | | QUEUE_NAME = QUEUENAME;
|
|---|
| | | // 实例化 RabbitMQUtils 对象
|
|---|
| | | receiver = new RabbitMQUtils();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public static void main(String[] argv) throws Exception {
|
|---|
| | | // ModuleA moduleA = new ModuleA("hangzhou2"); // 实例化 ModuleA 对象
|
|---|
| | | // String message = "Your message to send666";
|
|---|
| | | // String messageId = "5"; // 消息ID
|
|---|
| | | // receiver.sendMessageWithId(QUEUE_NAME, message, messageId); // 调用 sendMessageWithId 方法发送消息
|
|---|
| | | RabbitMQUtils.sendMessageWithId("hangzhou2", "Hello RabbitMQ!", "1");
|
|---|
| | | RabbitMQUtils.sendMessageWithId("hangzhou2", "Another message", "2");
|
|---|
| | | RabbitMQUtils.sendMessageWithId("hangzhou2", "Another message", "3");
|
|---|
| | | RabbitMQUtils.sendMessageWithId("hangzhou2", "Another message", "4");
|
|---|
| | | RabbitMQUtils.sendMessageWithId("hangzhou2", "Another message", "5");
|
|---|
| | | // receiver.sendMessageWithId("hangzhou2", "Yet another message", "1"); // 这条消息会打印重复消息的错误信息
|
|---|
| | |
|
|---|
| | | 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 + "'");
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
