# springboot-rocketmq

**Repository Path**: kipeng928829/springboot-rocketmq

## Basic Information

- **Project Name**: springboot-rocketmq
- **Description**: No description available
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2018-04-12
- **Last Updated**: 2020-12-20

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# springboot-rocketmq


配置信息

```
# 消费者的组名
apache.rocketmq.consumer.PushConsumer=PushConsumer
# 生产者的组名
apache.rocketmq.producer.producerGroup=Producer
# NameServer地址
apache.rocketmq.namesrvAddr=10.111.27.202:9876
````

初始化：RocketMQManager

需要传入所有实现MessageListener的类，处理消息

rocketmq中MessageListener的主要两个实现

1. MessageListenerConcurrently   A MessageListenerConcurrently object is used to receive asynchronously delivered messages concurrently
2. MessageListenerOrderly A MessageListenerConcurrently object is used to receive asynchronously delivered messages orderly.one queue,one thread


项目中主要做了producer和consumer的封装，只要配置相关的参数即可

如果想在项目中使用不同的topic和tag需要自己创建不同的RocketMQManager bean即可