AI 助理
文档备案控制台
开发者社区 阿里云SRE技术社区 文章 正文

JAVA应用开发MQ实战最佳实践——Series1：RocketMQ综述及代码设计

2020-12-03 6974
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： JAVA应用开发MQ实战最佳实践——Series1：RocketMQ综述及代码设计

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

文章标签：
云消息队列 MQ
Java
消息中间件
RocketMQ
开发者
相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
SRE团队技术小编-小凌
目录
相关文章
varin
|
消息中间件 Ubuntu Java
SpringBoot整合MQTT实战：基于EMQX实现双向设备通信
本教程指导在Ubuntu上部署EMQX 5.9.0并集成Spring Boot实现MQTT双向通信，涵盖服务器搭建、客户端配置及生产实践，助您快速构建企业级物联网消息系统。
varin
3258 1
技术自由圈/原疯狂创客圈
|
消息中间件 架构师 Java
美团面试：对比分析 RocketMQ、Kafka、RabbitMQ 三大MQ常见问题？
美团面试：对比分析 RocketMQ、Kafka、RabbitMQ 三大MQ常见问题？
技术自由圈/原疯狂创客圈
2938 22
美团面试：对比分析 RocketMQ、Kafka、RabbitMQ 三大MQ常见问题？
东阳马生架构
|
消息中间件 NoSQL Java
RocketMQ实战—10.营销系统代码优化
本文主要介绍了如何对营销系统的四大促销场景的代码进行优化，包括：全量用户推送促销活动、全量用户发放优惠券、特定用户推送领取优惠券消息、热门商品定时推送。
东阳马生架构
426 3
东阳马生架构
|
消息中间件 Java 数据库
RocketMQ实战—9.营销系统代码初版
本文主要介绍了实现营销系统四大促销场景的代码初版：全量用户推送促销活动、全量用户发放优惠券、特定用户推送领取优惠券消息、热门商品定时推送。
东阳马生架构
477 8
RocketMQ实战—9.营销系统代码初版
东阳马生架构
|
消息中间件 搜索推荐 调度
RocketMQ实战—8.营销系统业务和方案介绍
本文详细介绍了电商营销系统的业务流程、技术架构及挑战解决方案。涵盖核心交易与支付后履约流程，优惠券和促销活动的发券、领券、用券、销券机制，以及会员与推送的数据库设计。技术架构基于Nacos服务注册中心、Dubbo RPC框架、RocketMQ消息中间件和XXLJob分布式调度工具，实现系统间高效通信与任务管理。针对千万级用户量下的推送和发券场景，提出异步化、分片处理与惰性发券等优化方案，解决高并发压力。同时，通过RocketMQ实现系统解耦，提升扩展性，并利用XXLJob完成爆款商品推荐的分布式调度推送。整体设计确保系统在大规模用户场景下的性能与稳定性。
东阳马生架构
794 6
RocketMQ实战—8.营销系统业务和方案介绍
东阳马生架构
|
消息中间件 Java 测试技术
RocketMQ实战—7.生产集群部署和生产参数
本文详细介绍了RocketMQ生产集群的部署与调优过程，包括集群规划、环境搭建、参数配置和优化策略。
东阳马生架构
919 1
RocketMQ实战—7.生产集群部署和生产参数
东阳马生架构
|
消息中间件 存储 NoSQL
RocketMQ实战—6.生产优化及运维方案
本文围绕RocketMQ集群的使用与优化，详细探讨了六个关键问题。首先，介绍了如何通过ACL配置实现RocketMQ集群的权限控制，防止不同团队间误用Topic。其次，讲解了消息轨迹功能的开启与追踪流程，帮助定位和排查问题。接着，分析了百万消息积压的处理方法，包括直接丢弃、扩容消费者或通过新Topic间接扩容等策略。此外，提出了针对RocketMQ集群崩溃的金融级高可用方案，确保消息不丢失。同时，讨论了为RocketMQ增加限流功能的重要性及实现方式，以提升系统稳定性。最后，分享了从Kafka迁移到RocketMQ的双写双读方案，确保数据一致性与平稳过渡。
东阳马生架构
764 6
东阳马生架构
|
消息中间件 NoSQL 大数据
RocketMQ实战—5.消息重复+乱序+延迟的处理
本文围绕RocketMQ的使用与优化展开，分析了优惠券重复发放的原因及解决方案。首先，通过案例说明了优惠券系统因消息重复、数据库宕机或消费失败等原因导致重复发券的问题，并提出引入幂等性机制（如业务判断法、Redis状态判断法）来保证数据唯一性。其次，探讨了死信队列在处理消费失败时的作用，以及如何通过重试和死信队列解决消息处理异常。接着，分析了订单库同步中消息乱序的原因，提出了基于顺序消息机制的代码实现方案，确保消息按序处理。此外，介绍了利用Tag和属性过滤数据提升效率的方法，以及延迟消息机制优化定时退款扫描的功能。最后，总结了RocketMQ生产实践中的经验.
东阳马生架构
1102 4
RocketMQ实战—5.消息重复+乱序+延迟的处理
东阳马生架构
|
消息中间件 存储 Kafka
RocketMQ实战—4.消息零丢失的方案
本文分析了用户支付完成后未收到红包的问题，深入探讨了RocketMQ事务消息机制的实现原理及其在确保消息零丢失中的作用。首先，通过全链路分析发现消息可能在推送、存储或消费环节丢失。接着，介绍了RocketMQ事务消息机制如何通过half消息、本地事务执行及回调确认来保证消息发送成功，并详细解析了其底层原理，如half消息对消费者不可见、rollback与commit操作等。同时，对比了同步重试方案，指出其在复杂场景下的局限性。
东阳马生架构
1000 0
RocketMQ实战—4.消息零丢失的方案

