# note-rocketmq-spring

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

## Basic Information

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

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-06-30
- **Last Updated**: 2025-06-30

## Categories & Tags

**Categories**: Uncategorized

**Tags**: rocketmq, SpringBoot

## README

# note: RocketMQ

#### 介绍

`SpringBoot` 集成 `RocketMQ` 笔记

#### 环境准备

#### Windows环境

1. 下载并解压 RocketMQ

    - 从 Apache 官方网站[下载](https://rocketmq.apache.org/download/) RocketMQ 的二进制包。推荐使用二进制包，因为它避免了编译过程
    - 将下载的文件解压到一个合适的位置

2. 配置 ROCKETMQ_HOME 环境变量，启动脚本依赖于该变量去定位相关的配置文件和资源。

3. 修改配置文件`broker.conf`，添加如下配置:

   ```yaml
   brokerIP1 = 192.168.2.15
   autoCreateTopicEnable = true
   ```

4. 启动 Name Server 组件，主要负责存储 Topic 及其路由信息。

   ```cmd
   mqnamesrv.cmd
   ```

5. 启动 Broker 组件，主要作用是解耦客户端和服务端。服务端注册自己到Broker，通过暴露接口的方式允许客户端接入服务。客户端是通过Broker发送请求的，Broker转发请求道服务端，并将请求的结果或异常回发给客户端。

   ```cmd
   mqbroker.cmd -n localhost:9876 -c %ROCKETMQ_HOME%\conf\broker.conf
   ```

#### 使用说明

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

    - 生产端基础配置，必须改成你的真实信息

    ```yaml
    rocketmq.name-server.host=127.0.0.1:9876
    rocketmq.consumer.group=note_producer_group
    ```

    - 消费端基础配置，必须改成你的真实信息

    ```yaml
    rocketmq.name-server.host=127.0.0.1:9876
    rocketmq.consumer.group=note_consumer_group
    ```

2. 启动服务：`RocketProducerApplication` `RocketConsumerApplication`

3. 测试API：

- 发布主题通知(POST/JSON)：`http://localhost:8088/rocket/sent/notice`

#### 目录结构

```
├── mq-entity                             - 公用实体、常量
│   ├── .../entity                        - 实体类
│   └── .../route                         - 常量
├── mq-consumer                           - 消费者
│   └── .../mq                            - 消息监听器
├── mq-producer                           - 生产者
│   ├── .../mq                            - 消息发布业务
│   │       ├── NoticeTopicProducer       - 发布主题通知
│   │       └── ...                       - 待补充..
│   └── .../controller                    - API
```