全球購騎士卡是國內(nèi)領(lǐng)先的會員制特權(quán)電商平臺，匯聚國內(nèi)外“吃喝玩樂買”超 300 項會員專屬優(yōu)惠特權(quán)。全球購騎士卡基于移動互聯(lián)生活方式，打通線上、線下消費(fèi)場景，匯集時下熱門、高頻的商品及服務(wù)優(yōu)惠。會員可享全國超萬家大型商超購物8折起、全國加油7折起、熱門電商平臺專屬4折起、大牌美食餐飲 5 折起等，滿足用戶吃、喝、玩、樂、買各場景的消費(fèi)需求。截至2020年，全球購騎士卡已累計服務(wù)用戶超 5000 萬名。2020年4月，全球購騎士卡完成 A 輪數(shù)千萬美元融資；同年 5 月，全球購騎士卡完成數(shù)千萬美元 A+輪融資。

新的需求

全球購騎士特權(quán)業(yè)務(wù)的飛速發(fā)展，當(dāng)前每天平均發(fā)送的短信量達(dá)到了約 200 萬+，需要 PUSH 的推送量達(dá)到了約 1 億+，通過微信推送量達(dá)到了5000 萬+。因此，如何構(gòu)造建設(shè)一個高性能、高穩(wěn)定性、可擴(kuò)展的消息中心迫在眉睫。
消息中心技術(shù)選型主要參考以下因素：

• 削峰填谷能力 ：消息中心需要處理各條業(yè)務(wù)線的通知和營銷任務(wù)的信息，而這些信息根據(jù)轉(zhuǎn)化的需要，很大可能會集中化地在短期內(nèi)進(jìn)行推送，所以需要系統(tǒng)有削峰填谷的能力。
• 接口通用能力 ：消息中心的接入方不希望被綁定在某個接口上，不需要對該接口進(jìn)行維護(hù)可以供多個業(yè)務(wù)方進(jìn)行發(fā)送處理。
• 靈活類型劃分 ：消息中心需要支持靈活的業(yè)務(wù)分類配置， 因為我們消息中心這里的業(yè)務(wù)配置非常多，大類就有短信、PUSH、微信推送，短信里又分通知、驗證碼和營銷類別，而 PUSH 又區(qū)分 APNS、渠道服務(wù)商等第三方通道，以及 Android 廠商通道。
• 穩(wěn)定處理能力 ：所依賴的技術(shù)產(chǎn)品運(yùn)行穩(wěn)定，因為處于消息中心的通道位置，不能忍受產(chǎn)品本身的穩(wěn)定性波動帶來的業(yè)務(wù)損失。
• 集群擴(kuò)展能力 ：所依賴的技術(shù)產(chǎn)品沒有擴(kuò)容瓶頸，對于我們的業(yè)務(wù)繼續(xù)發(fā)展有擴(kuò)展的足夠空間，可以快速進(jìn)行業(yè)務(wù)擴(kuò)容訴求。
  

新的解法

• 隊列的擴(kuò)展能力 ：在這方面，RabbitMQ 的單 Queue 的處理能力不容易擴(kuò)展；而 RocketMQ 的 Topic 是有 ConsumerQueue 的參數(shù)來進(jìn)行配置擴(kuò)容的，在 Broker 的配置文件里指定，但是對 Broker 層面生效的；而 Kafka 的 Partition 可以每個 Topic 擁有不同的取值。這樣在分類靈活性方面，Kafka 是最優(yōu)的選擇，RocketMQ 次之。
• 通用的接入方式 ：本質(zhì)上 RabbitMQ、RocketMQ、Kafka 都是私有協(xié)議的方式接入，比較云上商業(yè)版本的接入方式，對于 Kafka 支持最純粹友好，可以使用官方的接入方式進(jìn)行接入。
• 消息的吞吐能力 ：在各類消息的對比測試中， 因為 Kafka 本身的處理機(jī)制原因，都是由客戶端進(jìn)行拉消息，整個 Broker 的處理方式比別的消息中間件要簡潔，而 Kafka 的讀寫能力/吞吐量都是最大的。
• 集群穩(wěn)定性能力 ：云上的消息產(chǎn)品都很友好地保持業(yè)務(wù)的連續(xù)性來進(jìn)行升配操作，并且對于商業(yè)版本的 Kafka 做了 Broker 上的優(yōu)化，存儲上的優(yōu)化，運(yùn)維上的優(yōu)化后，不需要擔(dān)心自建集群出現(xiàn)的不穩(wěn)定問題，完全滿足騎士卡的需求。

使用 Kafka 構(gòu)建消息中心，對騎士卡來說最重要的是 保障了業(yè)務(wù)的穩(wěn)健 。利用 Kafka 的吞吐能力，自定義的 partition 設(shè)定（擴(kuò)展），通過彈性擴(kuò)展消費(fèi)者實例的方式，自消息中心上線以來，一直運(yùn)行平穩(wěn)，沒有出現(xiàn)過影響業(yè)務(wù)的故障。
同時， 系統(tǒng)運(yùn)維起來十分簡單 。利用云上的Kafka能力，避免了測試期自建集群莫名其妙的 Broker 故障，不需要投入額外的資源來保障消息中間件正常工作。并且可以通過白屏化的升級操作來匹配騎士卡的業(yè)務(wù)發(fā)展，也可以按需要來快速調(diào)整實例數(shù)。
值得一提的是，使用云產(chǎn)品 Kafka，無論在生產(chǎn)環(huán)境還是本地開發(fā)測試環(huán)境，都可以直接使用云產(chǎn)品，最大限度減少通用產(chǎn)品依賴，讓團(tuán)隊專注于業(yè)務(wù)的開拓實現(xiàn)， 極大的提升了團(tuán)隊工作效率。

“在全球購騎士卡消息中心的搭建過程中，我們使用阿里云的Kafka完成了消息中心高吞吐量，穩(wěn)定以及可擴(kuò)展的目標(biāo)。 目前，消息中心作為業(yè)務(wù)運(yùn)營推廣的基石，發(fā)揮著重要作用，對于新業(yè)務(wù)的接入，通過消息隊列的配置修改即可完成，對現(xiàn)有業(yè)務(wù)可以做到無侵入，盡可能的減少了故障發(fā)生的可能。 ”
——騎士卡CTO