免费网站注册com凶,ps网页版在线制作,公司名称变更说明函,临桂区住房和城乡建设局门户网站系列文章目录 提示#xff1a;这里可以添加系列文章的所有文章的目录#xff0c;目录需要自己手动添加 消息队列之RabbitMQ介绍 提示#xff1a;写完文章后#xff0c;目录可以自动生成#xff0c;如何生成可参考右边的帮助文档 文章目录 系列文章目录前言一、RabbitMQ介绍…系列文章目录 提示这里可以添加系列文章的所有文章的目录目录需要自己手动添加 消息队列之RabbitMQ介绍 提示写完文章后目录可以自动生成如何生成可参考右边的帮助文档 文章目录 系列文章目录前言一、RabbitMQ介绍消息队列消息队列RabbitMQ 二、使用Rabbit MQ的优势解耦应用异步处理流量削峰高可靠性 三、使用Rabbit MQ的劣势四、RabbitMQ的应用场景秒杀活动消息分发数据同步异步处理 五、RabbitMQ的工作原理六、RabbitMQ的使用安装Erlang环境安装RabbitMQDockers安装RabbitMQ账户管理 总结 前言
提示这里可以添加本文要记录的大概内容
在当今的分布式系统和微服务架构中消息队列扮演着至关重要的角色。它们为应用程序提供了一种可靠的异步通信机制使得各个组件之间能够高效地传递消息和协调工作。而在众多的消息队列技术中RabbitMQ 无疑是一个备受关注和广泛应用的佼佼者。 RabbitMQ 是一个开源的消息队列服务器它基于 AMQPAdvanced Message Queuing Protocol协议实现。通过使用 RabbitMQ开发人员可以轻松地实现应用程序之间的消息传递、异步处理和流量削峰等功能。它具有高度的可靠性、灵活性和可扩展性能够处理大量的消息并发并支持多种编程语言和客户端。 在本博客中我将带领大家深入了解 RabbitMQ 的世界。我们将探讨 RabbitMQ 的核心概念、工作原理以及它的一些重要特性。我还将分享一些实际的使用场景和最佳实践帮助你更好地理解如何将 RabbitMQ 应用于你的项目中。 无论你是一名经验丰富的开发人员还是刚刚开始接触消息队列的新手我相信本博客都能为你提供有价值的信息和启发。让我们一起探索 RabbitMQ 的魅力掌握它的强大功能为构建高效、可靠的应用程序迈出坚实的一步 提示以下是本篇文章正文内容下面案例可供参考
一、RabbitMQ介绍
消息队列
MQ是Message Queue的简称也就是消息队列消息队列是用来消息传递的过程中储存消息的容器。应用于异步通信
消息
消息是指两台计算机间传递的数据单位。消息可以是简单的字符串也可以是复杂的对象。
队列
队列是数据结构中的概念。队列中的数据有先进先出、后进后出的特点。
RabbitMQ
RabbitMQ 是一个开源的消息队列服务器基于 AMQPAdvanced Message Queuing Protocol协议实现它提供了可靠的消息传递机制可以确保消息不会丢失。 RabbitMQ 具有高度的灵活性支持多种消息传递模式如点对点、发布/订阅等以满足不同的应用场景。同时它还支持多种编程语言和客户端并提供了广泛的客户端库方便开发人员进行开发。 在处理更高的消息吞吐量和更多的连接时RabbitMQ 可以轻松扩展。它提供了丰富的文档和资源方便用户学习和解决问题并且拥有一个活跃的社区可以提供技术支持和交流。
二、使用Rabbit MQ的优势
解耦应用
通过使用消息队列应用程序的不同组件可以松耦合地通信而无需直接相互依赖。这有助于提高应用的灵活性和可维护性。
举个例子考虑一个电子商务网站的订单处理系统。当用户在网站上下订单时订单系统需要将订单信息发送给库存系统以检查商品库存同时将订单信息发送给支付系统以处理支付。如果订单系统直接与库存系统和支付系统进行通信那么它们之间就会产生紧耦合。 使用 RabbitMQ订单系统可以将订单消息发送到一个队列中而库存系统和支付系统可以作为消费者从队列中接收订单消息并进行处理。这样订单系统不再直接与库存系统和支付系统进行通信而是通过消息队列进行解耦。 这种解耦的好处是当库存系统或支付系统需要升级或维护时订单系统不会受到影响。它们可以继续发送订单消息到队列中而库存系统和支付系统可以在之后的时间处理这些消息。此外如果订单量突然增加队列可以起到缓冲的作用确保库存系统和支付系统不会被瞬间的高流量淹没。
异步处理
RabbitMQ 允许应用程序进行异步处理从而提高系统的响应性和并发处理能力。发送方可以将消息发送到队列后立即返回而接收方可以在之后的时间处理消息。
流量削峰
在高并发或突发流量的情况下RabbitMQ 可以作为缓冲区来吸收和处理大量的消息。它可以帮助系统抵御瞬间的峰值负载避免应用程序崩溃或性能下降。
高可靠性
RabbitMQ 提供了可靠的消息传递机制确保消息不会丢失。即使在发送方或接收方出现故障的情况下消息也可以被存储在队列中并在系统恢复后重新处理。
三、使用Rabbit MQ的劣势
系统可用性降低 系统引入的外部依赖越多系统稳定性越差。一旦MQ宕机就会对业务造成影响。系统复杂度提高 MQ的加入大大增加了系统的复杂度以前系统间是同步的远程调用现在是通过MQ进行异步调用。一致性问题 A系统处理完业务通过MQ给B、C、D三个系统发消息数据如果B系统、C系统处理成功D系统处理失败则会造成数据处理的不一致。
四、RabbitMQ的应用场景
秒杀活动
对于抢红包、抢车票等秒杀活动一瞬间便会有大量请求打过来如果直接处理会浪费很多资源我们可以先将请求放到MQ中先请求的秒杀成功后请求的秒杀失败。
消息分发
如电商网站要推送促销信息该业务耗费时间较多但对时效性要求不高可以使用MQ做消息分发。
数据同步
假如我们需要将数据保存到数据库之外还需要一段时间将数据同步到缓存如Redis、搜索引擎如Elasticsearch中。此时可以将数据库的数据作为消息发送到MQ中并同步到缓存、搜索引擎中。
异步处理
在电商系统中订单完成后需要及时的通知子系统进销存系统发货用户服务积分发送短信进行下一步操作。为了保证订单系统的高性能应该直接返回订单结果之后让MQ通知子系统做其他非实时的业务操作。这样能保证核心业务的高效及时。
五、RabbitMQ的工作原理
生产者Producer生产者将消息发送到 RabbitMQ 队列中。生产者可以是应用程序或服务它们将消息发送到 RabbitMQ 队列以进行后续处理。连接Connection生产者/消费者和RabbitMQ服务器之间建立的TCP连接。信道Channel是TCP里面的虚拟连接。例如Connection相当于电缆Channel相当于独立光纤束一条TCP连接中可以创建多条信道增加连接效率。无论是发布消息、接收消息、订阅队列都是通过信道完成的。Broker消息队列服务器实体。即RabbitMQ服务器Virtual host虚拟主机。出于多租户和安全因素设计的把AMQP的基本组件划分到一个虚拟的分组中。每个vhost本质上就是一个mini版的RabbitMQ服务器拥有自己的队列、交换机、绑定和权限机制。当多个不同的用户使用同一个RabbitMQ服务器时可以划分出多个虚拟主机。RabbitMQ默认的虚拟主机路径是/。交换机Exchange交换机是RabbitMQ 中的一个组件用于将消息从生产者发送到队列。交换机可以根据消息的内容或属性将其发送到不同的队列中。队列QueueRabbitMQ 队列是一个存储消息的容器。队列可以被多个消费者同时消费消息在队列中按照先进先出FIFO的原则进行存储。绑定Binding绑定是RabbitMQ 中的一个配置用于将交换机和队列关联起来。通过绑定生产者可以将消息发送到特定的交换机而交换机则可以将消息转发到指定的队列中。消费者Consumer消费者从 RabbitMQ 队列中获取消息并进行处理。消费者可以是应用程序或服务它们从队列中获取消息并进行后续的处理或存储。
当生产者将消息发送到 RabbitMQ 时它会将消息发送到指定的交换机。交换机根据绑定规则将消息转发到相应的队列中。然后消费者从队列中获取消息并进行处理。整个过程是异步的生产者和消费者不需要等待对方完成操作而是可以继续进行自己的工作。
六、RabbitMQ的使用
因为RabbitMQ是使Erlang编写的所以使用RabbitMQ需要安装Erlanghuanjing
安装Erlang环境
1.安装Erlang所需的依赖
yum install -y epel-release
2.添加存储库条目
wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm
rpm -Uvh erlang-solutions-1.0-1.noarch.rpm
3.安装Erlang
yum install -y erlang
4.查看Erlang是否安装成功
erl -version
安装RabbitMQ
1.为了外部能够正常访问RabbitMQ服务先关闭防火墙
# 关闭运行的防火墙
systemctl stop firewalld.service
# 禁止防火墙自启动
systemctl disable firewalld.service
2.RabbitMQ是通过主机名进行访问的必须给服务器添加主机名
# 修改文件
vim /etc/sysconfig/network
# 添加如下内容
NETWORKINGyes
HOSTNAMEitbaizhan# 修改文件
vim /etc/hosts
# 添加如下内容
服务器ip zhangsan
3.在Windos中下载RabbitMQ压缩包大家去网上找使用rz命令从Windos上传到Linux虚拟机中。 4.安装RabbitMQ
# 解压RabbitMQ
tar xf rabbitmq-server-generic-unix-3.9.13.tar.xz# 重命名
mv rabbitmq_server-3.9.13 rabbitmq# 移动文件夹
mv rabbitmq /usr/local/
5.配置环境变量
# 编辑/etc/profile文件
vim /etc/profile#添加如下内容
export PATH$PATH:/usr/local/rabbitmq/sbin# 运行文件让修改内容生效
source /etc/profile
6.开启管控台插件
rabbitmq-plugins enable rabbitmq_management
7.后台运行
# 创建配置文件夹
mkdir -p /usr/local/rabbitmq/etc/rabbitmq
# 创建配置文件
vim /usr/local/rabbitmq/etc/rabbitmq/rabbitmq.conf
# 添加如下内容
loopback_usersnone# 重启RabbitMQ
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
8.通过管控台访问RabbitMQ路径http://ip地址:15672用户名guest密码guest 9.此时会提示guest账户只允许本地使用我们可以配置允许使用guest远程访问
# 创建配置文件夹
mkdir -p /usr/local/rabbitmq/etc/rabbitmq
# 创建配置文件
vim /usr/local/rabbitmq/etc/rabbitmq/rabbitmq.conf
# 添加如下内容
loopback_usersnone# 重启RabbitMQ
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
Dockers安装RabbitMQ
1.在虚拟机中安装docker
# 安装Docker
curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun# 启动docker
systemctl start docker
2.拉取镜像
docker pull rabbitmq
3.启动RabbitMQ容器
docker run -d --hostname zhangsan --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq
4.开启管控台插件
# 查询rabbitmq容器ID
docker ps
# 进入容器
docker exec -it 容器ID /bin/bash
# 开启管控台插件
rabbitmq-plugins enable rabbitmq_management
# 退出容器
ctrlpq
5.通过管控台访问rabbitmq路径http://ip地址:15672用户名guest密码guest 6.关闭RabbitMQ容器
docker stop rabbit账户管理
guest账户默认只允许本地使用我们可以创建新账户远程访问RabbitMQ
1.创建账户
# 创建账户
rabbitmqctl add_user 用户名 密码
2.给用户授予管理员角色
rabbitmqctl set_user_tags 用户名 administrator
3.给用户授权
# /表示虚拟机
# itbaizhan表示用户名
# .* .* .* 表示完整权限
rabbitmqctl set_permissions -p / itbaizhan .* .* .* 总结
提示这里对文章进行总结
RabbitMQ 是一个强大而灵活的消息队列解决方案能够帮助应用程序实现高性能、可靠的异步通信和数据处理。
