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