首页 > 解决方案 > 消息/通知系统架构

问题描述

我们正在开发一个项目来构建一个分布式消息和通知系统,例如 Gmail /whatsapp。

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

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

谁能指导我如何解决这个问题。

我总是对 gmail / whatsapp 架构的原理很感兴趣,他们能够在多长时间内立即将消息传递给数以亿计的用户。

标签: push-notificationnotificationsapache-kafkareliable-message-delivery

解决方案


推荐阅读