赞
踩
用户营销业务场景中存在大量延迟消息处理,如用户访问某物品未下单,15分钟后给该用户推送一张优惠券等,需要支持上亿用户推送,并且低延迟。现有技术方案:
以上技术缺点和本身系统大量应用kafka中间件,吞吐量高,考虑基于kafka开发延迟队列组件,同时也不需要引入第三方中间件
设计思路来自RocketMQ延迟消息:使用rocketmq延迟消息时,服务端实际上发送到另一个topic,并通过周期任务轮询检查延迟消息是否到期,到期才转发到目标topic,达到延迟效果。
参考该思路,自建延迟消息topic,在客户端消费者消费延迟消息,检查是否到期,到期则转发到目标topic&
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。