消息/通知系统架构

我们正在进行一个项目来构建一个像Gmail/whatsapp这样的分布式消息和通知系统。

目前我有一些缩放和性能问题。 我们的架构在kafa消息代理中丢弃消息。消息负载具有消息正文和收件人/组。 监听器然后检查消息,然后根据收件人进入数据库。

创建在数据库中插入数百万条记录的活动效率不高,而且会浪费时间,并根据代理中的消息堆积起来。这会导致邮件的非常规传递时间段。

有人能告诉我如何解决这个问题吗。

我一直很好奇gmail/whatsapp的架构是怎样的,以及他们能在多短的时间内将他们的信息即时传递给1亿用户。