springboot整合使用rocketMq

前文,我们讲述了rocketMq的基本使用,接下来聊聊如何使用springboot整合使用rocketMq;

1)新建maven工程,工程结构目录如图:

constants包下存放着常量信息,这里保存的是自定义的错误码,为将被异常类调用,

consumer包下存放的是消费者相关的配置,一个文件是消费者的配置,用于APP启动的时候全局注册,一个文件为消费者端的监听器,用于监听生产者发送过来的消息;

producer包放的是生产者相关的初始化配置信息;

test包下是用于测试的文件;

2)pom依赖的jar包,

<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.1.RELEASE</version>
		<relativePath /> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</pro
经验分享 程序员 微信小程序 职场和发展