当前位置： 首页 > news >正文

RabbitMq入门之概括

news 2025/10/3 13:42:32

在这里插入图片描述

1.概念：

1、消息队列

MQ全称Message Queue（消息队列）。是在消息的传输过程中保存消息的容器。多用于系统之间的异步通信

Ps:同步通信和异步通信的概念

  • 同步通信：相当于两个人之间你一言我一语，你说一句我回复一句这种
  • 异步通信：相当于有第三方记录双方的问题，类似于中介，但不需要两人随时保持联系。

2、消息

两台计算机之间传送的数据单位，消息可以非常简单，例如只包含文本字符串。

3、队列

在数据结构的概念中，队列遵循先进先出后进后出。

2、MQ的优势

应用解耦、异步提速、削峰填谷。

1、应用解耦

例如，在电商平台中，用户下订单的全过程需要订单系统、库存系统、支付系统和物流系统，这时候就会产生两个问题：

  • 如果库存系统出现故障，会导致整个系统的故障
  • 如果需求有需求，新增一个A系统，此时就必须修改订单系统的代码。

相当于，系统耦合性越高，容错性和可维护性就越低。此时在系统中引入MQ，订单系统将消息先发送到MQ中，再由MQ转发给其他系统，则会解决以下问题：

  • 如果订单系统只发消息给MQ，不直接对接其他系统，通过MQ分发消息，如果订单系统出现故障，不会影响其他的业务。
  • 如果需求更改，新增了一个A系统，此时无需修改订单系统的代码，只要修改MQ将消息发送给A系统。

2、异步提速

举一个流程的例子，

同步：如果同步调用的话走完整个流程需要20+300+300+300=620ms

引入MQ，异步调用：引入MQ之后，通过消息分发一套流程下来只需要20+5=25ms;

在这里插入图片描述

3、削骨填峰

​ 假设我们的系统每秒只能承载1000个请求，如果请求在一瞬间加到5000，则会造成系统崩溃，此时引入MQ即可解决这个问题，具体解决方法如下：

​ 使用MQ之后，速度限制在1000，这样一来，高峰的数据全部存储在MQ中，这个叫做削峰，通过MQ，高峰就被削掉了，直到消费完积压的库存。这个就叫做填谷

3、MQ的劣势：

1、系统可用性降低

​ 系统引入的外部依赖越多，系统稳定性越差。一旦MQ宕机，就会对业务造成影响。

2、系统复杂度提高

​ MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过MQ进行异步调

用。

3、一致性问题

​ A系统处理完业务，通过MQ给B、C、D三个系统发消息数据，如果B系统、C系统处理成功，D系

统处理失败，则会造成数据处理的不一致。

4、MQ应用场景

1、抢红包、秒杀活动、抢火车票等

这些业务场景都是短时间内需要处理大量请求，如果直接连接系统处理业务，会耗费大量资源，有可能造成系统瘫痪。

而使用MQ后，可以先让用户将请求发送到MQ中，MQ会先保存请求消息，不会占用系统资源，且MQ会进行消息排序，先请求的秒杀成功，后请求的秒杀失败。.

2、消息分发

如电商网站要推送促销信息，该业务耗费时间较多，但对时效性要求不高，可以使用MQ做消息分发。

在这里插入图片描述

3、数据同步

​ 假如我们需要将数据保存到数据库之外，还需要一段时间将数据同步到缓存（如Redis）、搜索引擎（如Elasticsearch）中。此时可以将数据库的数据作为消息发送到MQ中，并同步到缓存、搜索引擎中。

在这里插入图片描述

4、异步处理

​ 在电商系统中，订单完成后，需要及时的通知子系统（进销存系统发货，用户服务积分，发送短信）进行下一步操作。为了保证订单系统的高性能，应该直接返回订单结果，之后让MQ通知子系统做其他非实时的业务操作。这样能保证核心业务的高效及时。

在这里插入图片描述

5、离线处理

​ 在银行系统中，如果要查询近十年的历史账单，这是非常耗时的操作。如果发送同步请求，则会花费大量时间等待响应。此时使用MQ发送异步请求，等到查询出结果后获取结果即可。