阿里云SRE技术社区

热门文章

最新文章

  • 1
    RocketMQ与MYSQL事务消息整合
  • 2
    RocketMQ：一个纯java的开源消息中间件--开发测试环境搭建
  • 3
    RocketMQ 5.0 POP 消费模式探秘
  • 4
    RocketMQ 简介
  • 5
    RocketMQ 端云一体化设计与实践
  • 6
    Rocketmq整合Spring中的推消费和litepull消费
  • 7
    Apache RocketMQ 的 Service Mesh 开源之旅
  • 8
    RocketMQ消息生产者是如何选择Broker的
  • 9
    RocketMQ 5.0 API 与 SDK 的演进
  • 10
    RocketMQ最佳实践
  • 1
    2025 OSCAR丨与创新者同频！Apache RocketMQ 邀您共赴开源之约
    364
  • 2
    Modbus 与 MQTT 协议兼容：MyEMS 的泛在能源数据采集技术实现
    741
  • 3
    SpringBoot整合MQTT实战：基于EMQX实现双向设备通信
    3258
  • 4
    海量接入、毫秒响应：易易互联基于 Apache RocketMQ + MQTT 构筑高可用物联网消息中枢
    747
  • 5
    SpringBoot集成RocketMq
    2690
  • 6
    消息队列比较：Spring 微服务中的 Kafka 与 RabbitMQ
    786
  • 7
    RabbitMQ 和 Spring Cloud Stream 实现异步通信
    641
  • 8
    快速部署自己私有MQTT-Broker-下载安装到运行不到一分钟，快速简单且易于集成到自己项目中
    2596
  • 9
    阿里云消息队列 Apache RocketMQ 创新论文入选顶会 ACM FSE 2025
    641
  • 10
    Docker环境下快速部署RabbitMQ教程。
    847

    • 相关课程

    更多
  • 消息队列 RocketMQ 消息集成
  • 消息队列 MNS 入门课程
  • RocketMQ知识精讲与项目实战（第一阶段）
  • RocketMQ知识精讲与项目实战（第二阶段）
  • RocketMQ知识精讲与项目实战（第三阶段）
  • 微服务实战-RocketMQ Binder

    • 相关电子书

    更多
  • RocketMQ Client-GO 介绍
  • RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
  • 基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！