【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 去手动配置权限

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

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

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

机器人搬砖 - 华为OD统一考试

OD统一考试(C卷) 分值: 100分 题解: Java / Python / C 题目描述 机器人搬砖,一共有N堆砖存放在N个不同的仓库中,第 i 堆中有 bricks[i] 块砖头,要求在8小时内搬完。 机器人每小时能搬砖的数量…

【RT-DETR进阶实战】利用RT-DETR进行过线统计(可用于人 、车过线统计)

👑欢迎大家订阅本专栏,一起学习RT-DETR👑 一、本文介绍 Hello,各位读者,最近会给大家发一些进阶实战的讲解,如何利用RT-DETR现有的一些功能进行一些实战, 让我们不仅会改进RT-DETR,也能够利用RT-DETR去做一些简单的小工作,后面我也会将这些功能利用PyQt或者是p…

Vue中v-on 可以监听多个方法吗

当然可以!Vue.js是一款非常强大的JavaScript库,它提供了很多方便的方法和指令,使我们可以更容易地构建交互式的Web应用程序。其中,v-on指令是Vue.js中一个非常重要也非常常用的指令,它用于监听DOM事件,并在…

Qt网络编程-写一个简单的网络调试助手

环境 Windows&#xff1a;Qt5.15.2&#xff08;VS2022&#xff09; Linux&#xff1a;Qt5.12.12&#xff08;gcc) 源代码 TCP服务器 头文件&#xff1a; #ifndef TCPSERVERWIDGET_H #define TCPSERVERWIDGET_H #include <QWidget> namespace Ui { class TCPServerW…

微信红包测试用例设计,龙年大吉!

前言 大家好&#xff0c;我是chowley&#xff0c;在这里祝大家龙年大吉&#xff0c;身体健康&#xff0c;这次来回忆一下当时参加腾讯技术面的场景题&#xff0c;面试官让我测试拼手气红包&#xff0c;不需要考虑其他方面&#xff0c;只在功能方面进行探索。 我先贴一张红包界…

蓝桥杯每日一题------背包问题(一)

背包问题 阅读小提示&#xff1a;这篇文章稍微有点长&#xff0c;希望可以对背包问题进行系统详细的讲解&#xff0c;在看的过程中如果有任何疑问请在评论区里指出。因为篇幅过长也可以进行选择性阅读&#xff0c;读取自己想要的那一部分即可。 前言 背包问题可以看作动态规…

CSP-202203-1-未初始化警告

CSP-202203-1-未初始化警告 难点&#xff1a;时间复杂度 【核心】&#xff1a;统计输入的k组“赋值”中&#xff0c;右值不为0且未在先前作为左值出现过的次数【坑!】本题直接通过暴力枚举时间复杂度很可能过不了 【90分思路】 定义数组 initialized 用来存储已经处理过的左…

FastDFS安装并整合Openresty

FastDFS安装 一、环境--centos7二、FastDFS--tracker安装2.1.下载2.2.FastDFS安装环境2.3.安装FastDFS依赖libevent库2.4.安装libfastcommon2.5.安装 libserverframe 网络框架2.6.tracker编译安装2.7.文件安装位置介绍2.8.错误处理2.9.配置FastDFS跟踪器(Tracker)2.10.启动2.11…

猫头虎分享已解决Bug || 响应式布局错误(Responsive Design Issues):在移动设备上元素重叠、布局错位

博主猫头虎的技术世界 &#x1f31f; 欢迎来到猫头虎的博客 — 探索技术的无限可能&#xff01; 专栏链接&#xff1a; &#x1f517; 精选专栏&#xff1a; 《面试题大全》 — 面试准备的宝典&#xff01;《IDEA开发秘籍》 — 提升你的IDEA技能&#xff01;《100天精通鸿蒙》 …

windows上卸载完程序后,清理残余文件,无法删除的情况处理

现象&#xff1a;通常在卸载完软件后&#xff0c;要删除残余文件或者移动残余文件时候&#xff0c;会弹出来 原因&#xff1a; 因为文件被其他程序已经加载&#xff0c;处理的目标是找到使用这个文件的进程&#xff0c;然后kill掉。类似于linux上的lsof命令查找到进程号&…

