Mico.Demo/MassTransit示例代码/测试说明.md

MassTransit Demo 测试说明

项目结构

MassTransit.Demo/
├── MassTransitDemo.Contracts/      # 消息契约项目
│   ├── PublishSubscribeMessage.cs   # 发布/订阅消息契约
│   ├── RequestMessage.cs            # 请求消息契约
│   └── ResponseMessage.cs           # 响应消息契约
├── MassTransitDemo.Publisher/       # 消息发布者API
│   ├── Controllers/
│   │   └── MessageController.cs     # 消息发布控制器
│   ├── Program.cs                    # 服务配置
│   └── appsettings.json              # 配置文件
└── MassTransitDemo.Consumer/        # 消息消费者API
    ├── Consumers/
    │   ├── PublishSubscribeConsumer1.cs  # 消费者1
    │   ├── PublishSubscribeConsumer2.cs  # 消费者2
    │   └── RequestResponseConsumer.cs    # 请求/响应消费者
    ├── Program.cs                    # 服务配置
    └── appsettings.json              # 配置文件

前置条件

1. 确保RabbitMQ服务器已启动并运行在：192.168.2.7:5672
2. 确保使用用户名：rabbit，密码：qwe123!@# 可以正常连接
3. 安装.NET 10 SDK

运行步骤

1. 还原依赖

dotnet restore

2. 构建解决方案

dotnet build

3. 启动Consumer项目

打开一个终端，进入Consumer项目目录：

cd MassTransitDemo.Consumer
dotnet run

Consumer项目将监听RabbitMQ队列并等待消息。

4. 启动Publisher项目

打开另一个终端，进入Publisher项目目录：

cd MassTransitDemo.Publisher
dotnet run

Publisher项目将提供API接口用于发送消息。

API测试

发布/订阅模式测试

使用Postman或curl发送POST请求：

URL: POST /api/message/publish

请求体:

{
  "title": "测试消息",
  "content": "这是一条发布/订阅模式的测试消息",
  "priority": 1
}

curl示例:

curl -X POST "https://localhost:<port>/api/message/publish" \
  -H "Content-Type: application/json" \
  -d '{
    "title": "测试消息",
    "content": "这是一条发布/订阅模式的测试消息",
    "priority": 1
  }'

预期结果:

• 响应包含成功状态和MessageId
• Consumer项目的日志中会看到【消费者1】和【消费者2】都接收到了消息

请求/响应模式测试

URL: POST /api/message/request

支持的操作类型:

• echo: 原样返回参数
• uppercase: 将参数转换为大写
• lowercase: 将参数转换为小写
• reverse: 反转参数字符串
• length: 返回参数长度

请求体示例 (echo):

{
  "operation": "echo",
  "parameters": "Hello, MassTransit!"
}

请求体示例 (uppercase):

{
  "operation": "uppercase",
  "parameters": "Hello, MassTransit!"
}

curl示例:

curl -X POST "https://localhost:<port>/api/message/request" \
  -H "Content-Type: application/json" \
  -d '{
    "operation": "uppercase",
    "parameters": "Hello, MassTransit!"
  }'

预期结果:

• 响应包含成功状态、RequestId和处理后的数据
• Consumer项目的日志中会看到【请求/响应消费者】处理请求的过程

RabbitMQ配置说明

配置文件位置：appsettings.json

{
  "RabbitMQ": {
    "Host": "192.168.2.7",
    "Port": 5672,
    "Username": "rabbit",
    "Password": "qwe123!@#",
    "VirtualHost": "/"
  }
}

如需修改RabbitMQ连接信息，请更新Publisher和Consumer项目的appsettings.json文件。

消息队列说明

• publish-subscribe-queue-1: 消费者1的队列
• publish-subscribe-queue-2: 消费者2的队列
• request-response-queue: 请求/响应队列

故障排查

1. 连接RabbitMQ失败

   • 检查RabbitMQ服务器是否启动
   • 检查IP地址、端口、用户名和密码是否正确
   • 检查网络连接是否正常

2. 消息没有被消费

   • 确保Consumer项目正在运行
   • 检查RabbitMQ管理界面，确认队列存在且有绑定
   • 查看Consumer项目的日志输出

3. 请求超时

   • 确保Consumer项目正在运行
   • 检查网络延迟
   • 确认请求队列配置正确