来源:http://t.cn/EbxTHT5
消息队列是服务架构中常见的组件,可用于服务间解耦、事件广播、任务异步/延迟处理等,本文对于消息队列的实现如何满足几种消费语义进行了阐述。
img
为了支持上面3种消费语义,可以分3个阶段考虑消息队列系统中Producer、Message Broker、Consumer需要满足的条件:
该语义是最容易满足的,特点是整个消息队列吞吐量大,实现简单。适合能容忍丢消息,消息重复消费的任务。
适合不能容忍丢消息,允许重复消费的任务。
适合对消息消费情况要求非常高的任务,实现较为复杂。
在这里需要考虑一个问题,就是这里的“仅被消费一次”指的是如下哪种场景:
Message Broker上存储的消息被Consumer仅消费一次 场景要求:
Producer上产生的消息被Consumer仅消费一次 场景要求:
现在业内已经有许多成熟的消息队列的实现了,对于选择用哪一个实现,可以先根据业务需要支持的消费语义进行初步筛选,之后再根据运维难度、社区活跃度、性能、可用性等综合考虑选择合适的消息队列系统,如何判断一个消息队列实现是否支持某个消费语义,根据本文中阐述的3个阶段去判断即可。