开始

image.png

image.png

image.png
加一个重载,收到死信的时候要把死信保存起来。
image.png
消息的类型是Dead
image.png

死信的配置和死信的监听

新增配置类
image.png
把死信交换机,死信队列声明一下。死信的监听也声明一下。
image.png

image.png

队列、交换机和绑定都设置好了。都变成Bean交给Spring容器管理。框架里面的rabbitAdmin起来的时候,它会把这些交换机的设置都设置好。
image.png
类名改一下
image.png

添加死信的监听类

死信的消息不需要业务去监听了。框架监听就可以了。
image.png
image.png

ConditionalOnProperty加上这个注解,因为不是所有的服务都监听死信。有可能好几个微服务使用同一个rabbitMQ,也不需要所有的微服务都监听这个mq上的死信。我们需要一个可以配置的注册的内容。通过这个就设置是不是要监听这个死信。
image.png
如果不是死信的类就不需要监听。

image.png

image.png
重写onMessage方法
image.png

image.png
最后ack单挑确认。

image.png

结束