上班之余写的这篇文章，写得不是很好请见谅，由于公司最近在做ESB项目，为了做poc的环境测试，需要用到activemq所以我才会去接触到activemq，说句实在话，我真的没想到在制造业中能用到mq，当我了解到activemq的时候才发现这个mq与其他互联网主流的mq ，rmq kafka 这些mq之间比较它的功能相对比较单一。题外话不多说了。直接上代码。
https://github.com/huangdehui1994/springboot-activemq-topic
下载下来docker-compose up -d 后就可以跑了。
这个项目是根据官方文档去做的，也是基于官方文档的代码去改的，由于大部分的教程只提到了queue模式，并没有主题订阅模式的配置和详细的描述，正好我项目需要的业务场景又是主题模式的，所以这份代码非常适合需要主题模式的小伙伴。希望大家能够喜欢。
关于如何配置订阅模式的问题，该如何发送topic的message到activemq
https://stackoverflow.com/questions/40144561/how-to-listen-to-topic-using-spring-boot-jms
那个回答中有个错的地方，参考一下下面那个回答
image.png
关于如何处理POJO的异常 相关文章
MessageConversionException: Could not map JSON object
问题会在JmsOperations被触发
https://grokonez.com/java-integration/spring-jms-activemq-send-java-object-messages-activemq-server-specially-bi-directional-relationship-java-objects
这在我的代码注释中也会提到。
image.png
以上碰到的这些问题和踩过的这些坑这个项目都解决掉了，你们需要做的事情就是先跑这份docker-compose.yum 然后运行项目就Ok了。
网友评论