用 Project Reactor 的 bufferTimeout 代替 BufferTrigger 做高并发计数聚合
用 Project Reactor 的 bufferTimeout 代替 BufferTrigger 做高并发计数聚合 记录一次在计数服务里做「粉丝数聚合写」的实现。原教程用快手的 BufferTrigger,我改用了 Spring Boot 自带的 Project Reactor,零新增依赖。 背
Reactive-Stream规范
Reactive-Stream规范 传统的数据处理模式是生产者主动推送。如下图所示: 生产者(Producer):图左侧的“生产者”代表数据源。它拥有“巨大”或“大量”的数据,并以 10000w/s 的高速度源源不断地产生请求。 消费者(Consumer):图右侧的方框代表消费者,即处理这些数据的服