怎么用Spring-boot-starter标准改造项目内的RocketMQ客户端组件

这篇文章主要讲解了“怎么用Spring-boot-starter标准改造项目内的RocketMQ客户端组件”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“怎么用Spring-boot-starter标准改造项目内的RocketMQ客户端组件”吧！

成都创新互联公司专注于企业全网整合营销推广、网站重做改版、轵城网站定制设计、自适应品牌网站建设、H5页面制作、商城网站建设、集团公司官网建设、成都外贸网站制作、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为轵城等各大城市提供网站开发制作服务。

一、背景介绍

我们在使用Spring Cloud全家桶构建微服务应用时，经常能看到spring-boot-xxx-starter的依赖，像spring-boot-starter-web、spring-cloud-starter-feign、spring-boot-starter-test、mybatis-spring-boot-starter，仿佛只要带上starter的东西，你就拥有了这个组件的一切，包括所有的配置，引用类都搞定了，这样一个神奇的拿来就用的东西，是怎么实现的呢？我们自己能不能把自己的工具包做成一个starter？

二、Spring Boot Starter组件规范

• 命名规范

groupId：这个标签的命名没做太多要求，基本上使用公司域名+项目名方式，如官方一般使用org.springframework.cloud，第三方一般用自己公司域名，如org.mybatis.spring.boot。 artifactId：这个标签的命名Spring官方给了建议命名方式，Spring官方自己发布的组件，命名方式是spring-boot-starter-xxx，xxx表示组件名称，像上文提及的spring-boot-starter-web和spring-cloud-starter-feign；第三方开发的组件，命名方式是xxx-spring-boot-starter，如mybatis-spring-boot-starter。

• 工程规范

以maven工程为例，Spring Boot Starter用多模块方式建立工程，工程内有autoconfigure模块和starter模块。 autoconfigure模块为自动配置模块，里面包含配置加载，全部的功能代码实现及需要引用的jar包，负责对内功能实现，所有的代码开发都在这个模块中完成。 starter模块提供自动配置模块的依赖，里面没有代码，是个空jar包，只有对autoconfigure模块的所有引用，是一个依赖集，它的目的是简化使用该组件时的依赖，只要添加starter模块，就能使用整个starter组件。

三、案例实战

我们以常用的RocketMQ客户端组件为例，搭建一个自己定义的starter，RocketMQ是由阿里巴巴团队开发并捐赠给apache团队的优秀消息中间件，承受过历年双十一大促的考验。

1. 创建一个Maven工程，增加两个模块rocketmq-spring-boot-autoconfigure和rocketmq-spring-boot-starter，这里使用的RocketMQ版本为4.5.2，主pom.xml节选如下：

com.hy.demo
rocketmq
pom
1.0-SNAPSHOT


	rocketmq-spring-boot-autoconfigure
	rocketmq-spring-boot-starter



	
		org.apache.commons
		commons-lang3
		3.3.2
	
	
		org.apache.rocketmq
		rocketmq-client
		4.5.2
	
	
		org.projectlombok
		lombok
		provided
	
	
		org.springframework
		spring-context
		5.1.8.RELEASE
		compile
	
	
		org.slf4j
		slf4j-api
	

2. autoconfigure模块开发 src目录下添加相应的工具类，如注解，配置类，接口等，略 添加定位配置侯选类，在META-INF/目录下新建spring.factories文件：

org.springframework.boot.autoconfigure.EnableAutoConfiguration=com.hy.demo.rocketmq.MQConfig

Spring Boot会检查你发布的jar中是否存在META-INF/spring.factories文件，自动配置类只能通过这种方式加载

3. starter模块开发 只需要修改pom.xml文件即可：

	rocketmq
	com.hy.demo
	1.0-SNAPSHOT

4.0.0

rocketmq-spring-boot-starter


	
		
			com.hy.demo
			rocketmq
			1.0-SNAPSHOT
			pom
			import
		
	



	
		com.hy.demo
		rocketmq-spring-boot-autoconfigure
		1.0-SNAPSHOT
	

在IDEA上对该工程进行编译，打包，命令：

clean install -DskipTests=true

4、打包部署完成后，在应用模块里添加该starter的依赖即可

   com.hy.demo
   rocketmq-spring-boot-starter
   1.0-SNAPSHOT

注：因为RocketMQ组件较为通用，目前提供基本的几种发送和接收消息的方式，支持事务消息，文章内就不一一解释代码功能，附上此次源码地址：

rocketmq-spring-boot-starter源码示例

四、知识点梳理

1. Spring的几个注解： @Import用来整合所有在@Configuration注解中定义的Bean配置； @EventListener 事件监听，里面写的ContextStartedEvent，表示监听Spring上下文启动完成后的事件； @Configuration相当于xml的beans标签； @Bean标注在方法上，等同于xml的bean；

2. 自定义注解@MQConsumer和注解@MQTransactionProducer是如何起作用的？ 工程里定义了com.hy.demo.rocketmq.config.RocketMQAnnotationScan类对这两个注解进行扫描，利用注解@EventListener(ContextStartedEvent.class)，监听Spring上下文初始化事件，然后从Spring容器内读取所有带这两个注解的类，把RocketMQ相关的配置信息加载进去，由于事务消息生产者类org.apache.rocketmq.client.producer.TransactionMQProducer的特殊性（它需要在初始化时注入TransactionListener监听类，与应用模块有一定耦合性），所以增加了一个Map集合存储应用模块内所有使用了@MQTransactionProducer注解的实例。

感谢各位的阅读，以上就是“怎么用Spring-boot-starter标准改造项目内的RocketMQ客户端组件”的内容了，经过本文的学习后，相信大家对怎么用Spring-boot-starter标准改造项目内的RocketMQ客户端组件这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！