在这里插入图片描述

5、AMQP

RabbitMQ是由Erlang语言编写的基于AMQP的MQ产品。

1、AMQP

​ 即Advanced Message Queuing Protocol(高级消息队列协议)，是一个网络协议，专门为消息中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受不同中间件产品，不同开发语言等条件的限制。2006年AMQP规范发布，类比HTTP。

2、AMQP工作过程

​ 生产者(Publisher)将消息发布到交换机(Exchange)，交换机根据规则将消息分发给交换机绑定的队列(Queue)，队列再将消息投递给订阅了此队列的消费者。

在这里插入图片描述

6、RabbitMQ工作原理

在这里插入图片描述

Producer

消息的生产者。也是一个向交换机发布消息的客户端应用程序。

Connection

连接。生产者/消费者和RabbitMQ服务器之间建立的TCP连接。

Channel

信道。是TCP里面的虚拟连接。例如：Connection相当于电缆，Channel相当于独立光纤束，一条TCP连接中可以创建多条信道，增加连接效率。无论是发布消息、接收消息、订阅队列都是通过信道完成的。

Broker

消息队列服务器实体。即RabbitMQ服务器

Virtual host

虚拟主机。出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中。每个vhost本质上就是一个mini版的RabbitMQ服务器，拥有自己的队列、交换机、绑定和权限机制。当多个不同的用户使用同一个RabbitMQ服务器时，可以划分出多个虚拟主机。RabbitMQ默认的虚拟主机路径是Exchange交换机。用来接收生产者发送的消息，并根据分发规则，将这些消息分发给服务器中的队列中。不同的交换机有不同的分发规则。

Queue

消息队列。用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。消息一直在队列里面，等待消费者链接到这个队列将其取走。

Binding

消息队列和交换机之间的虚拟连接，绑定中包含路由规则，绑定信息保存到交换机的路由表中，作为消息的分发依据。

Consumer

消息的消费者。表示一个从消息队列中取得消息的客户端应用程序。

  • RabbitMQ为什么使用信道而不直接使用TCP连接通信？

​ TCP连接的创建和销毁开销特别大。创建需要3次握手，销毁需要4次分手。高峰时每秒成千上万条TCP连接的创建会造成资源巨大的浪费。而且操作系统每秒处理TCP连接数也是有限制的，会造成性能瓶颈。而如果一条线程使用一条信道，一条TCP链接可以容纳无限的信道，即使每秒成千上万的请求也不会成为性能的瓶颈。

7、RabbitMQ安装 安装Erlang

​ RabbitMQ是使用Erlang语言编写的，所以在安装RabbitMQ前需要先安装Erlang环境。

  • 安装Erlang所需的依赖 yum install -y epel-release

  • 添加存储库条目

    get https://packages.erlang-
solutions.com/erlang-solutions-1.0-
1.noarch.rpm
rpm -Uvh erlang-solutions-1.0-1.noarch.rpm

  • 安装Erlangyum install erlang-24.2.1

  • 查看Erlang是否安装成功 erl -version

8、安装RabbitMQ

  • 为了外部能够正常访问RabbitMQ服务，先关闭防火墙

    # 关闭运行的防火墙
systemctl stop firewalld.service
# 禁止防火墙自启动
systemctl disable firewalld.service

  • rabbitMQ是通过主机名进行访问的，必须给服务器添加主机名

    # 修改文件
vim /etc/sysconfig/network # 添加如下内容
NETWORKING=yes
HOSTNAME=yjk
# 修改文件
vim /etc/hosts
# 添加如下内容
服务器ip yjk

  • 使用rz命令上传RabbitMQ压缩文件

  • 安装RabbitMQ

# 解压RabbitMQ
tar xf rabbitmq-server-generic-unix-3.9.13.tar.xz
# 重命名：
mv rabbitmq_server-3.9.13 rabbitmq
# 移动文件夹：
mv rabbitmq /usr/local/
  • 配置环境变量
# 编辑/etc/profile文件
vim /etc/profile
#添加如下内容
exportPATH=$PATH:/usr/local/rabbitmq/sbin
# 运行文件，让修改内容生效source /etc/profile
  • 开启管控台插件
