教育行业A股IPO第一股(股票代码 003032)

全国咨询/投诉热线:400-618-4000

什么是消息队列?消息队列有哪些应用场景?

更新时间:2021年09月28日17时40分 来源:传智教育 浏览次数:

好口碑IT培训

消息队列,英文名:Message Queue,经常缩写为MQ。从字面上来理解,消息队列是一种用来存储消息的队列。来看一下下面的代码:

// 1. 创建一个保存字符串的队列
Queue<String> stringQueue = new LinkedList<String>();
// 2. 往消息队列中放入消息
stringQueue.offer("hello");
// 3. 从消息队列中取出消息并打印
System.out.println(stringQueue.poll());

上述代码,创建了一个队列,先往队列中添加了一个消息,然后又从队列中取出了一个消息。这说明了队列是可以用来存取消息的。我们可以简单理解消息队列就是将需要传输的数据存放在队列中。

消息队列中间件是用来存储消息的软件(组件)。举个例子来理解,为了分析网站的用户行为,我们需要记录用户的访问日志。这些一条条的日志,可以看成是一条条的消息,我们可以将它们保存到消息队列中。将来有一些应用程序需要处理这些日志,就可以随时将这些消息取出来处理。

目前市面上的消息队列有很多,例如:Kafka、RabbitMQ、ActiveMQ、RocketMQ、ZeroMQ等。

消息队列的应用场景

1.异步处理
电商网站中,新的用户注册时,需要将用户的信息保存到数据库中,同时还需要额外发送注册的邮件通知、以及短信注册码给用户。但因为发送邮件、发送注册短信需要连接外部的服务器,需要额外等待一段时间,此时,就可以使用消息队列来进行异步处理,从而实现快速响应。

1632821588139_消息队列0.png

2.系统解耦

1632821593973_消息队列2.png

如果库存系统出现问题,会导致订单系统下载失败。而且如果库存系统接口修改了,会导致订单系统也无法工作。

使用消息队列可以实现系统与系统之间的解耦,订单系统不再调用库存系统接口,而是把2订单消息写入到消息队列。库存系统从消息系统中拉取消息,然后再减库存,从而实现系统解耦。

3.流量削峰

1632821599471_消息队列3.png

4.日志处理(大数据领域常见)

大型电商网站(淘宝、京东、国美、苏宁...)、App(抖音、美团、滴滴等)等需要分析用户行为,要根据用户的访问行为来发现用户的喜好以及活跃情况,需要在页面上收集大量的用户访问信息。

1632821605585_消息队列4.png

5.生产者、消费者模型

我们之前学习过Java的服务器开发,Java服务器端开发的交互模型是这样的:

1632821612883_消息队列.png

我们之前也学习过使用Java JDBC来访问操作MySQL数据库,它的交互模型是这样的:

1632821620663_消息队列6.png

它也是一种请求响应模型,只不过它不再是基于http协议,而是基于MySQL数据库的通信协议。

而如果我们基于消息队列来编程,此时的交互模式成为:生产者、消费者模型。

1632821627384_消息队列7.png



猜你喜欢:

kafka自定义拦截器实例教程[传智教育]

Django如何给客户端推送消息?App推送怎样实现?

为什么选择kafka采集数据?

消息中间件常用协议有哪些?

传智教育python大数据开发培训

0 分享到:
和我们在线交谈!