发送都用RabbitTemplate
第一个参数如果没有, 就是发到routingKey的同名队列, 就是发到默认路由器
最简单队列 direct
只声明队列, 不写绑定:
发:
收
消费者确认(手动应答): 消费者回复收到或者没收到
单独的队列配置
队列的声明和消费发送都和上面一样
要加这么一个配置:这个队列开启消费者确认, 消费者是userReceiver里面会确认
消费者:
这里,失败重新入队, 如果就这么一个消费者在消费这个队列的信息, 下次再失败再失败 会死循环
如果不重新入队, 会投到死信交换器(如果有的话)
Message参数里面 信息很全:
Fanout 交换器
-
声明队列
2.声明Fanout 交换器
3.绑定2者(没有用路由键)
发送:
发送特别的地方是路由键空着就行
接受就和上面一样
topic 交换器
注意点是, 队列到 topic交换器的绑定的 路由键
发送方确认
全局配置：
开启发送方确认
配置上回调
这样所有的消费者消费, 多会打印
可以看到, 使用方法和原生的是一样的, 都是1要开启2配上回调
失败通知
全局配置:
开启, 配上回调
建议:
失败通知
发送方确认
消费方手动确认, 都用上
网友评论