腾讯云 TDMQ RocketMQ 版是基于 Apache RocketMQ 打造的满足金融级高可靠的在线业务消息队列产品,凭借其高可用、高可靠等特性,被广泛应...
随着分布式系统架构的普及,消息队列已成为支撑大规模、高并发在线业务的核心组件之一。TDMQ RocketMQ 版作为一款高性能、高可靠的消息中间件,通过提供稳定...
首先营销系统对全量用户发放优惠券的任务进行分片,然后将分片的消息发送到如下Topic。
接下来优化营销系统的四大促销场景的代码:全量用户推送促销活动、全量用户发放优惠券、特定用户推送领取优惠券消息、热门商品定时推送
在 RocketMQ 的日常运维中,我们经常需要访问不同的数据源来获取诊断信息。传统的方式往往需要编写复杂的查询语句,或者在多个系统之间切换,效率低下。为了解决...
那么会放哪些配置数据呢?其实会根据@ConfigurationProperties注解里指定的前缀prefix,把前缀对应的配置数据从配置文件里加载出来,注入到...
千万级用户促销活动全量推送、千万级用户惰性发放优惠券、百万级画像群体推送爆款商品的架构方案
采取2台NameServer,2组MasterSlave Broker的部署结构。
如果一个公司有很多技术团队,每个技术团队都会使用RocketMQ集群中的部分Topic。那么此时可能就会有一个问题:如果订单团队使用的Topic,被商品团队不小...
有用户在支付一个订单后,一下子收到了多个优惠券,本来按照规则只应该有一个优惠券的。也就是说,订单系统给用户重复发放了多个优惠券。
有用户反馈,按照规则,在支付成功后应该是可以拿到一个现金红包的,但是他在支付完一个订单后,却没有收到这个现金红包,于是就反馈给了客服。
目前已经有了一套3台NameServer机器 + 6台Broker机器的生产集群,而且对集群的生产参数都进行了适当优化,足以抗下每秒十多万的消息请求。
通常一个公司里可能会存在多个业务系统,这些业务系统之间的通信都是通过接口调用来进行的。现在假设用户在浏览器或者APP向系统A发起一个请求,系统A收到这个请求后会...
root@host apps]# unzip rocketmq-all-4.9.4-bin-release.zip
2.订单系统面临的技术问题一:下订单的同时还要发券、发红包、Push推送等导致性能太差
Push同步模式:Producer往Broker主节点写入数据后,Broker主节点会主动把数据推送Push到Broker从节点里。
本文将系统阐述 Apache RocketMQ 消息过滤机制的技术架构与实践要点。首先从业务应用场景切入,解析消息过滤的核心价值;接着介绍 Apache Roc...
Producer发送消息时需要指定一个Topic,需要知道Topic里有哪些Queue,以及这些Queue分别分布在哪些Broker上。因此,Producer发...
NameServer启动后,会有一个NamesrvController组件管理控制NameServer的所有行为,包括内部会启动一个Netty服务器去监听一个9...
现已知Broker作为一个JVM进程启动后,会由BrokerStartup这个启动组件先初始化4个配置组件,然后再通过这4个配置组件创建BrokerContro...