【RabbitMQ(一)】:基本介绍 | 配置安装与快速入门

应该是新年前最后一篇博客了,明天浅浅休息一下,提前祝大家新年快乐捏!😊😊😊

01. 基础理解

1.1 同步调用和异步调用

👉 同步调用 的时候调用者会 阻塞 等待被调用函数或方法执行完成,并且在完成后才继续执行后续代码。

💡 那这样会出现什么问题呢?

回想一下平时充话费的场景,当我们点击支付了之后,当余额被扣减完之后就可以直接退出了,其实是没有等待服务状态更新,和后面进行的很多业务的,比如短信通知服务也是在充值以后一段时间才会通知的,这其实就是一种异步的方式。

👉试想一下如果是同步调用会出现什么场景?

​ 答案是界面会卡住,等到一切短信发送完成才能得到 结果,这就导致了等待时间的延长;将视角再放的深一点,如果将这些业务都做成同步的话,其中一个业务的失败会导致所有业务的 级联失败,也就是如果短信通知业务失效了,钱甚至会被退回来,这就导致了用户体验的问题;再将视角放到程序员身上,如果设计一个同步业务,有新的业务加入进来,要去该原来的代码,这就导致了 耦合性很高 的问题。

不难总结出来同步调用的问题

  • 加需求的问题(耦合性很差)
  • 性能的问题,客户等待时间过长
  • 一个调用的失败导致级联失败

但任何事物都有两面性,同步调用的优势就是: 立即得到响应的结果 时效性非常好,很多业务必须要一次执行完毕且需要结果才能进行,比如银行转账,需要保证双方都成功才能进行。

👉 而异步调用正好是相反,对于一些不是那么急于知道结果的业务,可以在返回给用户结果后再执行,这就引出了它的优势:首先是 解耦合,业务不需要写在一个代码上,而是可以以微服务的形式拆分开;其次,**立即返回 **给 用户结果,用户无需等待;还可以实现 故障的隔离,一个服务的问题不会导致整个业务的级联失败;最后是可以缓存消息,当消息很多的时候可以 错峰执行,达到削峰填谷的作用。

但缺点就是不能立刻得到处理的结果,时效性比较差,同时实现依赖于 Broker(代理),如果 Broker 出现问题会导致严重的后果。

👉 异步调用中会出现三个角色,分别是消息发送者、消息代理、和消息接收者;消息发送者发送消息到消息代理然后就可以继续执行,消息代理负责将消息转发给消息接收者,剩余的部分在消息接收者那里执行。

1.2 什么是 MQ?

👉 MQ(Message Queue),消息队列,字面来看就是存放消息的队列;也就是异步调用中的 Broker;这个命名也就解释了它的实现机制:MQ 提供了一种 异步通信 的方式,允许将消息发送到队列中,并由接收者从队列中获取和处理这些消息。MQ 通常被用于解耦和增强系统的可伸缩性、可靠性和灵活性。

👉 下面来看一下常见的 MQ Broker:

RabbitMQActiveMQRocketMQKafka
公司 / 社区RabbitApache阿里Apache
开发语言ErlangJavaJavaScala & Java
协议支持AMQP, XMPP, SMTP, STOMPOpenWire, STOMP, REST, REST, SMPP, AMQP自定义协议自定义协议
可用性一般
单机吞吐量一般非常高
消息延迟微秒级毫秒级毫秒级毫秒以内
消息可靠性一般一般

💡 协议:是在通信系统中,用于规定数据传输格式、通信规则和通信过程的一组规范。

💡 单机吞吐量:单个计算机或服务器上处理的消息数量或请求数量的度量

选择 RabbitMQ 的原因是因为它的社区生态好,且各方面性能都很优异,很多公司也都在使用。

02. RabbitMQ介绍即安装方式

2.1 RabbitMQ 安装

这里采用 Docker 的安装方式:

💡 虚拟机的安装与配置,参考我的博客 从零开始 Linux(一):基础介绍与常用指令总结

💡 如果没有安装 Docker 的朋友可以看这一部分安装一下

  • 卸载旧版本的 Docker

    sudo yum remove docker \
                      docker-client \
                      docker-client-latest \
                      docker-common \
                      docker-latest \
                      docker-latest-logrotate \
                      docker-logrotate \
                      docker-engine
    
  • 安装 yum 工具

    $ sudo yum install -y yum-utils
    
  • 配置 Docker 的 yum 源

    $ sudo yum-config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo
    
  • 安装 Docker

    $ sudo yum install docker-ce docker-ce-cli containerd.io docker-buildx-plugin docker-compose-plugin
    
  • 检验是否安装成功

    $ docker -v
    
  • 启动 Docker

    $ sudo systemctl start docker
    
  • 检测是否启动成功

    $ docker images
    

👉 接下来是使用 Docker 安装 RabbitMQ

$ docker pull rabbitmq

$ docker images # 检测是否安装成功

👉 启动容器

