socket.io-push

整合了小米，华为，友盟，苹果推送的统一解决方案

更有应用内超低延迟顺序(生产环境平均200MS以下)透传功能，支持websocket

广播可支持同频道10w以上在线，每台前端(proxy)可支持5W以上长连接(取决于你的推送量)

16年1月上线运行，目前已经非常稳定，功能完善，我司有数款APP在使用，其中一个日活在500W以上

为什么做这个东西？

我们Java后端开发，以提供HTTP API的方式，做了几个简单的增删改查式的APP，但是在开发一款直播类APP的时候遇到了问题

直播间内的公屏，礼物广播，如何以最低延迟发给直播间内的用户？
频道里都有谁在线？都是哪些人？
主播断线，或者与主播连麦的人断线了，如何知晓？
如何推送离线系统通知（IOS，Android，小米，华为）？

参考其他一些团队的解决方案，大多是用c++写长连接服务器，甚至用Java的netty。开发维护成本太高，所以就有了这套推送系统，我们服务器依旧使用HTTP提供服务，下行推送，也只需要调用一个简单的HTTP接口，如 http://localhost:11001/api/push?topic=abc&json=hello 向abc这个直播间发送一条透传。

特点

厂商通道: 透明集成了小米, 华为push，第三方推送由于政策问题，无法做到
非厂商通道: 友盟推送 + socket.io 双通道客户端sdk去重, 可以享受友盟号称上万APP互相拉起, 大概可以增加非厂商通道50%以上送达率
IOS推送实现了可以部署代理节点, 可以通过国内专线->香港->苹果服务器, 极大提升成功率和吞吐能力
支持浏览器, 微信小程序, Unity3D (完成度很低）
与业务服务同机房部署，第三方服务无法比拟

性能

目前使用的最高日活的一款APP有350W日活, 评估目前架构至少可以支持千万日活APP
可以部署70台(实测)或者更多机器, 支持百万以上同时在线
单机广播速度可以达到10W条/秒，如果只使用系统通知功能，单机支撑一个10W左右日活的APP，平均1W以上同时在线，几乎不占机器负载
从推送接口调用，到客户端收到回包给服务器，RTT只有280m(线上平均延迟)

更新日志

0.9.14 api增加删除设备的接口
0.9.13 支持按uid,pushId查询推送送达率
0.9.12 支持谷歌的fcm推送
0.9.11 去掉apiRouter中的buffer机制，避免拥堵延迟
0.9.10 更新调用华为新版接口(华为开发者后台需要配置apk的sha256指纹)
0.9.9 修复自动重启进程的问题，更新node-apn版本
0.9.7 修正小米notify_foreground配置未生效
0.9.6 修正 push uid ttl未生效
0.9.5 修正notificationBuffer删错方向bug
0.9.4 修正demo后台bug
0.9.3 notfication加个type用于统计
0.9.3 删除redis-adapter一个指数级的调用
0.9.1 重构redis-adapter，优化批量推送大量uid的性能
0.8.97 接口支持post100mb以上数据

基本功能和实现原理

1. push (在线透传）

目标:

pushId: 对某个设备
topic: 已经订阅了某topic的设备列表，订阅关系在redis和socket.io实例里保存，如socket.io服务重启，会丢失，客户端重连上来会自动重新订阅建立关系

uid: 已绑定的设备列表，设备连接后读一次数据库，然后此关系以topic的方式实现

实现原理:

  使用socket.io通道，只针对当时在线，也可以通过制定timeToLive参数实现重传, 无论push给任何目标，只有一次redis pub操作，不走数据库，可靠性，速度非常高

2. notification（手机系统通知栏）

目标:

pushId: 对某个设备
uid: 已绑定的设备列表
tags: 绑定了某tag的设备列表，存储在数据库持久化
pushAll: 推送所有设备

实现原理:

无论给哪个目标发，都要查一次mongodb，用于确定目标设备的类型和token。

ios设备，走苹果apn推送。
小米和华为，走该厂商通道。
其它设备（安卓或者浏览器等）,走socket.io push通道。如有上报umeng token，会调用友盟推送再发一次。安卓客户端有可能收到两次，SDK层做去重保证手机只弹出一次。

Quick Start

高级功能文档

topic相关(用于实现如直播间观众列表，弹幕，礼物，支持同直播间20W人以上在线)
多机器/机房部署
苹果推送代理服务器(用于解决api服务器连接美国网络较差问题)
统计相关

Q&A

相比第三方推送有什么优劣?

优势:

同机房调用, 成功率100% vs 第三方 99.2%(我们调用小米接口成功率) 99.6%(我们调用华为接口成功率)
测试,正式环境,可以分开部署, 完全隔离
支持苹果推送多bundleId, 开发,发布,马甲版, 都可以自动匹配推送
苹果推送进程可以独立部署在香港/国外

劣势

需要自己运维部署服务器
如果需要扩容, 需要自己来评估, 第三方推送通常是给钱就可以了 =======

名词

push-server 推送服务器, 提供客户端长连接, http api接口
业务服务器 push-server api的调用方
客户端 业务app服务器
长连接 客户端到push-server之间的socket.io连接
notification 发送通知栏消息, ios走apns通道, 华为,小米走厂商通道(如配置开启), 浏览器/android手机走长连接
push 协议透传, 走长连接通道. app主进程存活的时候才能收到.主要应用场景如直播间聊天,送礼物,股价实时推送
topic 服务器push广播的对象,类似于直播间/频道的概念, 客户端进入某直播间(id=001)后(topic="room001"),业务服务器可以向此topic发聊天push,subscribe了这个topic的客户端即可收到push
pushId 某个设备的唯一标识, app安装后生成的随机字符串, 用于服务器单播
uid 业务服务器用于标识某个用户的id,字符串类型.可以通过push-server的接口进行绑定,通过客户端SDK解除绑定
timeToLive 过期时间

socket.io-push-redis
Release 1.0.6

Release 1.0.6

1.0.10

1.0.9

1.0.8

1.0.7

1.0.6

1.0.5

1.0.4

1.0.3

1.0.2

1.0.1

Documentation