一款全新的勒索病毒Hive来袭,已有企业中招

前言 Hive勒索病毒是一款全新的勒索病毒&#xff0c;笔者从6月26号开始关注这款全新的勒索病毒&#xff0c;知识星球相关信息&#xff0c;如下所示&#xff1a; id-ransomware网站也更新了此勒索病毒的相关信息&#xff0c;如下所示&#xff1a; 该勒索病毒采用GO语言编写&…

在线JSON解析格式化工具

在线JSON解析格式化工具 - BTool在线工具软件&#xff0c;为开发者提供方便。JSON在线可视化工具:提供JSON视图,JSON格式化视图,JSON可视化,JSON美化,JSON美化视图,JSON在线美化,JSON结构化,JSON格式化,JSON中文Unicode等等。以清晰美观的结构化视图来展示json,可伸缩折叠展示,…

OpenCV 笔记(20):霍夫圆检测

1. 霍夫圆变换 霍夫圆变换(Hough Circle Transform)是一种数字图像处理中的特征提取技术&#xff0c;用于在图像中检测圆形。它将二维图像空间中一个圆转换为该圆半径、圆心横纵坐标所确定的三维参数空间中一个点的过程。因此&#xff0c;圆周上任意三点所确定的圆&#xff0c…

【java苍穹外卖项目实战一】苍穹外卖项目介绍

文章目录 1、项目介绍1、项目概述2、 产品原型3、技术选型 1、项目介绍 在开发苍穹外卖这个项目之前&#xff0c;我们需要全方位的来介绍一下当前我们学习的这个项目。接下来&#xff0c;我们将从项目简介、产品原型、技术选型三个方面来介绍苍穹外卖这个项目。 1、项目概述 …

阿里云服务器租用价格表_2024一年_1个月_1小时收费价格表

2024年阿里云服务器租用价格表更新&#xff0c;云服务器ECS经济型e实例2核2G、3M固定带宽99元一年、ECS u1实例2核4G、5M固定带宽、80G ESSD Entry盘优惠价格199元一年&#xff0c;轻量应用服务器2核2G3M带宽轻量服务器一年61元、2核4G4M带宽轻量服务器一年165元12个月、2核4G服…

MySQL 升级脚本制作

当数据库更新字段后或添加一些基础信息&#xff0c;要对生产环境进行升级&#xff0c;之前都是手动编写sql&#xff0c;容易出错还容易缺失。 通过 Navcat 工具的数据库结构同步功能和数据同步功能完成数据库脚本的制作。 一、结构同步功能 1、选择 工具–结构同步&#xff1…

NOVATEK显示技术系列之CEDSCHPI Training差异简介

CEDS的数据封包格式&#xff1a;首先CEDS数据封包包括三个部分&#xff1a; Training Pattern即Phase1Control Data 即 Phase2RGB Data 即Phase3 Power on Timing&#xff1a; 工作原理&#xff1a; Power ON时&#xff0c;TCON会发Training Pattern&#xff0c;当COF接受Tr…

STC系列单片机的中断系统

目录 一、中断系统的定义 二、STC15系列单片机的中断请求源及结构图 三、中断查询表以及触发方式 四、在keil c中如何声明中断函数 五、外部中断 六、基于STC15芯片实战中断系统的使用 &#xff08;1&#xff09;外部中断2/外部中断3来检测门的开关状态 &#xff08;2&a…

架构之模板方法等模式的使用

目录 一、程序编写背景 二、编程思路讲解 - 类图 - 实现逻辑 - 工厂模式 - 模板方法模式 接口类&#xff08;代码&#xff09;抽象类&#xff08;代码&#xff09;具体实现类&#xff08;代码&#xff09;工厂类&#xff08;代码&#xff09;注册类&#xff08;代码&…

Vue3 常用的10个组合式 API

2024-01-025,917阅读6分钟 Vue.js是一个用于开发Web应用程序的强大JavaScript框架。Vue 2 于 2023 年 12 月 31 日停止维护。而通过Vue 3&#xff0c;组合式API增强了我们利用Vue的能力&#xff0c;使我们的代码更具模块性和可读性。下面分享10个常用的Vue3组合式API&#xff…