请教一下kotlin处理back pressure的事项


#1

现在有三种选择,kotlin协程,spring家的reactor,vertx

大概场景如下

上游消息可能会段时间内增多,但是下游服务需要低频处理这些消息(比如每秒10次),上游消息丢掉没关系

消息来源可能是http服务或者mq消息

请问用协程如何处理呢?channel?flow?


#2

flow把 主要是你要求下游处理来不及可以丢弃 这个应该不能称之为背压把
flow可以用conflate()拒绝旧任务未处理完时来的新任务,这种应该符合你的需求


京ICP备16022265号-2 Kotlin China 2017 - 2018