$ docker run -d \
--name mq \
-e RABBITMQ_DEFAULT_USER=root \
-e RABBITMQ_DEFAULT_PASS=123456 \
-v mq-plugins:/plugins \
-p 15672:15672 \
-p 5672:5672 \
rabbitmq

💡 这里来简单讲解一下这部分的指令:

  • \ 是换行符,用于多行输入
  • -e:environment,配置环境变量,上面是配置了管理员的用户名和密码,可以自行配置
  • -p:port,配置端口,rabbitmq 有两个提供服务的端口,一个是图形化界面 15672 和实际的业务端口 5672,可以通过 主机名:15672 的方式在浏览器访问界面。
  • --name:配置容器名
  • rabbitmq:是使用的镜像,就是上面拉取下来的镜像,如果不写版本号的话,默认是 @latest

❗ 如果图形化界面无法打开的话很有可能是没开启图形化服务:

$ docker exec -it fb7a78201d31 /bin/bash # 进入镜像内部
$ rabbitmq-plugins enable rabbitmq_management # 开启图形化服务

2.2 整体架构

除去上面提到的 publisherconsumer 这里来具体看一下其内部的部分

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

发送者发送信息给 交换机(exchange),交换机转发路由消息给 queueconsumer 监听队列变化并从队列中取出和处理消息。

💡 为什么需要 exchange,通过后续的学习,是可以将消息直接放到队列中的,但如果要向所有的队列(n 个)中发送消息,就要写 n 次调用代码;如果向固定的队列发送消息又要去定义新的方法,所以交换机就可以通过配置实现路由的效果,将消息按照规定的方式转发到队列。

💡 其中的 Virtual Host 是一种数据隔离手段,很多的消息都可以在同一台 RabbitMQ 服务器上执行,但为了不同模块的区分,需要一个类似命名空间的隔离效果。

2.3 快速入门

💡 任务:通过图形化界面来初步体会消息队列

👉 在这里输入上面配置中设置的账号和密码(镜像启动的配置)

👉 基本界面

👉 首先去 Queues 中创造两个队列

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

💡 先按照我的配置来创造 hello.queue1hello.queue2

👉 关联交换机与队列:交换机肯定不会服务到所有的队列,需要设置交换机与队列之间的 binding

在这里插入图片描述

💡 使用系统默认的交换机,配置关联


👉 发送信息

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

👉 在队列中查看信息

2.4 Virtual Host 体验

👉 找到 Admin 界面下的 Virtual Hosts 可以配置新的 Virtual Host

同时在 Users 界面下可以新增用户,用户如果有创建 Virtual Host 的权利的话,他创建的主机就默认有权限访问,反之则需要 Admin 去手动配置权限

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/380737.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【MySQL】MySQL表的增删改查(基础)

MySQL表的增删改查(基础) 1. CRUD2. 新增(Create)2.1 单行数据全列插入2.2 多行数据 指定列插入 3. 查询(Retrieve)3.1 全列查询3.2 指定列查询3.3 查询字段为表达式3.4 别名3.5 去重:DISTINCT…

K8S系列文章之 [使用 Alpine 搭建 k3s]

官方文档:K3s - 轻量级 Kubernetes | K3s 官方描述,可运行在 systemd 或者 openrc 环境上,那就往精简方向走,使用 alpine 做系统。与 RHEL、Debian 的区别,主要在防火墙侧;其他基础配置需求类似&#xff0…

每日五道java面试题之java基础篇(一)

第一题 什么是java? PS:碎怂 Java,有啥好介绍的。哦,⾯试啊。 Java 是⼀⻔⾯向对象的编程语⾔,不仅吸收了 C语⾔的各种优点,还摒弃了 C⾥难以理解的多继承、指针等概念,因此 Java 语⾔具有功能强⼤和简单易…

Python爬虫实战:抓取猫眼电影排行榜top100#4

爬虫专栏系列:http://t.csdnimg.cn/Oiun0 抓取猫眼电影排行 本节中,我们利用 requests 库和正则表达式来抓取猫眼电影 TOP100 的相关内容。requests 比 urllib 使用更加方便,而且目前我们还没有系统学习 HTML 解析库,所以这里就…

Linux开发:PAM1 介绍

PAM(Pluggable Authentication Modules )是Linux提供的一种通用的认证方式,他可以根据需要动态的加载认证模块,从而减少认证开发的工作量以及提供认证的灵活度。 1.PAM的框架 PAM的框架由一下几个部分构成 1)应用程序,即需要使用认证服务的程序,这些应用程序是使用抽象…

剑指offer——二维数组中的查找(杨氏矩阵)

目录 1. 题目描述2. 常见错误思路3. 分析3.1 特例分析3.2 规律总结 4. 完整代码 1. 题目描述 在一个二维数组中,每一行都按照从左到右递增的顺序排序,每一列都按照从上到下递增的顺序排序。请完成一个函数,输入这样的一个二维数组和一个整数&…

[SAP] ABAP代码程序美化器大小写格式化设置

