1.什么是MQ?
MQ是Message Queue(消息队列)的简称,队列是一种先进先出的数据结构,队列当中存储的就是消息,消息的类型可以是文本字符串、JSON、内嵌对象、byte。
消费者可以消费消息,消费一个消息队列就会删除一个消息,提供者可以提供消息,提供一个消息队列就会增加一个消息。当大量消息存储在队列当中且未被消费时,这就是我们说的消息堆积。
2.为什么要使用MQ?
应用解耦:在项目启动之初来预测将来会碰到什么需求是极其困难的。消息中间件在处理过程中间插入了一个隐含的、基于数据的接口层，两边的处理过程都要实现这一接口，这允许你独立地扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束即可。
冗余（存储）：有些情况下，处理数据的过程会失败。消息中间件可以把数据进行持久化直到它们已经被完全处理，通过这一方式规避了数据丢失风险。在把一个消息从消息中间件中删除之前，需要你的处理系统明确地指出该消息已经被处理完成，从而确保你的数据被安全地保存直到你使用完毕。
提高扩展性：因为消息中间件解耦了应用的处理过程，所以提高消息入队和处理的效率是很容易的，只要另外增加处理过程即可，不需要改变代码，也不需要调节参数。
削峰填谷：在访问量剧增的情况下，应用仍然需要继续发挥作用，但是这样的突发流量并不常见。如果以能处理这类峰值为标准而投入资源，无疑是巨大的浪费。使用消息中间件能够使关键组件支撑突发访问压力，不会因为突发的超负荷请求而完全崩溃。
可恢复性：当系统一部分组件失效时，不会影响到整个系统。消息中间件降低了进程间的耦合度，所以即使一个处理消息的进程挂掉，加入消息中间件中的消息仍然可以在系统恢复后进行处理。
顺序保证：在大多数使用场景下，数据处理的顺序很重要，大部分消息中间件支持一定程度上的顺序性。
缓冲：在任何重要的系统中，都会存在需要不同处理时间的元素。消息中间件通过一个缓冲层来帮助任务最高效率地执行，写入消息中间件的处理会尽可能快速。该缓冲层有助于控制和优化数据流经过系统的速度。
异步通信：在很多时候应用不想也不需要立即处理消息。消息中间件提供了异步处理机制，允许应用把一些消息放入消息中间件中，但并不立即处理它，在之后需要的时候再慢慢处理。
3.RabbitMQ介绍及特点
RabbitMQ是采用Erlang语言实现AMQP（Advanced Message Queuing Protocol，高级消息队列协议）的消息中间件，它最初起源于金融系统，用于在分布式系统中存储转发消息。
可靠性:RabbitMQ使用一些机制来保证可靠性，如持久化、传输确认及发布确认等。
灵活的路由:在消息进入队列之前，通过交换器来路由消息。对于典型的路由功能，RabbitMQ已经提供了一些内置的交换器来实现。针对更复杂的路由功能，可以将多个交换器绑定在一起，也可以通过插件机制来实现自己的交换器。
扩展性:多个RabbitMQ节点可以组成一个集群，也可以根据实际业务情况动态地扩展集群中节点。
高可用性:队列可以在集群中的机器上设置镜像，使得在部分节点出现问题的情况下队列仍然可用。
多种协议:RabbitMQ除了原生支持AMQP协议，还支持STOMP、MQTT等多种消息中间件协议。
多语言客户端:RabbitMQ几乎支持所有常用语言，比如Java、Python、Ruby、PHP、C＃、JavaScript等。
管理界面:RabbitMQ提供了一个易用的用户界面，使得用户可以监控和管理消息、集群中的节点等。
插件机制:RabbitMQ提供了许多插件，以实现从多方面进行扩展，当然也可以编写自己的插件。
相比较其他同类MQ,RabbitMQ最大优势在于消息延迟低(微妙级),由于采用Erlang语言开发在高并发场景也有不俗的表现。
4.Linux系统安装RabbitMQ
4.1 安装ErLang
由于RabbitMQ是erlang语言开发的,所以先安装erlang,先去RabbitMQ官网了解与RabbitMQ兼容的erlang版本,这里我用的erlang版本是23.1
(1).准备环境:
yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel
(2).解压安装erlang安装包并进入
cd otp_src_23.1
(3).设定安装规则:
#安装路径位于/usr/local/erlang下
./configure --prefix=/usr/local/erlang --with-ssl --enable-threads --enable-smp-support --enable-kernel-poll --enable-hipe --without-javac
(4).安装:
make && make install
(5).添加erlang环境变量
#打开环境变量配置文件
vim /etc/profile
#往配置文件加入以下内容
ERL_PATH=/usr/local/erlang/bin
PATH=$ERL_PATH:$PATH
#加完了使用以下命令使环境变量配置文件立马生效
source /etc/profile
#终端输入以下命令测试,出版本则说明安装成功了
erl
#退出erlang shell
halt().
4.2 安装Rabbitmq-server
(1).下载rabbimq-server安装包并解压
(2).添加环境变量
#编辑环境变量配置文件
vim /etc/profile
#加入以下内容,rabbitmq_server的安装路径在/home/package/rabbitmq_server-3.8.9
PATH=$PATH:/home/package/rabbitmq_server-3.8.9/sbin
#重载环境变量
source /etc/profile
# 添加web管理插件
rabbitmq-plugins enable rabbitmq_management
#独立启动服务
rabbitmq-server -detached
(3).访问RabbitMQ管理面板。浏览器输入ip:+15672。账号:guest,密码:guest
4.3 rabbitmq常用命令
#启动服务
rabbitmq-server -detached
#停止服务
rabbitmqctl stop
#查看插件列表
rabbitmq-plugins list
#启用插件
rabbitmq-plugins enable 插件名
#停用插件
rabbitmq-plugins disable 插件名
#添加用户
rabbitmqctl add_user 用户名 密码
#删除用户
rabbitmqctl delete_user 用户名
#修改用户密码
rabbitmqctl change_password 用户名 新的密码
#列出所有用户
rabbitmqctl list_users
#查看所有用户权限
rabbitmqctl list_permissions
5.Docker安装RabbitMQ
docker安装rabbitmq命令:
docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
若有收获，就点个赞吧
0 人点赞
