# mq-spring-boot-starter

**Repository Path**: hanlen/mq-spring-boot-starter

## Basic Information

- **Project Name**: mq-spring-boot-starter
- **Description**: 消息队列二次包装(redis queue/rocket queue)。使用起来更简单
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 2
- **Forks**: 0
- **Created**: 2021-10-26
- **Last Updated**: 2021-11-10

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## mq-spring-boot-starter


## 本功能目标
1. 让各种消息服务中间件运用起来更灵活
2. 能按需加载对应的中间件模块
3. 保证消息高可靠性,低开发成本


#### 组件简介

- 1.0 加入了Redis队列功能(适用于不需要重量级中间件的应用)
- RocketMQ功能准备接入中

#### 使用说明

##### 1、Spring Boot 项目添加 Maven 依赖

``` xml
<dependency>
    <groupId>hanlen.mq</groupId>
    <artifactId>mq-spring-boot-starter</artifactId>
    <version>${project.version}</version>
</dependency>
```
2、 Redis队列功能发送案例

``` java
@Autowired
private RedissonService redissonService;

public void send(){
    redissonService.addQueue("testQueue", MsgEntity.builder().name("test").build());
}
```
3、 Redis队列监听案例
``` java
@RedisQueueListener(name = "testQueue")
public void onMessage(MsgEntity msg) {
    log.info("redis listener data:{} ", JsonUtils.toJsonString(msg));
}
```
4、 此外Redis队列基础功能上还增加了自动愈合功能(客户端消费失败 抛出Exception后会根据 @RedisQueueListener的retry=true 自动生成对应的dlq(死性队列)并转存，并可以通过实现spi接口RedisQueueExportService暴露的饱和策略去灵活处理消费失败或持续失败的消息 )

5、 天然支持Redis延时队列
 
``` java
@Autowired
private RedissonService redissonService;

public void send(){
    redissonService.addDelayedQueue("testQueue", header, delay, delayTimeUnit, MsgEntity.builder().name("test").build());
}
```
6、 还有其他特性待续