RabbitMQ简介以及基于windows的安装
文章目录
一。消息中间件概述
1.什么是消息中间件?
MQ全称为Message Queue,消息队列是应用程序和应用程序之间的通信方法。
为什么要使用MQ?
在项目中,可将一些无需即时返回且耗时的操作提取出来,进行异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。
2.应用场景
1、任务异步处理
将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。提高了应用程序的响应时间。
2、应用程序解耦合
MQ相当于一个中介,生产方通过MQ与消费方交互,它将应用程序进行解耦合。
3、削峰填谷
如订单系统,在下单的时候就会往数据库写数据。但是数据库只能支撑每秒1000左右的并发写入,并发量再高就容易宕机。低峰期的时候并发也就100多个,但是在高峰期时候,并发量会突然激增到5000以上,这个时候数据库肯定卡死了。
消息被MQ保存起来了,然后系统就可以按照自己的消费能力来消费,比如每秒1000个数据,这样慢慢写入数据库,这样就不会卡死数据库了。
但是使用了MQ之后,限制消费消息的速度为1000,但是这样一来,高峰期产生的数据势必会被积压在MQ中,高峰就被“削”掉了。但是因为消息积压,在高峰期过后的一段时间内,消费消息的速度还是会维持在1000QPS,直到消费完积压的消息,这就叫做“填谷”
二。AMQP 和 JMS
MQ是消息通信的模型;实现MQ的大致有两种主流方式:AMQP、JMS。
1.AMQP
AMQP是一种协议,更准确的说是一种binary wire-level protocol(链接协议)。这是其和JMS的本质差别,AMQP不从API层进行限定,而是直接定义网络交换的数据格式。
2.JMS
JMS即Java消息服务(JavaMessage Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。
3.AMQP 与 JMS 区别
- JMS是定义了统一的接口,来对消息操作进行统一;AMQP是通过规定协议来统一数据交互的格式
- JMS限定了必须使用Java语言;AMQP只是协议,不规定实现方式,因此是跨语言的。
- JMS规定了两种消息模式;而AMQP的消息模式更加丰富
4.消息队列产品
市场上常见的消息队列有如下:
- ActiveMQ:基于JMS
- ZeroMQ:基于C语言开发
- RabbitMQ:基于AMQP协议,erlang语言开发,稳定性好
- RocketMQ:基于JMS,阿里巴巴产品
- Kafka:类似MQ的产品;分布式消息系统,高吞吐量
四。RabbitMQ
RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。
RabbitMQ官方地址:http://www.rabbitmq.com/
RabbitMQ提供了6种模式:
- 简单模式
- work模式
- Publish/Subscribe发布与订阅模式
- Routing路由模式
- Topics主题模式
- RPC远程调用模式
官网对应模式介绍:https://www.rabbitmq.com/getstarted.html
五。RabbitMQ基于Windows的安装与配置
RabbitMQ的安装需要有Elang环境的支持,所以我们需要先安装Elang
1.安装Erlang
1.官方地址:https://www.erlang.org/,选择自己的版本号进行下载,我这里选择的是windows 64位的:
2.下载完成后打开安装包,一直跟着下一步安装即可:
3.安装完成后添加系统变量ERLANG_HOME,值为安装目录:
4.编辑Path变量,新增值为%ERLANG_HOME%\bin:
5.打开命令行,输入erl,出现对应的版本号则说明安装成功:
2.安装RabbitMQ
官方地址:https://github.com/rabbitmq/rabbitmq-server/releases/v3.8.3/,选择自己的版本号进行下载,我这里选择的是3.8.3:
2.下载完成后打开安装包,一直跟着下一步安装即可:
3.安装完成后进入安装目录的sbin目录,在地址栏输出cmd,回车,以命令行的方式进入该目录下:
4.执行命令rabbitmq-plugins enable rabbitmq_management
,安装三个插件:(由于我之前安装好了,所以没有重新下载)
5.下载完成后,将出现以下三个插件:
6.访问网址:http://localhost:15672/,默认用户名:guest,密码:guest
7.登录成功出现RabbitMQ管控台,说明RabbitMQ安装成功: