Java 项目教程《黑马商城》RabbitMQ 高级篇 01 - 13一、参考资料【黑马程序员SpringCloud微服务开发与实战java黑马商城项目微服务实战开发涵盖MybatisPlus、Docker、MQ、ES、Redis高级等】 https://www.bilibili.com/video/BV1S142197x7/?p85share_sourcecopy_webvd_source855891859b2dc554eace9de3f28b4528黑马商城项目 Gitee 地址 https://gitee.com/yangjunbo-jetli/hmall.gitRabbitMQ 测试项目 Gitee 地址 https://gitee.com/yangjunbo-jetli/mq-demo.git二、笔记总结-高级篇01、课程介绍02、发送者可靠性-发送者重连机制03、发送者可靠性-发送者确认机制04、发送者可靠性-发送者确认的代码实现05、MQ 可靠性-数据持久化06、MQ 可靠性-LazyQueue07、消费者可靠性-消费者确认机制08、消费者可靠性-消费者失败重试策略09、消费者可靠性-业务幂等处理10、延迟消息-什么是延迟消息11、延迟消息-死信交换机12、延迟消息-延迟消息插件13、延迟消息-取消超时订单四、AI 简介 黑马商城微服务实战RabbitMQ 核心技术与应用在微服务架构中服务间的通信是核心痛点。《黑马商城》项目通过引入RabbitMQ巧妙地解决了服务耦合、异步处理和流量削峰等问题。本篇教程将带你深入 Spring Cloud 微服务与 RabbitMQ 的整合实战从底层原理到代码实现助你掌握企业级消息中间件的落地技巧。 核心学习内容SpringAMQP 快速入门基础组件详解 Exchange交换机的四种类型Fanout、Direct、Topic、Headers与 Queue队列的声明及绑定关系。声明方式对比Bean声明与RabbitListener注解声明的优劣解决多参数绑定的繁琐问题。消息序列化针对 JDK 默认序列化存在的“体积大、不安全、可读性差”痛点实战配置JSON 序列化转换器提升消息传输的效率与可读性。业务改造与异步通信场景实战以“支付成功后更新订单状态”为例演示如何将传统的同步 Feign 调用改造为基于 MQ 的异步通知。解耦与容错通过引入 Direct Exchange实现精准的消息路由避免广播带来的资源浪费。代码实现涵盖生产者Pay-Service的消息发送逻辑与消费者Trade-Service的监听处理逻辑确保业务逻辑的平滑迁移。消息可靠性投递高级篇生产者可靠性配置发送者重连机制应对网络抖动导致的消息发送失败。数据持久化讲解消息的持久化策略确保 RabbitMQ 服务重启后消息不丢失Lazy Queue 的默认优化。消费者可靠性通过try-catch异常捕获与手动 ACK 机制防止因消费者异常导致的消息丢失。常见问题与进阶方案幂等性处理解决网络波动导致的“重复消费”问题如用户收到多条扣款通知通过业务逻辑判断或唯一 ID 校验保证数据一致性。延迟消息引入延迟队列或死信交换机DLX实现“订单超时未支付自动取消”的电商核心功能。架构优化探讨按业务模块拆分队列如order.queue、inventory.queue实现业务隔离与独立伸缩。 技术亮点全链路实战不仅讲 API 用法更注重在 Spring Cloud 微服务环境下的实际业务场景落地。避坑指南针对初学者常遇到的“消息堆积”、“序列化异常”、“路由键配置错误”等问题提供解决方案。源码与配置结合 Nacos 配置中心管理 MQ 地址利用 Docker 快速部署 RabbitMQ 环境提供可复用的代码片段与配置文件。适合人群具备 Java 基础与 Spring Boot 开发经验正在学习微服务架构或准备面试的开发者。通过本教程的学习你将能独立设计并实现高可靠、高性能的消息中间件方案为你的分布式项目增添核心竞争力。