spring boot中rocketmq自定义使用

说起来这也是个挺悲伤的故事，之前项目中用过ribbitMQ，然后新公司用的rocketMQ，虽然确实两者其实在被spring boot封装以后使用起来大同小异，但是还是遇到了点小问题，所以这里简单整理下。

首先引入jar包

我上面都说了用的是spring boot框架，所以引入的rocketMQ的jar包也是spring的场景启动器：

        <!--mq-->
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.0.4</version>
        </dependency>

RocketMQ的配置

其实这里我遇到了个大坑。因为一开始我不太熟悉这个用法，下意识的就像用万能的模板。也就是RocketMQTemplate。然后就报错了。说没有这个bean。然后开始翻源码。发现了个小秘密：这个看似spring boot整合的rocket其实是自己凑上来的。类似于mybatis。jar包的命名都是rocketmq在前面。当然了这是小问题，继续去翻源码，关于RocketMQTemplate的写法：

自动注入的源码位置

然后这个类其实比较好理解，大概的层级关系如下：

RocketMQTemplate的源码
简单分析一下，这里用了大量的条件注解。

• 首先要有rocketmq的name-server这个配置类才会生效。
• 第一个判断会不会生效的bean是DefaultMQProducer。这个注解的小件也比较简单：首先没有这个bean，其次是配置文件中要有"name-server", "producer.group"这两个属性。
• 第二个bean就是我们想要的RocketMQTemplate。这个类的条件注解也是两个：一个是不存这个bean，第二个很重要，是要存在DefaultMQProducer，也就是我们第一步获得的bean。

后面的就不一一分析了，简单来讲，这里RocketMQTemplate不存在只能是DefaultMQProducer不存在。而这个不存在的唯一原因："name-server", "producer.group"这两个参数有缺。
自我感觉找到问题了，然后屁颠屁颠去看了配置文件。哎呦，真的没有producer.group属性。
就在我抱着发现新大陆的心态想要高喊一声我找到项目的bug的时候，转头一想不太对啊，我们项目中的配置是走的配置中心，别的项目组用rocket.yml都没问题，理论上配置文件不应该有错啊。
于是乎迂回问了我们组长：我们的组名是什么啊？然后组长回答我了以后我又佯装无意的提了下：这个不用写在配置文件里么？
然后组长告诉我：因为我们项目中有多个推送，有不同组别。所以这里组别写在代码里的。
我乖乖点了点头，然后滚去敲代码了。
仔细分析了下，其实把组别写在代码里的意思应该是自己去写这个rocketMQTemplate而不用注入bean。但是真要是不拿现成的，也没必要非执着于rocketMQTemplate了，可以直接用DefaultMQProducer。果然点进原码发现这个类提供了传组别作为参数的构造方法：

传组别名称的构造方法

于是乎代码就很顺利的写出来了：

rocket发送消息代码

RocketMQ消息接收

这个就没啥好说的了，也比较简单。
用默认的DefaultMQPushConsumer就可以。就不多说了。
本篇笔记就到这里，如果稍微帮到你了记得点个喜欢点个关注。也祝大家工作顺顺利利，身体健健康康！其实这个问题挺小的，但是第一次把看源码用在了工作中，觉得比较值得纪念，嘿嘿~