项目作者: zntzhang

项目描述 :
springboot集成rocketMq的starter工具包
高级语言: Java
项目地址: git://github.com/zntzhang/rocketmq-spring-boot-starter.git
创建时间: 2020-07-22T01:39:34Z
项目社区:https://github.com/zntzhang/rocketmq-spring-boot-starter

开源协议:

下载


springboot集成rocketMq的starter工具包

准备工作

下载starter工程好后,mvn clean install 一下

使用步骤

在你需要集成rocketMq的工程

1. pom文件中,引用上面starter的jar包

  1. ```
  2. <dependency>
  3. <groupId>com.springboot</groupId>
  4. <artifactId>rocketmq-spring-boot-starter</artifactId>
  5. <version>0.0.1-SNAPSHOT</version>
  6. </dependency>
  7. ```

2. application.yml中添加一下相关配置

  1. ```
  2. # 消息队列
  3. rocketmq:
  4. #消费者的组
  5. consumerGroup: pushConsumer
  6. #生产者的组
  7. producerGroup: default
  8. #Nameserver的地址,这里配置你MQ安装的机器上的IP就好,我这里在本机安装的
  9. namesrvAddr: 127.0.0.1:9876
  10. #topic
  11. topic: test
  12. ```

3. 发送端和消费端的处理

  • 消费端需要自定义一个consumerHandler继承AbstractMessageListenerHandler,重写doConsumeMessage方法消费消息。

  • 生产者注入MyMqProducer,调用send方法即可

4. 启动方法添加@EnableRocketMq注解,扫描starter的config