# tutorial-mq **Repository Path**: ma5d/tutorial-mq ## Basic Information - **Project Name**: tutorial-mq - **Description**: tutorial-mq - **Primary Language**: Unknown - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 0 - **Created**: 2025-09-26 - **Last Updated**: 2026-01-29 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # Tutorial MQ 统一的消息队列学习项目,包含 Kafka 和 RabbitMQ 的示例代码。 ## 项目结构 ``` tutorial-mq/ ├── src/main/java/com/ma5d/kafka/ # Kafka 相关代码 ├── HelloWorld/ # RabbitMQ HelloWorld 示例 │ └── src/main/java/com/ma5d/rabbit/helloworld/ ├── WorkQueues/ # RabbitMQ WorkQueues 示例 │ └── src/main/java/com/ma5d/rabbit/workqueues/ ├── SpringRabbit/ # Spring Boot + RabbitMQ 示例 │ └── src/main/java/com/ma5d/rabbit/ ├── kafka-ui/ # Kafka UI 工具 └── pom.xml # 父项目配置 ``` ## 模块说明 ### Kafka 模块 - 位于 `src/main/java/com/ma5d/kafka/` - 包含 Kafka 生产者和消费者示例 ### RabbitMQ 模块 #### HelloWorld - 基础的 RabbitMQ 生产者和消费者示例 - 包名:`com.ma5d.rabbit.helloworld` #### WorkQueues - 工作队列模式示例,包含多种消息模式 - 包名:`com.ma5d.rabbit.workqueues` - 包含:订单处理、交换机、确认机制、死信队列、优先级队列等 #### SpringRabbit - Spring Boot 集成 RabbitMQ 示例 - 包名:`com.ma5d.rabbit` - 包含:配置类、控制器、消费者、生产者等 ## 编译和运行 ```bash # 编译项目 mvn clean compile # 运行特定模块 cd HelloWorld && mvn exec:java -Dexec.mainClass="helloworld.rabbit.com.ma5d.tutorial.rabbit.producer.HelloChannelProducer" cd WorkQueues && mvn exec:java -Dexec.mainClass="com.ma5d.rabbit.workqueues.Producer" cd SpringRabbit && mvn spring-boot:run ``` ## 依赖说明 项目统一管理了以下依赖: - RabbitMQ Java Client - Spring Boot Starter AMQP - Spring Kafka - Lombok - FastJSON2 - Commons IO - Logback ## 注意事项 - 确保 RabbitMQ 和 Kafka 服务已启动 - 查看 `rabbitmq_info.txt` 了解 RabbitMQ 连接信息 - Spring Boot 应用默认端口:8080