按照ABAP开发的规范,ABAP源代码里推荐将所有的关键字大写,其余ABAP变量小写 我们可以手动修改上述代码大小写规范的问题,但如果代码量很多的情况下,手动确保这个规范(所有的关键字大写,其余ABAP变量小写)有点费事&…

机器学习系列——(二十)密度聚类

引言 在机器学习的无监督学习领域,聚类算法是一种关键的技术,用于发现数据集中的内在结构和模式。与传统的基于距离的聚类方法(如K-Means)不同,密度聚类关注于数据分布的密度,旨在识别被低密度区域分隔的高…

谷歌 DeepMind 联合斯坦福推出了主从式遥操作双臂机器人系统增强版ALOHA 2

谷歌 DeepMind 联合斯坦福推出了 ALOHA 的增强版本 ——ALOHA 2。与一代相比,ALOHA 2 具有更强的性能、人体工程学设计和稳健性,且成本还不到 20 万元人民币。并且,为了加速大规模双手操作的研究,ALOHA 2 相关的所有硬件设计全部开…

VDB-具有动态拓扑的高分辨率稀疏体积表示方法

论文地址:Museth_TOG13.pdf 概述 论文提出了一个称为VDB的新颖数据结构和算法,它可以高效地表示三维网格上的稀疏、随时间变化的数据。 VDB的数据结构基于B树,包含一个动态的根节点,以及多个内部节点和叶节点层次,这…

Guava RateLimiter单机实战指南

欢迎来到我的博客,代码的世界里,每一行都是一个故事 Guava RateLimiter单机实战指南 前言maven坐标引入业务实现重要参数和方法关于warmupPeriod实战 前言 想象一下你是一位大厨,正在烹饪美味佳肴。突然之间,前来就餐的人潮如潮水…

查看系统进程信息的Tasklist命令

Tasklist命令是一个用来显示运行在本地计算机上所有进程的命令行工具,带有多个执行参数。另外,Tasklist可以代替Tlist工具。通过任务管理器,可以查看到本机完整的进程列表,而且可以通过手工定制进程列表方式获得更多进程信息&…

【stomp实战】websocket原理解析与简单使用

一、WebSocket 原理 WebSocket是HTML5提供的一种浏览器与服务器进行全双工通讯的网络技术,属于应用层协议。它基于TCP传输协议,并复用HTTP的握手通道。浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接, 并…

Python入门知识点分享——(二十)继承和方法重写

今天是大年三十,祝大家龙年大吉,当然无论何时何地,我们都不要忘记继续学习。今天介绍的是继承和方法重写这两种面向对象编程特点。继承机制指的是,一个类(我们称其为子类或派生类)可以使用另一个类&#xf…

备战蓝桥杯---动态规划(基础3)

本专题主要介绍在求序列的经典问题上dp的应用。 我们上次用前缀和来解决,这次让我们用dp解决把 我们参考不下降子序列的思路,可以令f[i]为以i结尾的最大字段和,易得: f[i]max(a[i],a[i]f[i-1]); 下面是AC代码: #in…

vue3 之 商城项目—登陆

整体认识 登陆页面的主要功能就是表单校验和登陆登出业务 路由配置 模版 <script setup></script><template><div><header class"login-header"><div class"container m-top-20"><h1 class"logo"&g…

【数学建模】【2024年】【第40届】【MCM/ICM】【A题 七鳃鳗性别比与资源可用性】【解题思路】

我们通过将近半天的搜索数据&#xff0c;查到了美国五大湖中优势物种的食物网数据&#xff0c;以Eric伊利湖为例&#xff0c;共包含34各优势物种&#xff0c;相互之间的关系如下图所示&#xff1a; 一、题目 &#xff08;一&#xff09; 赛题原文 2024 MCM Problem A: Reso…

OpenCV 笔记(21):图像色彩空间

1. 图像色彩空间 图像色彩空间是用于定义颜色范围的数学模型。 它规定了图像中可以使用的颜色以及它们之间的关系。它决定了图像中可以显示的颜色范围。不同的色彩空间可以包含不同的颜色范围&#xff0c;因此选择合适的色彩空间对于确保图像在不同设备上看起来一致非常重要。…

【开源】基于JAVA+Vue+SpringBoot的假日旅社管理系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 系统介绍2.2 QA 问答 三、系统展示四、核心代码4.1 查询民宿4.2 新增民宿评论4.3 查询民宿新闻4.4 新建民宿预订单4.5 查询我的民宿预订单 五、免责说明 一、摘要 1.1 项目介绍 基于JAVAVueSpringBootMySQL的假日旅社…

专业145+总分400+合肥工业大学833信号分析与处理综合考研经验电子信息通信,真题,大纲,参考书

今年专业课145总分400&#xff0c;我总结一下自己的专业课合肥工业大学833信号分析与处理和其他几门的复习经验。希望对大家复习有帮助。 我所用的教材是郑君里的《信号与系统》&#xff08;第三版&#xff09;和高西全、丁玉美的《数字信号处理》&#xff08;第四版&#xff…