10 月 23 - 25 日,QCon 上海站即将召开,现在大会已开始正式报名,可以享受 8 折优惠 了解详情
写点什么

我们是怎么做到每小时推送百万级通知的

  • 2019-12-03
  • 本文字数:2085 字

    阅读完需:约 7 分钟

我们是怎么做到每小时推送百万级通知的

推送通知是让用户立即接收到事件的一个非常有效的工具。在 Gojek,我们每天需要处理 300 多万个订单,跨 20 多款产品。


可以想象的是,我们每天推送的通知数量有多大——大概每小时 1 百万个。这篇文章将介绍我们在处理如此体量的推送通知时所面临的挑战,以及我们的解决方案。


体量大还只是其中的一个方面,在 Gojek,我们还需要面对一些独有的问题。

多个应用程序

Gojek 不只有一个 App,除了用户 App,我们还有 GoLife、司机 App、商家 App,还有服务商 App。



当我们的系统要推送通知,要么是推给某个用户的 App(例如,推给 GoLife 的通知不会被推到 Gojek 上),要么是推给所有的 App(例如促销通知)。


我们的系统需要足够灵活,能够在广播和单独推送之间自由地选择。

多个通知服务提供商

因为我们的用户 App 需要支持 iOS 和 Android 两个平台,所以也需要支持多个通知系统。


Android 平台我们使用了 FCM(Firebase Cloud Messaging)和 GCM(Google Cloud Messaging),iOS 平台我们使用了 APNS(Apple Push Notification Service)。



每一个通知服务提供商都为不同的 App 提供了不同的 API 秘钥和令牌。例如,GoLife 和 Gojek 使用的 FCM API 秘钥就不一样。

一个用户多个设备

我们允许一个用户同时登录多个设备,所以通知需要被推送给用户已登录的所有设备上,这就存在之前的两个问题:


  1. 用户可以在单个设备上登录多个 App(Gojek 和 GoLife);

  2. 用户可能会登录多个设备,每个设备需要使用不同的通知服务提供商。例如,用户可以在 Android 设备和 iOS 设备上登录 Gojek。

多个需要推送通知的服务

Gojek 采用了微服务架构,我们想要让每个服务都能推送通知,不需要操心多设备和多服务提供商问题。



为了解决上述问题,并尽可能保持 API 简单,我们的通知系统被分为三个组件:


  1. 通知服务器——提供通知推送 API,并将通知推送到作业队列中;

  2. 令牌存储——保存已登录用户的设备和设备令牌数据;

  3. 通知处理器——处理作业队列中的消息,并将消息发送给通知服务提供商。



每个组件都解决了上述的一部分问题,接下来,我们来深入介绍这些组件。

令牌存储

用户在登录 App 后,App 会使用设备令牌和 App ID 调用令牌存储 API。



在用户退出时,这些记录会被删除。


令牌存储用于决定向用户的哪些设备推送通知。

通知服务器

这是 HTTP 服务器,提供用于推送通知的 API。


为了简单起见,API 要求把用户 ID 和 App ID 放在 HTTP 头部,把通知信息放在请求体里:


POST http://<base_url>/notificationuser_id: <user_id>application_id: <application_id>{  "payload": {},  "title": "You driver is here",  "message": "Please meet your driver at the pickup point"}
复制代码


服务器从令牌存储获取所有的用户设备信息,然后为每个用户设备安排一个调度作业。


通知服务器为系统提供了外部接口,需要推送通知的服务只要通过用户 ID 来调用它的 API,剩下的事情由通知服务负责处理。

作业队列

我们使用 RabbitMQ 作为作业队列,并为每一种 App ID 和通知类型创建了单独的队列。



分配单独的队列是很重要的,因为我们要为每一种 App 和通知类型做好故障隔离。例如,如果 com.gojek.app 的 FCM 令牌过期,就不会影响到 com.gojek.life 或者 com.gojek.driver.bike 的作业。

通知处理器

处理器进程从作业队列里拉取消息,把它们发送给对应的通知服务提供商。


为了保持代码简单,并能够支持不同的服务提供商,我们定义了统一接口:


type PushService interface {  Push(ctx context.Context, m PushRequest) (PushResponse, error)}
复制代码


Push 方法接收一个请求对象,并返回一个响应对象。


请求对象包含了与接收方和通知(比如过期时间、标题和文本)有关的信息。


