如何设计一个 千万用户级的实时订阅消息推送系统?

如何设计一个 千万用户级的实时 订阅消息推送系统
比如说 关注一个主播 主播发文提醒 开播提醒 或者主播视频点赞超过多少 这类 数据源与发送消息的功能不在统一系统
要求要足够通用，并且能抗住大量用户

目前能想到的就是基于ES做召回 但是ES的QPS好像又太低