# rocketmq测试

**Repository Path**: wan_long_bei/rocketmq-testing

## Basic Information

- **Project Name**: rocketmq测试
- **Description**: No description available
- **Primary Language**: Java
- **License**: MulanPSL-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-04-03
- **Last Updated**: 2026-04-03

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# test-public-rocketmq

## 项目简介

这是一个基于Spring Boot 3.2.11和RocketMQ的测试项目，用于演示如何集成RocketMQ消息队列到Spring Boot应用中。

## 项目功能

- Spring Boot 3.2.11框架集成
- RocketMQ消息队列集成
- 健康检查端点
- 服务状态监控

## 技术栈

| 技术 | 版本 | 说明 |
|------|------|------|
| Java | 17 | 编程语言 |
| Spring Boot | 3.2.11 | 应用框架 |
| RocketMQ | 5.1.4 | 消息队列 |
| Lombok | 1.18.36 | 代码简化工具 |
| Maven | 3.9.1 | 构建工具 |

## 依赖版本

### 核心依赖

- **Spring Boot**: 3.2.11
  - spring-boot-starter-web: 3.2.11
  - spring-boot-starter-test: 3.2.11

- **RocketMQ**: 5.1.4
  - rocketmq-spring-boot-starter: 5.1.4

- **工具依赖**
  - Lombok: 1.18.36

### 构建工具

- **Maven Compiler Plugin**: 3.11.0
- **Spring Boot Maven Plugin**: 3.2.11

## 项目结构

```
test-public-rocketmq/
├── src/
│   ├── main/
│   │   ├── java/com/example/testpublicrocketmq/
│   │   │   ├── TestPublicRocketmqApplication.java  # 启动类
│   │   │   └── controller/
│   │   │       └── HealthController.java          # 健康检查控制器
│   │   └── resources/
│   │       └── application.yml                     # 配置文件
│   └── test/
│       └── java/com/example/testpublicrocketmq/
├── pom.xml                                         # Maven配置文件
└── README.md                                       # 项目说明文件
```

## 配置说明

### application.yml

```yaml
# 应用配置
spring:
  # 应用名称
  application:
    name: test-public-rocketmq

# 服务器配置
server:
  # 服务器端口
  port: 8080

# RocketMQ配置
rocketmq:
  # 名称服务器地址
  name-server: localhost:9876
  # 生产者配置
  producer:
    # 生产者组
    group: test-producer-group
    # 发送消息超时时间（毫秒）
    send-message-timeout: 3000
    # 发送失败重试次数
    retry-times-when-send-failed: 2
    # 异步发送失败重试次数
    retry-times-when-send-async-failed: 2
    # 最大消息大小（字节）
    max-message-size: 4096
    # 消息压缩阈值（字节）
    compress-message-body-threshold: 1024
    # 重试下一个服务器
    retry-next-server: true
```

## 快速开始

### 1. 环境要求

- JDK 17+
- Maven 3.9.1+
- RocketMQ 5.1.4 (运行中)

### 2. 构建项目

```bash
# 构建项目
mvn clean package -DskipTests

# 运行项目
java -jar target/test-public-rocketmq-0.0.1-SNAPSHOT.jar
```

### 3. 验证服务

- **服务状态检查**：访问 http://localhost:8080/health
- **欢迎页面**：访问 http://localhost:8080/

## 启动日志

服务启动时会显示以下日志：

```
==================================
开始启动 RocketMQ 测试服务...
==================================
... 启动过程日志 ...
==================================
RocketMQ 测试服务启动成功！
访问地址: http://localhost:8080
健康检查: http://localhost:8080/health
==================================
```

## 健康检查响应

```json
{
  "status": "UP",
  "message": "服务启动成功！",
  "service": "test-public-rocketmq",
  "version": "0.0.1-SNAPSHOT"
}
```

## 注意事项

1. 确保RocketMQ服务正在运行，并且地址配置正确
2. 本项目使用Java 17，确保环境变量配置正确
3. 如需修改配置，请编辑application.yml文件

## 许可证

本项目采用MIT许可证，详见LICENSE文件。