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

新的需求

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

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

新的解法

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

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

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