阿里云 MNS 切换为自建 RabbitMQ

逃离我推掉我的手 2023-07-06 14:31 5阅读 0赞

介于阿里云的MNS收费超过预算，因此决定切换为自行搭建的RabbitMQ队列，费用能大幅度降低。

由于之前的代码很整齐规范，消息的发送和读取，与业务处理完全分开，因此切换起来毫不费力。

新增了几个公共类，将代码引用改掉，删除阿里云MNS的相关代码，即可完成队列切换。

1、RabbitMQ jar的版本为3.6.6

<dependency>  
    <groupId>com.rabbitmq</groupId>  
    <artifactId>amqp-client</artifactId>  
    <version>3.6.6</version>  
</dependency>

2、类解释

RabbitMqConnUtil.java RabbitMQ连接工具类，包含创建连接的封装，连接池的封装，以及queue、exchange的存在判断封装。

RabbitMqProducer.java  发消息的工具类，实现了实时消息、延迟消息的发送。

RabbitMqCustomer.java 接收实时消息的基类，业务消费者只需要继承该类，并实现相应的业务方法。

RabbitMqCustomerDelay.java 接收延迟消息的基类，业务消费者只需要继承该类，并实现相应的业务方法。

RabbitMqFactory.java  用于项目中，消费者在服务启动后，连接队列监听消息使用。

OrderCustomer.java 接收实时消息的消费者（业务演示代码）。

OrderCustomerDelay.java 接收延迟消息的消费者（业务演示代码）。

3、注意事项

实现延迟消息时，生产者与消费者，在队列的命名规则，遵守统一的约定，否则消费者无法正常接收到延迟消息。

4、参考

延迟消息实现原理 参考  https://blog.csdn.net/u013256816/article/details/55106401

连接池实现 参考 [https://www.cnblogs.com/skyfeng/p/rabbitmq.html][https_www.cnblogs.com_skyfeng_p_rabbitmq.html]

VirtualHost 解读 参考 [https://blog.csdn.net/h996666/article/details/83304626][https_blog.csdn.net_h996666_article_details_83304626]

其他常见问题参考 [https://blog.csdn.net/a1063916463/article/details/90288013][https_blog.csdn.net_a1063916463_article_details_90288013]

5、完整代码，参考附件

[https://download.csdn.net/download/u011453631/12171877][https_download.csdn.net_download_u011453631_12171877]

6、不足

仅仅只是简单的切换，实现了消息的发送、接收，以及延迟消息。

未实现事务性消息，也没有采用广播、主题等方式。

[https_www.cnblogs.com_skyfeng_p_rabbitmq.html]: https://www.cnblogs.com/skyfeng/p/rabbitmq.html
[https_blog.csdn.net_h996666_article_details_83304626]: https://blog.csdn.net/h996666/article/details/83304626
[https_blog.csdn.net_a1063916463_article_details_90288013]: https://blog.csdn.net/a1063916463/article/details/90288013
[https_download.csdn.net_download_u011453631_12171877]: https://download.csdn.net/download/u011453631/12171877