2.6日学习打卡----初学RabbitMQ（一）

2.6日学习打卡

初识RabbitMQ、

一. MQ

在这里插入图片描述

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

  • 同步通信相当于两个人当面对话，你一言我一语。必须及时回复

在这里插入图片描述

  • 异步通信相当于通过第三方转述对话，可能有消息的延迟，但不需要二人时刻保持联系。
    在这里插入图片描述

消息
两台计算机间传送的数据单位。消息可以非常简单，例如只包含文
本字符串；也可以更复杂，可能包含嵌入对象。

队列
数据结构中概念。在队列中，数据先进先出，后进后出。
在这里插入图片描述

二. MQ的优势

应用解耦

在电商平台中，用户下订单需要调用订单系统，此时订单系统还需
要调用库存系统、支付系统、物流系统完成业务。此时会产生两个
问题：

  1. 如果库存系统出现故障，会造成整个订单系统崩溃。
  2. 如果需求修改，新增了一个X系统，此时必须修改订单系统的代码。
    在这里插入图片描述

如果在系统中引入MQ，即订单系统将消息先发送到MQ中，MQ再
转发到其他系统，则会解决以下问题：

  1. 由于订单系统只发消息给MQ，不直接对接其他系统，如果库存系统出现故障，不影响整个订单。
  2. 如果需求修改，新增了一个X系统，此时无需修改订单系统的代码，只需修改MQ将消息发送给X系
    统即可。
    在这里插入图片描述

异步提速

如果订单系统同步访问每个系统，则用户下单等待时长如下:
在这里插入图片描述
如果引入MQ，则用户下单等待时长如下:
在这里插入图片描述
削峰填谷

假设我们的系统每秒只能承载1000请求，如果请求瞬间增多到每秒
5000，则会造成系统崩溃。此时引入mq即可解决该问题
在这里插入图片描述
使用了MQ之后，限制消费消息的速度为1000，这样一来，高峰期
产生的数据势必会被积压在MQ中，高峰就被“削”掉了，但是因为消
息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持
在1000，直到消费完积压的消息，这就叫做**“填谷”**。
在这里插入图片描述

三. MQ的劣势

在这里插入图片描述

系统可用性降低
系统引入的外部依赖越多，系统稳定性越差。一旦MQ宕机，就会对业务造成影响。
系统复杂度提高
MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过MQ进行异步调用。
一致性问题
A系统处理完业务，通过MQ给B、C、D三个系统发消息数据，如果B系统、C系统处理成功，D系统处理失败，则会造成数据处理的不一致。

四.MQ应用场景

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

这些业务场景都是短时间内需要处理大量请求，如果直接连接系
统处理业务，会耗费大量资源，有可能造成系统瘫痪。
在这里插入图片描述
而使用MQ后，可以先让用户将请求发送到MQ中，MQ会先保存
请求消息，不会占用系统资源，且MQ会进行消息排序，先请求
的秒杀成功，后请求的秒杀失败
在这里插入图片描述

消息分发

如电商网站要推送促销信息，该业务耗费时间较多，但对时效性
要求不高，可以使用MQ做消息分发。
在这里插入图片描述
数据同步

假如我们需要将数据保存到数据库之外，还需要一段时间将数据
同步到缓存（如Redis）、搜索引擎（如Elasticsearch）中。此
时可以将数据库的数据作为消息发送到MQ中，并同步到缓存、
搜索引擎中
在这里插入图片描述
异步处理

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

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

五. AMQP

在这里插入图片描述

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

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

AMQP工作过程
生产者(Publisher)将消息发布到交换机(Exchange)，交换机根据规
则将消息分发给交换机绑定的队列(Queue)，队列再将消息投递给
订阅了此队列的消费者
在这里插入图片描述

六. 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链接
可以容纳无限的信道，即使每秒成千上万的请求也不会成为性
能的瓶颈

七.RabbitMQ的安装

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

  1. 安装Erlang所需的依赖

yum install -y epel-release

  1. 添加存储条目

wget https://packages.erlangsolutions.com/erlang-solutions-1.0-1.noarch.rpm

rpm -Uvh erlang-solutions-1.0-1.noarch.rpm

  1. 安装Erlang

