GitHub - ghsqt/m1c-rocketmq: m1c-rocketmq 是针对rocketmq结合spring 后续只需要实现Listener，然后配置好properties，而后配置spring-config-rocketmq.xml，rocketmq程序下载请到：t.m1c.cn/3Urm2e

ghsqt / m1c-rocketmq Public

Notifications You must be signed in to change notification settings
Fork 4
Star 4

m1c-rocketmq 是针对rocketmq结合spring 后续只需要实现Listener，然后配置好properties，而后配置spring-config-rocketmq.xml，rocketmq程序下载请到：t.m1c.cn/3Urm2e

t.m1c.cn/3Urm2e

4 stars 4 forks Branches Tags Activity

Star

Notifications

Branches Tags

Name		Name	Last commit message	Last commit date
Latest commit History 3 Commits
src/main		src/main
.gitattributes		.gitattributes
.gitignore		.gitignore
pom.xml		pom.xml
readme		readme

Repository files navigation

该工程是 rocketmq+spring demo工程
1、实例化producer 和 consumer 都在spring-config-rocketmq.xml中
2、本工程是模拟请求然后将请求的业务数据交给producer处理，放入rocketmq中，入口类 RocketAction
3、在实例化consumer时，base Class 就一个 MyConsumer.java 
  根据在spring-config-rocketmq.xml 配置不同的入参 实例化出不同的consumer（其实主要是不同的RocketMqMessageListener），
  根据rocketmq.properties中配置的不同的入参和不同的RocketMqMessageListener的实现类，可以实例化出监听不同topic和不同subExpression的consumer