美文网首页
异步消费者模式

异步消费者模式

作者: Cheava | 来源:发表于2018-12-08 20:41 被阅读7次

提供一个最长 flush time,以及一个队列最长长度,
如果到这个时间阈值,队列还没满,那么直接清空队列进行消费
如果还没到时间阈值,队列满了,就直接清空队列进行消费
需要考虑消费者过慢的问题,提供多个消费者,在多个线程中进行消费,避免 block
有很多实现方式,参考ElasticSearch 的 BulkProcessor

相关文章

网友评论

      本文标题:异步消费者模式

      本文链接:https://www.haomeiwen.com/subject/uvlchqtx.html