消息队列RocketMQ版如何保证的相关内容

文章 2023-02-19 来自：开发者社区

RocketMQ结合实际场景顺序消费，它是如何保证顺序消费的？

一、实战场景用户更新钱包金额 ->用户向钱包中转入100元，短信通知用户A目前剩余金额100元 ->用户下单商品消费50元，短信通知用户A目前剩余金额50元。普通消息：不顺序发送余额短信，则用户可能存在先收到余额50元，再收到余额100元的信息，带来不好的用户体验。代码环节为了更加体现消息的顺序性差异，我们在一次调用中循环发送10次发送普通消息publicBooleanupdateU....

文章 2022-09-08 来自：开发者社区

面试官：RocketMQ 如何保证消息不丢失，如何保证消息不被重复消费？

1、消息整体处理过程这里我们将消息的整体处理阶段分为3个阶段进行分析：Producer发送消息阶段。Broker处理消息阶段。Consumer消费消息阶段。Producer发送消息阶段发送消息阶段涉及到Producer到broker的网络通信，因此丢失消息的几率一定会有，那RocketMQ在此阶段用了哪些手段保证消息不丢失了（或者说降低丢失的可能性）。手段一：提供SYNC的发送消息方式，等待br....

文章 2022-05-13 来自：开发者社区

Kafka/RocketMQ 多线程消费时如何保证消费顺序？

上两篇文章都在讨论顺序消息的一些知识，看到有个读者的留言如下：这个问题问得非常棒，由于在之前的文章中并没有提及到，因此我在这篇文章中单独讲解，本文将从消费顺序性这个问题出发，深度剖析 Kafka/RocketMQ 消费线程模型。Kafkakafka 的消费类 KafkaConsumer 是非线程安全的，因此用户无法在多线程中共享一个 KafkaConsumer 实例，且 KafkaConsume....

文章 2021-02-02 来自：开发者社区

RocketMQ如何保证消息的可靠性？

作者 | 修戟来源 | 阿里技术公众号分布式系统中一个重要的前提假设是所有的网络传输都是不可靠的，在网络传输不可靠的情况下，保证消息的可靠传输，除了进行重试投递别无他法。常用的绝大多数消息队列RocketMQ、RabbitMQ等在消息传输上都只能保证至少传输成功一次，也即（At least once），而不能保证只传输成功一次（Exactly once）。由于分布式系统网络的不可靠，可能就会出现....

问答 2018-12-10 来自：开发者社区

[@倚贤][¥20]rocketMQ二阶事务消息如何保证高效吞吐量?

问题来自Java技术沙龙的刘静Java技术沙龙报名链接：https://yq.aliyun.com/promotion/796

问答 2018-12-07 来自：开发者社区

[@倚贤][¥20]rocketMQ二阶事务消息如何保证高效吞吐量？

问题来自Java技术沙龙的刘静Java线下沙龙报名链接：https://yq.aliyun.com/activity/796

共有6条

< 1 >

跳转至： GO

更新时间 2023-05-10 15:28:21

本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。

消息队列RocketMQ版您可能感兴趣

产品推荐

