1、三方rabbitmq配置类:RealDataRabbitMqConfig

① 关键参数:host、port、username、password、virtualHost、exchange、routingkey和queue

② 关键参数:host、port、username、password、virtualHost、exchange、routingkey和queue

注:设置完ConnectionFactory之后,使用Connection进行连接,测试链接是否有效,若无效,则返回无参数的ConnectionFactory,避免三方rabbitmq无法使用导致人员定位系统服务启动失败

③ 配置RabbitTemplate

注:template设置MessageConverter为 JSON序列化,发送的Object会被JSON序列化,无需在调用template的convertAndSend方法是再次JSON序列化

④ 初始化 Exchange

⑤初始化 Queue

⑥绑定 Queue 和 Exchange

⑦ 初始化 RabbitAdmin

注:可能存在三方rabbitmq无法使用的情况,初始化时需要try-catch,保证服务正常启动

2、发送数据至三方RabbitMq时,使用异步线程池,避免发送失败报错导致主流程中断。

3、设置项目的主rabbitMq配置

注:该bean对象需要设置为Primary,否则会出现rabbitMq配置初始化时找不到主连接,从而导致项目启动失败

注:如果不重新设置自己的RabbitMq配置,会导致RabbitMqUtil中的RabbitTemplate使用成三方mq的RabbitTemplate,造成配置混乱。

此外还需要设置RabbitAdmin的bean对象,否则会出现如下报错

更多推荐