# 云消息队列 MQ #
1
关注
13504内容
恭喜 Apache RocketMQ 荣获 2024 开源创新榜单“年度开源项目”
恭喜 Apache RocketMQ 荣获 2024 开源创新榜单“年度开源项目”
一本书精通Apache RocketMQ
一本书精通Apache RocketMQ
RabbitMQ实用技巧
连接超时通常是由于网络不稳定或RabbitMQ负载过高。可以通过增加连接重试机制来提高可靠性。
RabbitMQ如何保证消息可靠性？
RabbitMQ通过多种机制确保消息的可靠性，包括消息持久化、确认机制、消息重试与死信队列、消息去重、高可用性配置以及监控与告警机制。这些措施共同构成了RabbitMQ可靠消息传递的基础，帮助开发者在构建分布式系统时有效避免消息丢失和重复处理问题。理解并正确实施这些技术，将显著提高应用系统的稳定性和用户体验。
分库分表—4.数据迁移系统文档
本文介绍了数据迁移系统的设计与实现，主要包括：
1. 数据库设计：订单表、订单详情表、binlog消息消费记录表等关键表结构。
2. 枚举类：增量数据同步的操作类型、消费操作结果、DB数据库渠道等枚举值。
3. 接口设计：访问迁移看板界面、查询同步进度、发起全量同步等API。
4. 定时任务设计：定时核对校验数据、数据量统计、增量数据落地和失败重试等任务。
5. 技术亮点：滚动拉取方案、统计滚动进度、防止增量同步数据丢失和高效写入方案、数据扩容方案。
6. 全量同步和增量同步整体流程图。
7. 功能升级：数据源动态化配置、XML动态生成及扩容迁移时的问题处理。
【有奖实践】轻量消息队列（原 MNS）订阅 OSS 事件实时处理文件变动
当你需要对对象存储 OSS（Object Storage Service）中的文件变动进行实时处理、同步、监听、业务触发、日志记录等操作时，你可以通过设置 OSS 的事件通知规则，自定义关注的文件，并将 OSS 事件推送到轻量消息队列（原 MNS）的队列或主题中，开发者的服务即可及时收到相关通知，并通过消费消息进行后续的业务处理。
分库分表—3.详细介绍二
本文主要介绍了：基于Canal和RocketMQ的增量同步、增量同步任务查询与线程池提交、RocketMQ里的binlog消息的消费逻辑、新增binlog的数据同步逻辑、binlog基于内存队列的异步转发逻辑、基于CAS加锁的读写队列互换机制、binlog基于内存的merge合并逻辑、对merge数据从目标库里分批查询、对merge数据基于目标库数据做过滤、将过滤后的merge数据写入目标库、offset提交线程的启动和逻辑分析、增量同步过程中binlog写入失败的恢复、增量同步过程中的各种失败场景的恢复机制、定时移除已提交的增量同步消息、增量与全量并行运行、数据校验逻辑分析、无损发布方案等。
分库分表—2.详细介绍一
本文主要介绍了：单库单表到多库多表的全量复制方案、全量数据复制方案的中断恢复分析、数据迁移系统的工程结构和数据源配置、基于订单号和用户ID的分片路由算法、发起全量数据迁移任务的实现、处理全量数据迁移任务时的内存级表锁的实现、最小订单号的查询实现、全量数据迁移任务的进度组件的初始化、每一批数据的滚动查询、范围过滤、模型转换、去重校验以及批量写入、多数据源的工程代码实现、多批次滚动迁移的代码逻辑实现、手动触发和自动触发被中断的全量数据迁移任务、按天粒度的订单数据量定时计算逻辑、全量数据同步过程中的进度处理逻辑
分库分表—1.简要概述
本文从单库版本到分库分表的演进开始介绍，然后分析MySQL的性能瓶颈以及对应的解决方案，接着引入分库分表，最后介绍分库分表实战的一些关键细节。
Docker部署RocketMQ5.2.0集群
本文详细介绍了如何使用Docker和Docker Compose部署RocketMQ 5.2.0集群。通过创建配置文件、启动集群和验证容器状态，您可以快速搭建起一个RocketMQ集群环境。希望本文能够帮助您更好地理解和应用RocketMQ，提高消息中间件的部署和管理效率。
免费试用