为什么需要使用消息队列?
复杂系统重,多个模块或服务之间会相互依赖,如果直接使用调用函数或 API 调用的方式,会极大的造成模块或服务之间的耦合,当其中一个模块发生改变时,需要同时修改调用者和被调用者的代码。如果使用消息队列作为中间件的话,不同的模块可以将消息发送到消息队列中,就不需要知道具体的接收方是谁,接收方只需独立的消费消息就可以了,从而实现了模块之间的解耦。在系统高负载的时候,使用消息队列作为缓冲区,将消息放入消息
·
关键回答
解耦、异步、削峰填谷
-
解耦:复杂系统重,多个模块或服务之间会相互依赖,如果直接使用调用函数或 API 调用的方式,会极大的造成模块或服务之间的耦合,当其中一个模块发生改变时,需要同时修改调用者和被调用者的代码。如果使用消息队列作为中间件的话,不同的模块可以将消息发送到消息队列中,就不需要知道具体的接收方是谁,接收方只需独立的消费消息就可以了,从而实现了模块之间的解耦。
-
异步:系统服务中有些操作会比较耗时,例如:发送邮件、生成报表,如果使用同步的方式处理,会阻塞主线程或进程,导致系统的性能下降。如果使用消息队列的话,就可以将这些操作封装为消息,放入消息队列中,异步的处理这些操作,从而不影响主流程的执行。
-
削峰填谷:削峰填谷是一种在高并发场景下平衡系统压力的技术,同时用于平衡系统高峰期和低峰期的资源利用率。在系统高负载的时候,使用消息队列作为缓冲区,将消息放入消息队列,然后再系统低负载的时候进行处理,进而将系统高峰期时的压力分散到较长的时间段内。
消息队列优点
- 可靠性高:可以实现消息的持久化存储、消息的备份和故障恢复等功能,保证消息不会丢失。
- 扩展性好:可以通过增加消息队列实例或者添加消费者实例,实现消息队列的水平扩展,提高系统的处理能力。
- 灵活性高:消息队列通常支持多种消息传递模式,点对点、发布/订阅模式。
常见的消息队列
- kafka
- activeMQ
- RabbitMQ
- RocketMQ
更多推荐
所有评论(0)