# mq_demo

**Repository Path**: liyouqing/mq_demo

## Basic Information

- **Project Name**: mq_demo
- **Description**: 分布式消息中间件相关代码，包括rocketmq  rabbitmq  kafka等等
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 2
- **Forks**: 0
- **Created**: 2025-06-04
- **Last Updated**: 2025-10-24

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

该项目中未找到 README.md 文件，因此无法提供现有内容。请根据以下建议创建一个 README.md 文件：

---

# MQ Demo 项目说明

## 项目简介
这是一个演示多种消息队列（MQ）实现的项目，包括 Kafka、RabbitMQ、RocketMQ 以及一个简单的自定义消息队列实现。此外，还提供了与 Spring Boot 集成的示例。

## 项目结构
- **kafka_demo** - Kafka 基础生产者与消费者示例。
- **rabbitmq_demo** - RabbitMQ 基础生产者与消费者示例。
- **rocketmq_demo** - RocketMQ 基础生产者与消费者示例。
- **simple_mq** - 一个简单的自定义消息队列实现。
- **spring_boot_kafka_demo** - Kafka 与 Spring Boot 集成示例。
- **spring_boot_rabbitmq_demo** - RabbitMQ 与 Spring Boot 集成示例。
- **spring_boot_rocketmq_demo** - RocketMQ 与 Spring Boot 集成示例，包括事务消息、延迟消息和顺序消息。

## 使用说明
### 环境要求
- JDK 1.8 或更高版本
- Maven 3.x
- 各消息队列的运行环境（如 Kafka、RabbitMQ、RocketMQ 服务）

### 构建与运行
1. 克隆项目：
   ```bash
   git clone https://gitee.com/liyouqing/mq_demo.git
   ```
2. 进入项目目录：
   ```bash
   cd mq_demo
   ```
3. 使用 Maven 构建项目：
   ```bash
   mvn clean install
   ```
4. 进入具体模块目录并运行示例代码。

### 示例
- **Kafka 示例**：
  - 启动 Kafka 服务。
  - 运行 `kafka_demo` 模块中的 `Producer.java` 和 `Consumer.java`。

- **RabbitMQ 示例**：
  - 启动 RabbitMQ 服务。
  - 运行 `rabbitmq_demo` 模块中的 `Producer.java` 和 `Consumer.java`。

- **RocketMQ 示例**：
  - 启动 RocketMQ 服务。
  - 运行 `rocketmq_demo` 模块中的 `Producer.java` 和 `Consumer.java`。

- **Simple MQ 示例**：
  - 运行 `simple_mq` 模块中的 `BrokerServer.java` 启动 Broker。
  - 运行 `Producer.java` 和 `Consumer.java` 进行测试。

- **Spring Boot 集成示例**：
  - 根据具体模块配置 `application.yml`。
  - 启动 Spring Boot 应用并访问相关接口进行测试。

## 贡献指南
欢迎贡献代码！请遵循以下步骤：
1. Fork 项目。
2. 创建新分支。
3. 提交 Pull Request。

## 许可证
本项目采用 MIT 许可证。详情请查看 LICENSE 文件。

--- 

请根据实际需求调整内容并保存为 README.md 文件。