骑士卡:基于Kafka搭建消息中心,上亿消息推送轻松完成-阿里云开发者社区

开发者社区> 阿里中间件> 正文
登录阅读全文

骑士卡:基于Kafka搭建消息中心,上亿消息推送轻松完成

简介: 消息中心作为业务运营推广的基石,发挥着重要作用。使用消息队列Kafka即可构造建设一个高性能、高稳定性、可扩展的消息中心,完美契合骑士卡高速发展过程中遇到的需求。

作者:折松,阿里云解决方案架构师


全球购骑士卡是国内领先的会员制特权电商平台,汇聚国内外“吃喝玩乐买”超300项会员专属优惠特权。全球购骑士卡基于移动互联生活方式,打通线上、线下消费场景,汇集时下热门、高频的商品及服务优惠。会员可享全国超万家大型商超购物8折起、全国加油7折起、热门电商平台专属4折起、大牌美食餐饮5折起等,满足用户吃、喝、玩、乐、买各场景的消费需求。截至2020年,全球购骑士卡已累计服务用户超5000万名。2020年4月,全球购骑士卡完成A轮数千万美元融资;同年5月,全球购骑士卡完成数千万美元A+轮融资。


新的需求


全球购骑士特权业务的飞速发展,当前每天平均发送的短信量达到了约200万+,需要PUSH的推送量达到了约1亿+,通过微信推送量达到了5000万+。因此,如何构造建设一个高性能、高稳定性、可扩展的消息中心迫在眉睫。


消息中心技术选型主要参考以下因素:


  • 削峰填谷能力:消息中心需要处理各条业务线的通知和营销任务的信息,而这些信息根据转化的需要,很大可能会集中化地在短期内进行推送,所以需要系统有削峰填谷的能力。
  • 接口通用能力:消息中心的接入方不希望被绑定在某个接口上,不需要对该接口进行维护可以供多个业务方进行发送处理。
  • 活类型划分:消息中心需要支持灵活的业务分类配置, 因为我们消息中心这里的业务配置非常多,大类就有短信、PUSH、微信推送,短信里又分通知、验证码和营销类别,而PUSH又区分APNS、渠道服务商等第三方通道,以及Android厂商通道。
  • 稳定处理能力:所依赖的技术产品运行稳定,因为处于消息中心的通道位置,不能忍受产品本身的稳定性波动带来的业务损失。
  • 集群扩展能力:所依赖的技术产品没有扩容瓶颈,对于我们的业务继续发展有扩展的足够空间,可以快速进行业务扩容诉求。


新的解法


image.png


使用消息中间件来做消息中心的通道是显现而见的目标选项,综合对比多种消息的产品,由于骑士卡并没有需要顺序消息、事务消息等高阶功能,而是重点关注以下这些功能点:


  • 队列的扩展能力: 在这方面,RabbitMQ的单Queue的处理能力不容易扩展;而RocketMQ的Topic是有ConsumerQueue的参数来进行配置扩容的,在Broker的配置文件里指定,但是对Broker层面生效的;而Kafka的Partition可以每个Topic拥有不同的取值。这样在分类灵活性方面,Kafka是最优的选择,RocketMQ次之。
  • 通用的接入方式:本质上RabbitMQ、RocketMQ、Kafka都是私有协议的方式接入,比较云上商业版本的接入方式,对于Kafka支持最纯粹友好,可以使用官方的接入方式进行接入。
  • 消息的吞吐能力:在各类消息的对比测试中, 因为Kafka本身的处理机制原因,都是由客户端进行拉消息,整个broker的处理方式比别的消息中间件要简洁,而Kafka的读写能力/吞吐量都是最大的。
  • 集群稳定性能力:云上的消息产品都很友好地保持业务的连续性来进行升配操作,并且对于商业版本的Kafka做了Broker上的优化,存储上的优化,运维上的优化后,不需要担心自建集群出现的不稳定问题,完全满足骑士卡的需求。


业务价值


使用Kafka构建消息中心,对骑士卡来说最重要的是保障了业务的稳健。利用Kafka的吞吐能力,自定义的partition设定(扩展),通过弹性扩展消费者实例的方式,自消息中心上线以来,一直运行平稳,没有出现过影响业务的故障。


同时,系统运维起来十分简单。利用云上的Kafka能力,避免了测试期自建集群莫名其妙的Broker故障,不需要投入额外的资源来保障消息中间件正常工作。并且可以通过白屏化的升级操作来匹配骑士卡的业务发展,也可以按需要来快速调整实例数。


值得一提的是,使用云产品Kafka,无论在生产环境还是本地开发测试环境,都可以直接使用云产品,最大限度减少通用产品依赖,让团队专注于业务的开拓实现,极大的提升了团队工作效率。


“在全球购骑士卡消息中心的搭建过程中,我们使用阿里云的Kafka完成了消息中心高吞吐量,稳定以及可扩展的目标。目前,消息中心作为业务运营推广的基石,发挥着重要作用,对于新业务的接入,通过消息队列的配置修改即可完成,对现有业务可以做到无侵入,尽可能的减少了故障发生的可能。”

——骑士卡CTO


关联产品:

消息队列 Kafka


扫码了解更多技术内容与客户案例:

image.png


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

分享:
阿里中间件
使用钉钉扫一扫加入圈子
+ 订阅

为企业提供高效、稳定、易扩展的中间件产品

官方博客
链接