跳转到主要内容

标签: 交易系统

  • Kafka 在交易系统的削峰与解耦

    发布于 博客 83 字 1 分钟

    Kafka消息队列交易系统架构

    交易系统引入 Kafka 通常出于两个动机:扛住流量尖峰,以及把非核心逻辑从主链路上摘下来。这两件事它都能做,但做法和注意点完全不同。 削峰:把洪峰变成队列 代发工资、批量还款、营销活动这些场景的流量特征是极不均匀——平时每秒几百笔,活动开始瞬间冲到几万笔。数据库扛不住的不是总量,是瞬时并发。 削峰的本质是用延迟换稳定:请求先落 Kafka,下游按自己的处理能力匀速消费。关键是消费端要限速,不能拿到消息就火力全开打数据库。 spring: kafka: consumer: group-id: …

    交易系统引入 Kafka 通常出于两个动机:扛住流量尖峰,以及把非核心逻辑从主链路上摘下来。这两件事它都能做,但做法和注意点完全不同。 削峰:把洪峰变成队列 代发工资、批量还款、营销活动这些场景的流量特征是极不均匀——平时每秒几百笔,活动开始瞬间冲到几万笔。数据库扛不住的不是总量,是瞬时并发。 削峰的本质是用延迟换稳定:请求先落 Kafka,下游按自己的处理能力匀速消费。关键是消费端要限速,不能拿到消息就火力全开打数据库。 spring: kafka: consumer: group-id: …