yum install erlang-24.2.1

  1. 查看Erlang是否安装成功

erl -version

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

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

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

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

  1. 使用rz命令上传RabbitMQ压缩文件
  2. 安装RabbitMQ

#解压RabbitMQ
tar xf rabbitmq-server-generic-unix-
3.9.13.tar.xz
#重命名：
mv rabbitmq_server-3.9.13 rabbitmq
#移动文件夹：
mv rabbitmq /usr/local/

  1. 配置环境变量

#编辑/etc/profile文件
vim /etc/profile
#添加如下内容
export PATH=$PATH:/usr/local/rabbitmq/sbin
#运行文件，让修改内容生效
source /etc/profile

  1. 开启管控台插件

rabbitmq-plugins enable
rabbitmq_management

  1. 后台运行

#启动rabbitmq
rabbitmq-server -detached
#停止rabbitmq
rabbitmqctl stop

  1. 通过管控台访问RabbitMQ
    路径：http://ip地址:15672 ，用户名： guest ，密码： guest

  2. 此时会提示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

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

  1. 创建账户

#创建账户
rabbitmqctl add_user 用户名 密码

  1. 给用户授予管理员角色

rabbitmqctl set_user_tags 用户名
administrator

  1. 给用户授权

#“/“表示虚拟机
#jjy表示用户名
#”." ".” “." 表示完整权限
rabbitmqctl set_permissions -p “/” jjy ".” “." ".”

八.Docker安装RabbitMQ

  1. 关闭RabbitMQ服务

rabbitmqctl stop

  1. 在Centos7中安装docker

#安装Docker
curl -fsSL https://get.docker.com | bash -
s docker --mirror Aliyun
#启动docker
systemctl start docker

  1. 拉取镜像

docker pull rabbitmq

  1. 启动RabbitMQ容器

docker run -d --hostname jjy --name
rabbit -p 15672:15672 -p 5672:5672
rabbitmq

  1. 开启管控台插件

#查询rabbitmq容器ID
docker ps
#进入容器
docker exec -it 容器ID /bin/bash
#开启管控台插件
rabbitmq-plugins enable
rabbitmq_management
#退出容器
ctrl+p+q

  1. 通过管控台访问rabbitmq
    路径： http://ip地址:15672 ，用户名： guest ，密码： guest

  2. 关闭RabbitMQ容器

docker stop rabbit

如果我的内容对你有帮助，请点赞，评论，收藏。创作不易，大家的支持就是我坚持下去的动力！
在这里插入图片描述

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

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

相关文章

Redis核心技术与实战【学习笔记】 - 27.限制Redis Cluster规模的因素（通信开销）

Redis核心技术与实战【学习笔记】 - 27.限制Redis Cluster规模的因素（通信开销）

简述 Redis Cluster 能保存的数据量以及支撑的吞吐量，跟集群实例规模相关。 Redis 官方给出了 Redis Cluster 的规模上线，就是一个集群运行 1000 个实例。 其实，限定 Redis Cluster 集群规模的一个关键因素就是，实例间的通信开销…
阅读更多...
入门指南｜Chat GPT 的兴起：它如何改变数字营销格局？

入门指南｜Chat GPT 的兴起：它如何改变数字营销格局？

随着数字营销的不断发展，支持数字营销的技术也在不断发展。OpenAI 的 ChatGPT 是一项备受关注的突破性工具。凭借其先进的自然语言处理能力，ChatGPT 已被证明是全球营销人员的宝贵资产。在这份入门指南中，我们将探讨Chat GPT对数字营销专家及…
阅读更多...
社区店选址要素揭秘：人流量与商业潜力的关键

社区店选址要素揭秘：人流量与商业潜力的关键

开店五年，我深刻体会到选址对于社区店的重要性。 不管是哪个行业的实体店，选址更是决定成败的关键因素之一。今天，我就以一名资深鲜奶吧创业者的身份，来揭秘社区店选址的几大要素，帮助大家在创业的道路上少走弯路。 …
阅读更多...
Maven - 编译报错：程序包 XXX 不存在（多模块项目）

Maven - 编译报错：程序包 XXX 不存在（多模块项目）

问题描述 编译报错&#xff1a;程序包 XXX 不存在&#xff08;多模块项目&#xff09; 原因分析 检查依赖模块 pom 文件&#xff0c;看是不是引入了如下插件 <plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-pl…
阅读更多...
【深度学习】实验7布置，图像超分辨

【深度学习】实验7布置，图像超分辨

清华大学驭风计划 因为篇幅原因实验答案分开上传&#xff0c; 实验答案链接http://t.csdnimg.cn/P1yJF 如果需要更详细的实验报告或者代码可以私聊博主 有任何疑问或者问题&#xff0c;也欢迎私信博主&#xff0c;大家可以相互讨论交流哟~~ 深度学习训练营 案例 7 &#xff1…
阅读更多...
2024年【起重机司机(限桥式起重机)】最新解析及起重机司机(限桥式起重机)考试资料

2024年【起重机司机(限桥式起重机)】最新解析及起重机司机(限桥式起重机)考试资料

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 起重机司机(限桥式起重机)最新解析是安全生产模拟考试一点通生成的&#xff0c;起重机司机(限桥式起重机)证模拟考试题库是根据起重机司机(限桥式起重机)最新版教材汇编出起重机司机(限桥式起重机)仿真模拟考试。2024…
阅读更多...
Idea里自定义封装数据警告解决 Spring Boot Configuration Annotation Processor not configured

Idea里自定义封装数据警告解决 Spring Boot Configuration Annotation Processor not configured

我们自定对象封装指定数据&#xff0c;封装类上面一个红色警告&#xff0c;虽然不影响我们的执行&#xff0c;但是有强迫症看着不舒服&#xff0c; 去除方式&#xff1a; 在pom文件加上坐标刷新 <dependency><groupId>org.springframework.boot</groupId><…
阅读更多...
Stata实证命令代码汇总

Stata实证命令代码汇总

Stata代码命令汇总 数据内容&#xff1a;包括数据导入和管理、数据的处理、描述性统计、相关性分析、实证模型、内生性解决、检验分析、结果导出 具体如下&#xff1a; 一、数据导入和管理&#xff1a;数据导入、数据导出 二、数据的处理&#xff1a;生成新变量、格式转换、…
阅读更多...
FTP 文件传送协议

FTP 文件传送协议

目录 1 文件传送协议 FTP 1.1 FTP 的基本工作原理 FTP 特点 主进程的工作步骤 两个连接 两个不同的端口号 NFS 采用另一种思路 1.2 简单文件传送协议 TFTP TFTP 的主要特点 TFTP 的工作&#xff08;很像停止等待协议&#xff09; 1 文件传送协议 FTP 文件传送协议 …
阅读更多...
计算机算术

计算机算术

计算机算术 数据是什么 数据是各种各样的信息&#xff0c;如数字、文本、计算机程序、音乐、图像、符号等等&#xff0c;实际上&#xff0c;信息可以是能够被计算机存储和处理的任何事物。 位与字节 计算机中存储和处理信息的最小单位是位&#xff08;Binary digit比特&#x…
阅读更多...
C++，stl，list容器详解

C++，stl，list容器详解

目录 1.list基本概念 2.list构造函数 3.list的赋值和交换 4.list大小操作 5.list的插入的删除 6.list数据存取 7.list反转和排序 排序案例 1.list基本概念 2.list构造函数 #include<bits/stdc.h> using namespace std;void print(const list<int> &lk) …
阅读更多...
【Ubuntu 20.04/22.04 LTS】最新 esp-matter SDK 软件编译环境搭建步骤

【Ubuntu 20.04/22.04 LTS】最新 esp-matter SDK 软件编译环境搭建步骤

仓库链接&#xff1a;esp-matter SDK官方软件说明&#xff1a;ESP Matter Programming Guide官方参考文档&#xff1a;使用 Matter-SDK 快速搭建 Matter 环境 (Linux) 环境要求 Ubuntu 20.04 或 Ubuntu22.04网络环境支持访问 Gihub 在安装 esp-matter SDK 软件编译环境之前&a…
阅读更多...
行程开关方向

行程开关方向

