5.rabbitMq+springboot(gold_axe)
2020-11-22 本文已影响0人
胖达_4b7e
发送都用RabbitTemplate
![](https://img.haomeiwen.com/i4930604/bd0a5a3b959c0adc.png)
第一个参数如果没有, 就是发到routingKey的同名队列, 就是发到默认路由器
最简单队列 direct
只声明队列, 不写绑定:
![](https://img.haomeiwen.com/i4930604/02c1f72238241412.png)
发:
![](https://img.haomeiwen.com/i4930604/373dce87ae9c9644.png)
收
![](https://img.haomeiwen.com/i4930604/d6ef7a31750bdd01.png)
消费者确认(手动应答): 消费者回复收到或者没收到
单独的队列配置
队列的声明和消费发送都和上面一样
要加这么一个配置:这个队列开启消费者确认, 消费者是userReceiver里面会确认
![](https://img.haomeiwen.com/i4930604/9a8295d61fcd404d.png)
消费者:
![](https://img.haomeiwen.com/i4930604/cd74b7e3812f8cbe.png)
这里,失败重新入队, 如果就这么一个消费者在消费这个队列的信息, 下次再失败再失败 会死循环
如果不重新入队, 会投到死信交换器(如果有的话)
Message参数里面 信息很全:
![](https://img.haomeiwen.com/i4930604/bd97ab499bb4fbca.png)
![](https://img.haomeiwen.com/i4930604/25b00d8ccb57fae6.png)
Fanout 交换器
-
声明队列
2.声明Fanout 交换器
3.绑定2者(没有用路由键)
发送:
![](https://img.haomeiwen.com/i4930604/76a057036ea5d30c.png)
接受就和上面一样
topic 交换器
注意点是, 队列到 topic交换器的绑定的 路由键
![](https://img.haomeiwen.com/i4930604/8f9d931d1fe59ea2.png)
发送方确认
全局配置:
![](https://img.haomeiwen.com/i4930604/404c7719dd5c80f1.png)
![](https://img.haomeiwen.com/i4930604/4c8dec852b97133a.png)
![](https://img.haomeiwen.com/i4930604/3a8dc9e26f720168.png)
这样所有的消费者消费, 多会打印
可以看到, 使用方法和原生的是一样的, 都是1要开启2配上回调
失败通知
全局配置:
![](https://img.haomeiwen.com/i4930604/9ff758884abf560b.png)
开启, 配上回调
建议:
失败通知
发送方确认
消费方手动确认, 都用上