# note-rabbitmq-spring

**Repository Path**: xiaobowen-hz/note-rabbitmq-spring

## Basic Information

- **Project Name**: note-rabbitmq-spring
- **Description**: 一个关于 SpringBoot 与 RabbitMQ 整合的学习笔记与示例项目仓库
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-04-21
- **Last Updated**: 2025-04-23

## Categories & Tags

**Categories**: Uncategorized

**Tags**: RabbitMQ, SpringBoot

## README

# note: RabbitMQ

#### 介绍

`SpringBoot` 集成 `RabbitMQ` 笔记


#### 环境准备

一、RabbitMQ（略...）


#### 使用说明

1. 配置文件 `application.yaml` 中的参数说明

    - 生产端基础配置，必须改成你的真实信息
    
    ```yaml
    spring.rabbitmq.host=192.168.8.2
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    ```
   
   PS：以下配置可自定义；但自定义后，消费端也必须保持一致
   
    ```yaml
    mq.exchange.sync=noteSyncDirect
    mq.queue.sync.user=userSyncQueue
    mq.queue.sync.room=roomSyncQueue
    mq.queue.sync.device=deviceSyncQueue
    ```
   
    - 消费端基础配置，必须改成你的真实信息
    
    ```yaml
    spring.rabbitmq.host=192.168.8.2
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    ```
   
   PS：以下配置可自定义；但必须与消息发布端保持一致，目的是为了在不同环境动态配置监听的队列名
   
    ```yaml
    mq.queue.sync.user=userSyncQueue
    mq.queue.sync.room=roomSyncQueue
    mq.queue.sync.device=deviceSyncQueue
    ```

2. 启动服务：`RabbitProducerApplication` `RabbitConsumerApplication`

3. 测试API：

- 发布点对点消息(POST/JSON)：`http://localhost:8080/rabbit/sent/user`
- 发布点对点消息(POST/JSON)：`http://localhost:8080/rabbit/sent/room`
- 发布点对点消息(POST/JSON)：`http://localhost:8080/rabbit/sent/device`
- 推送广播消息(POST/JSON)：`http://localhost:8080/rabbit/sent/notice`
- 酒店主题通知(POST/JSON)：`http://localhost:8080/rabbit/sent/hotelNotice`
- 管理员主题通知(POST/JSON)：`http://localhost:8080/rabbit/sent/adminNotice`


#### 目录结构

```
├── mq-entity                             - 公用实体、常量
│   ├── .../entity                        - 实体类
│   └── .../route                         - 常量
├── mq-consumer                           - 消费者
│   ├── .../config                        - 配置类
│   ├── .../mq                            - 消息监听器
│   ├── .../recoverer                     - 自定义消息恢复器（多选一）
│   └── .../handler                       - 自定义处理器，如：异常处理器
├── mq-producer                           - 生产者
│   ├── .../config                        - 配置类
│   ├── .../mq                            - 消息发布业务
│   │       ├── SyncDirectProducer        - 发布点对点消息
│   │       ├── NoticeFanoutProducer      - 广播消息
│   │       ├── NoticeTopicProducer       - 发布主题通知
│   │       └── ...                       - 待补充..
│   └── .../controller                    - API
```