3.流量控制
消息中间件可以设置流量控制,当消息流量过大时,可以暂停消息的发送,等到流量下降时再继续发送,从而平滑地处理流量峰值。
4.日志处理
消息中间件需要对关键信息进行日志记录和处理,以便于监控和追踪系统运行情况,发现潜在问题,优化系统性能。
消息中间件原理消息中间件通常由生产者(Producer)、消息队列(Message Queue)、消费者(Consumer)三部分组成。
如下图所示:
上图为整体架构会涉及三类角色:
- 生产者:将消息发送到消息队列中;
- 消费者:从消息队列中获取消息并进行处理;
- 消息队列:作为消息传递的桥梁,负责存储和管理消息;
消息中间件提供多种消息传递模式如点对点模式和发布/订阅模式等。
1.点对点模型
在点对点模式中,生产者将消息发送到一个特定的消息队列中,消息队列只会将消息传递给一个消费者进行处理。
也就是说,一个消息只能被一个消费者处理,这种模式也称为队列模式(Queue Mode)。
如下图所示: