消息队列和常规消息队列概述

By in 365bet是什么 on 2019年12月11日

首先,对消息队列(MQ)进行一般描述

MessageQueue(MessageQueue)是分布式系统的重要组件。典型的使用场景可以简要描述如下:

如果您不需要立即获得结果,而是需要控制并发量,那么该使用消息队列了。

消息队列主要解决诸如应用程序绑定,异步处理和流量调整之类的问题。

当前使用的消息队列包括RabbitMQ,RocketMQ,ActiveMQ,Kafka,ZeroMQ,MetaMq,并且某些数据库(例如Redis,Mysql和phxsql)可以实现消息队列功能。

二,消息队列使用场景

消息队列包括以下四种用于实际应用程序的方案:

应用程序耦合:多个应用程序之间的消息队列处理同一条消息,避免了调用接口故障,并使整个过程失败。

异步处理:多个应用程序处理消息队列中的同一消息,并在应用程序之间同时处理消息,与串行处理相比,减少了处理时间。

当前有限的峰值削减:广泛用于特定或补充活动,以避免应用程序系统由于流量过大而崩溃的情况。

消息驱动的系统:系统分为消息队列,消息生产者和消息使用者,其中生产者负责生成消息,而使用者负责处理消息。

详细介绍以下四个方案以及在前四个方案中如何使用消息队列。

2)

1异步处理

特定情况:要使用该应用程序进行注册,系统需要发送注册电子邮件并验证SMS。

有两种方法可以处理这两个操作:串行和并行。

(1)串行模式:生成新的注册信息后,首先发送注册电子邮件,然后发送确认短信。

这样,必须发送最后的确认SMS并将其返回给客户端。

(2)并行处理:在写入新的注册信息之后,并行发送文本消息和电子邮件以进行处理。

此方法涉及在将文本消息和电子邮件返回给客户之前先对其进行处理。

假定前三个子系统处理的时间为50毫秒,并且不考虑网络延迟,则总处理时间为:


Comments are closed.