{"moduleinfo":{"card_count":[{"count_phone":1,"count":1}],"search_count":[{"count_phone":4,"count":4}]},"card":[],"search":[],"countinfo":{"search":{"length_pc":0,"length":0},"card":{"length_pc":0,"length":0}},"simplifiedDisplay":"newEdition","newCard":[{"link":"https://www.aliyun.com/product/rocketmq","icon":"","title":"云消息队列 RocketMQ 版","des":"云消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。RocketMQ 自诞生以来一直服务阿里集团十余年，历经多次双十一万亿级数据洪峰稳定性验证。","btn1":"产品控制台","link1":"https://ons.console.aliyun.com/overview","btn2":"查看详情","link2":"https://www.aliyun.com/product/rocketmq","btn3":"预约咨询","link3":"https://survey.aliyun.com/apps/zhiliao/bzT3AfPaq","infoGroup":[{"infoName":"精选推荐","infoContent":{"firstContentName":"Serverless资源包优惠","firstContentLink":"https://common-buy.aliyun.com/?spm=5176.234368.J_5253785160.2.7f334ef6LINaFS&commodityCode=ons_rocketmqV5_spn_public_cn","lastContentName":"新用户首月85折","lastContentLink":"https://common-buy.aliyun.com/?commodityCode=ons_rmqsub_public_cn#/buy"}},{"infoName":"最佳实践","infoContent":{"firstContentName":"开源RocketMQ迁移","firstContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/user-guide/overview-6?spm=a2c4g.11186623.0.0.72053010BxUbOn","lastContentName":"故障处理最佳实践","lastContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/user-guide/best-practices-for-fault-handling-based-on-the-observability-feature?spm=a2c4g.11186623.0.0.5691637btgDv5N"}},{"infoName":"用户指南","infoContent":{"firstContentName":"产品快速入门","firstContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/getting-started/overview-9?spm=a2c4g.11186623.0.0.3530714e0G3I6J","lastContentName":"产品常见问题","lastContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/support/faq?spm=a2c4g.11186623.0.0.1375244aclcafe"}},{"infoName":"解决方案","infoContent":{"firstContentName":"RocketMQ全链路追踪","firstContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/user-guide/end-to-end-tracing-analysis-solution?spm=a2c4g.11186623.0.0.179d52a8wcVlvO","lastContentName":"","lastContentLink":""}}],"ifIcon":"img","iconImg":"https://img.alicdn.com/imgextra/i2/O1CN017fCdal1qFwEnah5wz_!!6000000005467-2-tps-200-200.png","contentLink":"https://www.aliyun.com/product/rocketmq"}],"visual":{"icon":"","topbg":"","textColor":"dark"}}

{"$env":{"JSON":{}},"$page":{"env":"production"},"$context":{"moduleinfo":{"card_count":[{"count_phone":1,"count":1}],"search_count":[{"count_phone":4,"count":4}]},"card":[],"search":[],"countinfo":{"search":{"length_pc":0,"length":0},"card":{"length_pc":0,"length":0}},"simplifiedDisplay":"newEdition","newCard":[{"link":"https://www.aliyun.com/product/rocketmq","icon":"","title":"云消息队列 RocketMQ 版","des":"云消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。RocketMQ 自诞生以来一直服务阿里集团十余年，历经多次双十一万亿级数据洪峰稳定性验证。","btn1":"产品控制台","link1":"https://ons.console.aliyun.com/overview","btn2":"查看详情","link2":"https://www.aliyun.com/product/rocketmq","btn3":"预约咨询","link3":"https://survey.aliyun.com/apps/zhiliao/bzT3AfPaq","infoGroup":[{"infoName":"精选推荐","infoContent":{"firstContentName":"Serverless资源包优惠","firstContentLink":"https://common-buy.aliyun.com/?spm=5176.234368.J_5253785160.2.7f334ef6LINaFS&commodityCode=ons_rocketmqV5_spn_public_cn","lastContentName":"新用户首月85折","lastContentLink":"https://common-buy.aliyun.com/?commodityCode=ons_rmqsub_public_cn#/buy"}},{"infoName":"最佳实践","infoContent":{"firstContentName":"开源RocketMQ迁移","firstContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/user-guide/overview-6?spm=a2c4g.11186623.0.0.72053010BxUbOn","lastContentName":"故障处理最佳实践","lastContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/user-guide/best-practices-for-fault-handling-based-on-the-observability-feature?spm=a2c4g.11186623.0.0.5691637btgDv5N"}},{"infoName":"用户指南","infoContent":{"firstContentName":"产品快速入门","firstContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/getting-started/overview-9?spm=a2c4g.11186623.0.0.3530714e0G3I6J","lastContentName":"产品常见问题","lastContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/support/faq?spm=a2c4g.11186623.0.0.1375244aclcafe"}},{"infoName":"解决方案","infoContent":{"firstContentName":"RocketMQ全链路追踪","firstContentLink":"https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-5-x-series/user-guide/end-to-end-tracing-analysis-solution?spm=a2c4g.11186623.0.0.179d52a8wcVlvO","lastContentName":"","lastContentLink":""}}],"ifIcon":"img","iconImg":"https://img.alicdn.com/imgextra/i2/O1CN017fCdal1qFwEnah5wz_!!6000000005467-2-tps-200-200.png","contentLink":"https://www.aliyun.com/product/rocketmq"}],"visual":{"icon":"","topbg":"","textColor":"dark"}}}