平板打印机的行程开关方向通常取决于设备的特定设计和制造商的指导。一般来说&#xff0c;行程开关的方向是指当行程开关被触发时&#xff0c;设备移动的方向。例如&#xff0c;如果一个行程开关被设计为当它被触发时&#xff0c;设备会向左移动&#xff0c;那么这个行程开关的…
阅读更多...
Oracle 几种行转列的方式 sum+decode sum+case when pivot

Oracle 几种行转列的方式 sum+decode sum+case when pivot

目录 原始数据&#xff1a; 方式一&#xff1a; 方式二&#xff1a; 方式三&#xff1a; unpivot的使用&#xff1a; 原始数据&#xff1a; 方式一&#xff1a; select t_name,sum(decode(t_item, item1, t_num, 0)) item1,sum(decode(t_item, item2, t_num, 0)) item2,s…
阅读更多...
【51单片机】添加模块代码的常见问题（图示＆代码演示）

【51单片机】添加模块代码的常见问题（图示＆代码演示）

前言 大家好吖&#xff0c;欢迎来到 YY 滴 系列 &#xff0c;热烈欢迎&#xff01; 本章主要内容面向接触过C的老铁 主要内容含&#xff1a; 本章节是Lcd1602章节的一部分&#xff0c;以把4个Lcd驱动程序添加为例子&#xff0c;完整传送门在下方传送门 欢迎订阅 YY滴C专栏&…
阅读更多...
【蓝桥杯冲冲冲】[CEOI2015 Day2] 世界冰球锦标赛

【蓝桥杯冲冲冲】[CEOI2015 Day2] 世界冰球锦标赛

蓝桥杯备赛 | 洛谷做题打卡day32 文章目录 蓝桥杯备赛 | 洛谷做题打卡day32题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 提示样例解释 题解代码我的一些话 [CEOI2015 Day2] 世界冰球锦标赛 题目描述 译自 CEOI2015 Day2 T1「Ice Hockey World Championship」 今年的…
阅读更多...
三、OpenAI所有模型介绍

三、OpenAI所有模型介绍

1. 综述 OpenAI API开发了具有各种能力的模型。可以根据不同的需求选择不同的模型并进行精调。 模型描述GPT-4、GPT-4 Turbo一组从GPT-3.5升级后的模型&#xff0c;能够生成自然语言和代码GPT-3.5 Turbo一组从GPT-3.5升级后的模型&#xff0c;能够生成自然语言和代码DALL.E能…
阅读更多...
政安晨：示例演绎机器学习中（深度学习）神经网络的数学基础——快速理解核心概念（二）{两篇文章讲清楚}

政安晨：示例演绎机器学习中（深度学习）神经网络的数学基础——快速理解核心概念（二）{两篇文章讲清楚}

这一篇与上一篇是兄弟篇&#xff0c;意在通过两篇文章讲清楚深度学习中神经网络的数学基础&#xff0c;第一次看到这篇文章的小伙伴可以从上一篇文章看起&#xff08;包括搭建环境等等都在上一篇&#xff09;&#xff0c;上一篇链接如下&#xff1a; 政安晨&#xff1a;示例演…
阅读更多...
Aethir和Well-Link Tech携手革新云游戏，释放人工智能(AI)潜力

Aethir和Well-Link Tech携手革新云游戏，释放人工智能(AI)潜力

​Aethir将为Well-Link Tech的2亿用户提供先进的GPU计算能力&#xff0c;大幅提升他们的游戏体验。 新加坡&#xff0c;2024年2月7日 - 先驱性的去中心化GPU网络Aethir与实时云渲染技术领导者Well-Link Tech携手共创云游戏和元宇宙发展的新时代。 借助Well-Link Tech对领先游戏…
阅读更多...
ECMAScript Modules规范的示例详解

ECMAScript Modules规范的示例详解

ECMAScript Modules&#xff08;ESM&#xff09;是JavaScript中用于模块化开发的规范&#xff0c;它允许开发者将代码分割成多个独立的文件&#xff0c;以提高代码的可维护性和可重用性。下面是一个ECMAScript Modules规范的示例详解&#xff1a; 创建模块 1.1 导出变量 在一个…
阅读更多...
最新文章

Copyright @ 2022~2023