rabbitmq-plugins enable 
rabbitmq_management
  • 后台运行
#启动rabbitmq
rabbitmq-server -detached
#停止rabbitmq
rabbitmqctl stop
  • 通过管控台访问RabbitMQ
路径：http://ip地址:15672,用户名：guest 密码：guest

  • 此时会提示guest账户只允许本地使用，我们可以配置允许使用guest远程访问

    # 创建配置文件夹
mkdir-p /usr/local/rabbitmq/etc/rabbitmq # 创建配置文件
vim
/usr/local/rabbitmq/etc/rabbitmq/rabbitmq.conf
# 添加如下内容
loopback_users=none
# 重启RabbitMQ
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

9、RabbitMQ安装 账户管理

guest账户默认只允许本地使用，我们可以创建新账户远程访问RabbitMQ

  • 创建账户
# 创建账户
rabbitmqctl add_user 用户名密码
  • 给用户授予管理员角色
rabbitmqctl set_user_tags 用户名
administrator
  • 给用户授权
# "/"表示虚拟机
# guest表示用户名
# ".*" ".*" ".*" 表示完整权限
rabbitmqctl set_permissions -p"/"guest".*"".*"".*"
  • 通过管控台访问rabbitmq

10、RabbitMQ安装管控台

在这里插入图片描述
在这里插入图片描述

#11 、RabbitMQ安装Docker安装

  • 关闭RabbitMQ服务
rabbitmqctl stop
  • 在Centos7中安装docker
# 安装Docker
curl-fsSL https://get.docker.com | bash-s docker --mirror Aliyun
# 启动docker
systemctl start docker
  • 拉取镜像
docker pull rabbitmq
  • 启动RabbitMQ容器
docker run -d--hostname guest--name rabbit -p15672:15672 -p5672:5672
rabbitmq
  • 开启管控台插件
# 查询rabbitmq容器ID
docker ps  
# 进入容器
docker exec -it容器ID /bin/bash # 开启管控台插件
rabbitmq-plugins enable
rabbitmq_management
# 退出容器
ctrl+q
  • 通过管控台访问rabbitmq
路径：http://ip地址:15672 用户名：guest 密码：guest
  • 关闭RabbitMQ容器
docker stop rabbit
http://www.dtcms.com/a/436060.html

相关文章：

  • 山西营销网站建设那个公司好上海百度seo
  • 经验分享：如何通过SAP HANA数据库优化将SAP B1性能提升50%
  • 免费注册域名邮箱龙岗优化网站建设
  • 如何通过cpa网站做推广产品展厅柜设计公司
  • 机器视觉滤光片怎么选？
  • 韶关市建设与房地产信息网站营销排名seo
  • 波音网站开发php网站开发用什么ide
  • 电子商务网站功能设计与分析微信社群营销怎么做
  • 运城手机网站制作郑州高端设计公司
  • 音乐网站建设规划第1ppt模板免费下载
  • 如何对网站进行分析网站开发合作
  • GUI自动化之pywinauto
  • 杭州网站设计费用app软件下载入口
  • 网站建设php教程建设一个好的网站
  • 遵义网站建设找工作百安居装修口碑怎么样
  • 用别人的网站视频做app网站建设文字设计
  • 网站建设推广兼职地推一手项目平台
  • 网站建设和安全管理制度html5制作网页的代码
  • C++类和对象（1）
  • 嵌入式开发学习日志32——stm32之PWM
  • 数据结构 之 【图的最短路径】(Dijstra、BellmanFord、FloydWarShall算法实现)
  • 时序数据库高基数问题（一）：当数据标签太多时会发生什么
  • 东莞市企业网站制作企业关键词推广优化排名品牌
  • 个人网站免费搭建软文标题和内容
  • 普洱高端网站建设价格燕郊房价2023年最新房价走势
  • 怎么做二维码微信扫后直到网站合肥网站排名提升
  • 如何办网站 论坛网站一定要公司吗
  • 主流网站开发平台新媒体运营需要哪些技能
  • 江门网站php网站开发遇到的问题
  • 做韦恩图网站建网站如果不买域名别人能不能访问