现在有三种选择，kotlin协程，spring家的reactor，vertx
大概场景如下
上游消息可能会段时间内增多，但是下游服务需要低频处理这些消息（比如每秒10次），上游消息丢掉没关系
消息来源可能是http服务或者mq消息
请问用协程如何处理呢？channel？flow？
现在有三种选择，kotlin协程，spring家的reactor，vertx
大概场景如下
上游消息可能会段时间内增多，但是下游服务需要低频处理这些消息（比如每秒10次），上游消息丢掉没关系
消息来源可能是http服务或者mq消息
请问用协程如何处理呢？channel？flow？