# springboot-rabbitmq

**Repository Path**: ldxcf/springboot-rabbitmq

## Basic Information

- **Project Name**: springboot-rabbitmq
- **Description**: 一个简单的，基于springboot+rabbitmq+redis 的Demo程序。
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2021-02-25
- **Last Updated**: 2021-05-07

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 说明文档

### 这个一个简单的基于springboot+rabbitMQ+Redis 实现的简单的消息队列实现DEMO
采用了多种手段保证消息的可靠性投递。

* 消息本身是持久化的
* Exchange和Queue也是持久化的
* 提供了投递的Confirm 和 Returns 监听
* 所有的队列设置死信队列
* 消费出现异常可以重试
* 消息属性持久化到Redis之中，后续改造为持久化到数据库中
* TODO：后续添加定时任务，查找失败队列，并支持手工执行。
* TODO：后续添加消息执行日志。
* 由于学习RabbitQM时间不多，各种错误和遗漏会很多，请批评指正。

运行的步骤
* 修改consumer 和 producer 两个module 的 application.yml 之中redis和Rabbitmq的配置
* 在rabbitmq之中创建virtual-host : ylhost
* 启动consumer 子模块，ConsumerApplication 的main方法。
* producer的test下有送消息的方法ProducerApplicationTests.testSend()。执行该方法即可。

实现的核心

* 由Redis保存消息的状态，并后续进行手工处理失败消息。
* 将MQ中exchage，queue，routingkey 配置在application.yml之中，这样再新增队列的时候可以简单地配置yml即可，不用在写代码