type PushRequest struct {  DeviceID   string   Title      string  Message    string  Payload    map[string]interface{}  //其他参数}
复制代码


响应消息里包含了通知是否发送成功的信息:


type PushResponse struct {  Success         bool  ErrorMsg        string}
复制代码


然后为不同的服务提供商实现接口。例如,FCM 和 APNS 对应的实现看起来像下面这样:


type FCMProvider struct {  // 配置信息,比如API令牌和URL端点}func (p *FCMProvider) Push(ctx context.Context, m queue.Message) (notification.PushResponse, error) {  // 发送通知给FCM服务器}type APNSProvider struct {  // 配置信息,比如API令牌和URL端点}func (p *APNSProvider) Push(ctx context.Context, m queue.Message) (notification.PushResponse, error) {  // 发送通知给APNS服务器}
复制代码


通知处理器负责选择对应的通知服务提供商,并将消息发送给它们。

结论

在面对这些挑战时,我们找出其中的一些常用模式,把它们抽离成不同的服务,将一个相对复杂的问题变成了一系列简单且易于管理的服务。


每当一个核心逻辑需要不同的实现时,我们就把它抽离成单独的服务:


  • 多个设备问题通过令牌服务来解决;

  • 多个 App 问题通过统一的通知服务器接口来解决;

  • 多个通知服务提供商通过单独的作业队列和通知处理器来解决。


最终,我们构建了一个每小时能够处理 1 百多万个推送通知的系统。

原文链接

How We Manage a Million Push Notifications an Hour


2019-12-03 11:147670
用户头像
小智 让所有人认同的文字称不上表达

发布了 408 篇内容, 共 402.8 次阅读, 收获喜欢 1986 次。

关注

评论

发布
暂无评论
发现更多内容

你必须得认真体验下 TDengine Cloud 了!抢 600 元体验券

TDengine

数据库 tdengine

电子标准院持续开展低代码开发平台能力评价工作

电子标准院软工研究室

低代码

转换Html(富文本编辑器)到docx的Java工具类

alexgaoyh

html POI 转换 Web 富文本编辑器 docx

针对PDF文档:印章、数字签名、编辑保护、PDF/A的Java工具类

alexgaoyh

数字签名 pdfbox PDF/A 电子印章 受保护禁止编辑

中小企业上本地MES还是云MES比较好?

万界星空科技

生产管理系统 mes 云mes 万界星空科技

抖音API接口:解锁社交电商的创新潜力

Noah

人工智能ChatGPT的多种应用:提示词工程

测吧(北京)科技有限公司

测试

淘宝商品详情API接口:高效处理商品信息,提升工作效率

技术冰糖葫芦

API Explorer API 接口 API 策略 pinduoduo API

借助Historian Connector + TDengine,打造工业创新底座

TDengine

数据库 时序数据库

软件测试学习笔记丨Vue路由-编程式导航

测试人

StarRocks vs. Trino: 高并发性能背后的技术优势是什么?

StarRocks

数据库 大数据

得物SRE K8s 故障诊断:从 CPU 高负载到挂载泄露根源揭示

得物技术

Linux 容器 性能优化 稳定性 企业号2024年6月PK榜

互联网政务应用指那些?怎么过等保?

行云管家

互联网 过等保 互联网政务

XML HttpRequest 入门指南

Liam

JavaScript xml 前端 Web axaj

开源无代码 / 低代码平台 NocoBase 1.0.1-alpha.1: 区块支持高度设置

NocoBase

开源 低代码 无代码开发 低代码开发 无代码

软件测试学习笔记丨Vue路由-嵌套路由

测试人

软件测试

面试官:你讲下接口防重放如何处理?

不在线第一只蜗牛

程序员 面试 接口

百度面试:如何用Redis实现限流?

王磊

Java 面试

MES系统在电线电缆行业生产上的应用

万界星空科技

工业互联网 mes 万界星空科技 电线电缆mes 电线电缆

软件测试学习笔记丨Vue路由-路由重定向

测试人

软件测试

英特尔软硬协同,优化阿里云通义千问2 AI模型

E科讯

2024年吉林等级保护测评机构名单

行云管家

等级保护 等保测评 过等保 吉林

我们是怎么做到每小时推送百万级通知的_架构_Soham Kamani_InfoQ精选文章