基于 RabbitMQ 和 Kafka 的异步后端

我设计并构建异步的、事件驱动的后端，使服务彼此独立，能够抵御故障并准备应对增长的负载。当请求不需要等待所有下游步骤完成时，您的 API 保持快速，后台工作以自己的节奏进行。首先，我建模消息流：哪些事件重要，谁发布它们，谁消费它们，以及在出错时应该发生什么。使用这个模型，我在 RabbitMQ 或 Kafka 中构建真实的拓扑，使用清晰的名称、深思熟虑的路由和每个队列和主题的明确责任。

在 RabbitMQ 中，我为您的实际路由配置交换、队列和绑定，然后编写正确确认消息的工作者，合理使用预取，并在重启时不丢失数据。我添加了一个具有指数退避的重试策略，针对卡住消息的死信交换，以及幂等处理程序，以便重新投递不会导致重复收费或重复发送。对于高流量流，我使用 Kafka：分区主题、消费者组、偏移管理和历史重放，以便您在部署新功能后可以重新处理数据。无论哪种方式，我都专注于背压、排序保证和在负载下的行为，而不仅仅是理想场景。

您获得的后台处理能够承受高峰和故障：重任务、通知、集成和数据管道通过代理流动，而不是阻塞用户。我提供清晰的流程图、经过测试的生产者和消费者、健康检查、指标和仪表板，以及用于值班的事件处理手册。我可以扩展现有系统或从头开始构建一个，提供完整的文档，以便您的团队能够自信地进一步开发解决方案。

— 拓扑设计：交换、队列、主题、分区
— 可靠的工作者：确认、预取、重试、死信
— 在实际负载下的幂等性、排序和背压
— 监控、警报和生产运行手册