更新

严智鑫

2024-03-06 f7ecb62a4fcfc86893458f1298995692315ff79f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package com.mes.service; 
 
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; 
        receiver = new RabbitMQUtils(); // 实例化 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 方法发送消息 
        receiver.sendMessageWithId("hangzhou2", "Hello RabbitMQ!", "1"); 
        receiver.sendMessageWithId("hangzhou2", "Another message", "2"); 
        receiver.sendMessageWithId("hangzhou2", "Yet another message", "1"); // 这条消息会打印重复消息的错误信息 
 
    } 
}