RabbitMQ 基本使用（注解的方式）

1
2
3

1. 发送者代码：

1
2
3
4
5
6
7
 @Autowired
private AmqpTemplate amqpTemplate;
public void send(){
String msg = "mqsender send ..." + new Date();
amqpTemplate.convertAndSend("myQueue", msg);
}

1
2
3

2. 接收者代码

1
2
3
4
5
6
7
8
9

/**
* 需要手动在39...50:15672/ 下的RabbitMQ management 界面下创建一个队列 myQueue
* @param msg
*/
@RabbitListener(queues = "myQueue")
public void receive(String msg){
log.info("mqReceive = {}" , msg );
}

1
2
3
4

1. 发送方程序和上面一样
2. 接收方程序如下：

1
2
3
4
5
6
7
8
9

/**
*
* @param msg
*/
@RabbitListener(queuesToDeclare = @Queue("myQueue"))
public void receive(String msg){
log.info("mqReceive = {}" , msg );
}

1
2
3
4

1. 发送方程序不变
2. 接收方程序如下：

1
2
3
4
5
6
7
8
9

// 3. 自动创建，queue 和 exchange 绑定
@RabbitListener(bindings = @QueueBinding(
value = @Queue("myQueue"),
exchange = @Exchange("myExchange")
))
public void receive(String msg){
log.info("mqReceive = {}" , msg );
}

1
2
3

1. 发送方：

1
2
3
4
5
6
7
8
9
10

/**
* 模拟消息分组 发送方
*/
public void sendOrder(){
String msg = "mqsender send ..." + new Date();
// 参数：交换机，路由key, 消息
amqpTemplate.convertAndSend("myOrder","computer", msg);
}

1
2
3

2. 接收方：

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
26
/**----------- 模拟消息分组 --------------------*/
/**
* 数码供应商服务
接收消息
* 消息发到交换机，交换机根据不同的key 发送到不同的队列
*/
@RabbitListener(bindings = @QueueBinding(
exchange = @Exchange("myOrder"),
key = "computer",
value = @Queue("computerOrder")
))
public void receiveComputer(String msg){
log.info(" receiveComputer service = {}" , msg );
}
/**
* 水果供应商服务
接收消息
*/
@RabbitListener(bindings = @QueueBinding(
value = @Queue("fruitOrder"),
key = "fruit",
exchange = @Exchange("myOrder")
))
public void receiveFruit(String msg){
log.info(" receiveFruit service = {}" , msg );
}

1
2
3

3. 测试用例

1
2
3
4
5
6
7

@Autowired
private MQSender sender;
@Test
public void sendOrderTest() {
sender.sendOrder();
}

1
2
3
4
5

4. 结果：
消息发送到交换机，交换机通过路由key 发送到对应的队列。
因此computerOrder队列得到了消息，进而receiveComputer()接收到了消息。