# springboot_rocketmq

**Repository Path**: lpyRoker/springboot_rocketmq

## Basic Information

- **Project Name**: springboot_rocketmq
- **Description**: 本仓库是个人学习 Apache RocketMQ 的实践记录，聚焦消息队列核心模型与特性探索。涵盖发布订阅、请求应答、延迟 / 定时消息等场景的完整代码示例，包含生产者、消费者多实例演示（如消费者组模拟）。同时整理了 RocketMQ 消息模型、特性原理的学习笔记，从代码实操到理论梳理，助力快速上手分布式消息中间件，适合想深入理解 RocketMQ 工作机制的开发者参考交流～
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-07-09
- **Last Updated**: 2025-07-09

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README



# RocketMQ 示例项目

本项目演示了如何使用 RocketMQ 实现多种消息类型，包括普通消息、批量消息、延迟消息、事务消息等。

## 项目结构

本项目由两个主要模块组成：

- **rocketmq-producer**: 消息生产者模块，演示如何发送各种类型的消息。
- **rocketmq-consumer**: 消息消费者模块，演示如何消费各种类型的消息。

## 主要功能

该项目展示了 RocketMQ 的多种消息类型和使用场景：

- 普通消息（NormalMsg）
- 批量消息（BatchMsg）
- 延迟消息（DelayMsg）
- 顺序消息（OrderMsg）
- 异步消息（AsyncMsg）
- 单向消息（OneWayMsg）
- 请求回复消息（RequestReplyMsg）
- 重试消息（RetryMsg）
- 事务消息（TransactionMsg）

## 使用技术

- Java
- RocketMQ
- Spring Boot（通过 `@SpringBootApplication` 注解）
- Maven（通过 `pom.xml` 文件）

## 安装和运行

请参考各个模块中的 `README.md` 文件以获取详细的安装和运行说明。

## 主要类

### 生产者模块 (rocketmq-producer)

- `RocketmqProducerApplication`: Spring Boot 应用程序的主类。
- `NormalMsgProducer`: 发送普通消息。
- `BatchMsgProducer`: 发送批量消息。
- `DelayMsgProducer`: 发送延迟消息。
- `OrderMsgProducer`: 发送顺序消息。
- `AsyncMsgProducer`: 发送异步消息。
- `OneWayMsgProducer`: 发送单向消息。
- `RequestReplyMsgProducer`: 发送请求回复消息。
- `RetryMsgProducer`: 发送带有重试机制的消息。
- `SyncMsgProducer`: 发送同步消息。
- `TransactionMsgProducer`: 发送事务消息。
- `TransactionListenerImpl`: 实现事务消息的监听器。

### 消费者模块 (rocketmq-consumer)

- `RocketmqConsumerApplication`: Spring Boot 应用程序的主类。
- `NormalMsgConsumer`: 消费普通消息。
- `BatchMsgConsumer`: 消费批量消息。
- `DelayMsgConsumer`: 消费延迟消息。
- `OrderMsgConsumer`: 消费顺序消息。
- `AsyncMsgConsumer`: 消费异步消息。
- `OneWayMsgConsumer`: 消费单向消息。
- `RequestReplyMsgConsumer`: 消费请求回复消息。
- `RetryMsgConsumer`: 消费带有重试机制的消息。
- `SyncMsgConsumer`: 消费同步消息。
- `TransactionMsgConsumer`: 消费事务消息。

## 许可证

本项目遵循 Apache 2.0 协议。有关详细信息，请参阅 [RocketMQ 官方网站](https://rocketmq.apache.org)。