做桂林网站的图片大全,自己怎么做可以让百度收录的网站,石家庄坤鹏企业管理咨询有限公司,封面免费制作网站RabbitMQ概述-MQ介绍 RabbitMQ是一个开源的消息代理和队列服务器#xff0c;它支持多种消息协议#xff0c;并且可以轻松地与多种编程语言和框架集成。RabbitMQ是使用Erlang语言编写的#xff0c;因此它具有高并发和高可用性的特点。以下是RabbitMQ的一些关键特性和概念 消息…RabbitMQ概述-MQ介绍 RabbitMQ是一个开源的消息代理和队列服务器它支持多种消息协议并且可以轻松地与多种编程语言和框架集成。RabbitMQ是使用Erlang语言编写的因此它具有高并发和高可用性的特点。以下是RabbitMQ的一些关键特性和概念 消息代理Message Broker RabbitMQ充当消息代理它接收来自生产者的消息并将这些消息传递给消费者。消息队列Message Queue 消息队列是一种数据结构用于存储等待处理的消息。生产者Producer 生产者是发送消息到RabbitMQ的应用程序。消费者Consumer消费者是从RabbitMQ接收消息的应用程序。交换器Exchange 交换器是RabbitMQ中消息的路由点。它接收来自生产者的消息并根据路由规则将消息路由到一个或多个队列绑定Binding 绑定是交换器和队列之间的关系。它定义了消息如何从交换器路由到队列路由键Routing Key 路由键是消息的一部分用于消息的路由。生产者发送消息时指定路由键交换器根据绑定规则和路由键将消息路由到相应的队列队列Queue 队列是存储消息的实体。消费者从队列中获取消息进行处理确认Acknowledgement 当消费者成功处理完一条消息后它会发送一个确认信号给RabbitMQ表示消息已被处理持久化Persistence RabbitMQ支持消息和队列的持久化确保在服务器重启后消息不会丢失集群Clustering 多个RabbitMQ节点可以组成一个集群以提高消息处理的吞吐量和系统的可用性高可用性High Availability RabbitMQ支持镜像队列可以实现队列的高可用性消息的可靠性 通过消息确认和持久化机制RabbitMQ确保消息的可靠传递多种消息协议支持 RabbitMQ支持多种消息协议如AMQP高级消息队列协议、MQTT、STOMP等插件系统 RabbitMQ有一个丰富的插件系统可以通过插件扩展其功能。 RabbitMQ广泛应用于分布式系统中用于解耦服务、异步处理任务、消息传递和事件通知等场景。 MQ从字面意思上看本质上是个队列FIFO先进先出只不过队列中存放的内容是消息message而已消息可以非常简单比如只包含文本字符串JSON等也可以很复杂比如内嵌对象
MQ多用于分布式系统之间进行通信
系统之间的调用通常有两种方式
同步通信
直接调用对方的服务数据从一端发出后立即就可以达到另一端 异步通信
数据从一端发出后先进入一个容器进行临时存储当达到某种条件后再由这个容器发送给另一端容器的一个具体实现就是MQMessage Queue RabbitMQ就是MQ的一种实现
MQ作用
MQ主要⼯作是接收并转发消息, 在不同的应⽤场景下可以展现不同的作⽤
可以把MQ想象成⼀个仓库. 采购部⻔进货之后, 把零件放进仓库⾥, ⽣产部⻔从仓库中取出零件, 并加 ⼯成产品. MQ和仓库的区别是, 仓库⾥放的是物品, MQ⾥放的是消息, 仓库负责存储物品,并转发物品, MQ负责存储和转发消息 异步解耦: 在业务流程中, ⼀些操作可能⾮常耗时, 但并不需要即时返回结果. 可以借助MQ把这些操 作异步化, ⽐如 ⽤⼾注册后发送注册短信或邮件通知, 可以作为异步任务处理, ⽽不必等待这些操作 完成后才告知⽤⼾注册成功流量削峰: 在访问量剧增的情况下, 应⽤仍然需要继续发挥作⽤, 但是这样的突发流量并不常⻅. 如果 以能处理这类峰值为标准⽽投⼊资源,⽆疑是巨⼤的浪费. 使⽤MQ能够使关键组件⽀撑突发访问压 ⼒, 不会因为突发流量⽽崩溃. ⽐如秒杀或者促销活动, 可以使⽤MQ来控制流量, 将请求排队, 然后系 统根据⾃⼰的处理能⼒逐步处理这些请求消息分发: 当多个系统需要对同⼀数据做出响应时, 可以使⽤MQ进⾏消息分发. ⽐如⽀付成功后, ⽀ 付系统可以向MQ发送消息, 其他系统订阅该消息, ⽽⽆需轮询数据库延迟通知: 在需要在特定时间后发送通知的场景中, 可以使⽤MQ的延迟消息功能, ⽐如在电⼦商务平 台中如果⽤⼾下单后⼀定时间内未⽀付可以使⽤延迟队列在超时后⾃动取消订单
为什么选择RabbitMQ
⽬前业界有很多的MQ产品, 例如RabbitMQ, RocketMQ, ActiveMQ, Kafka, ZeroMQ等, 也有直接使⽤ Redis充当消息队列的案例, 这些消息队列, 各有侧重, 也没有好坏, 只有适合不适合, 在实际选型时, 需要 结合⾃⾝需求以及MQ产品特征, 综合考虑
以下我们介绍⼀下当前最主流的3种MQ产品
Kafka Kafka⼀开始的⽬的就是⽤于⽇志收集和传输追求⾼吞吐量, 性能卓越, 单机吞吐达到⼗万级, 在⽇ 志领域⽐较成熟, 功能较为简单主要⽀持简单的 MQ 功能, 如果有⽇志采集需求,肯定是⾸选kafka 了RocketMQ RocketMQ采⽤Java语⾔开发, 由阿⾥巴巴开源, 后捐赠给了Apache. 它在设计时借鉴了Kafka并做出了⼀些⾃⼰的改进, ⻘出于蓝⽽胜于蓝, 经过多年双⼗⼀的洗礼, 在 可⽤性、可靠性以及稳定性等⽅⾯都有出⾊的表现. 适合对于可靠性⽐较⾼,且并发⽐较⼤的场景, ⽐ 如互联⽹⾦融. 但⽀持的客⼾端语⾔不多, 且社区活跃度⼀般RabbitMQ 采⽤Erlang语⾔开发, MQ 功能⽐较完备, 且⼏乎⽀持所有主流语⾔开源提供的界⾯也⾮常友好, 性 能较好, 吞吐量能达到万级, 社区活跃度也⽐较⾼⽐较适合中⼩型公司, 数据量没那么⼤, 且并发没 那么⾼的场景 综合: 由于RabbitMQ的综合能⼒较强, 咱们这边的项⽬没有那么⼤的⾼并发, 且RabbitMQ社区⽐较成 熟, 管理界⾯友好, 所以咱们接下来主要学习RabbitMQ的使⽤ RabbitMQ介绍
RabbitMQ 官⽹: RabbitMQ: One broker to queue them all | RabbitMQ
RabbitMQ是采⽤Erlang语⾔实现AMQP(Advanced Message Queuing Protocol,⾼级消息队列协议)的 消息中间件,它最初起源于⾦融系统领域, 为了在分布式系统中存储和转发消息⽽设计的
在此之前,有⼀些消息中间件的商业实现,⽐如微软的MSMQ(MicroSoft Message Queue), IBM的 WebSphere等. 但是他们价格太贵了,⼀般只应⽤于⼤型组织机构
RabbitMQ开发始于2006年, 是由Rabbit Technologies开发并且提供商业⽀持的. 之所以取名为 Rabbit, 是因为兔⼦⾏动⾮常迅速且繁殖起来⾮常疯狂, RabbitMQ的开创者认为这个名字再合适不过 了2010年4⽉, Rabbit Technologies被 VMware 旗下的 SpringSource 收购, 在 2013 年 5 ⽉被并⼊ Pivotal其实 VMware, Pivotal 本质上是⼀家的. 不同的是VMware 是独⽴上市⼦公司, ⽽ Pivotal 是整合了 EMC的某些资源, 其中我们现在使⽤的 Spring 系列框架, 就是 Pivotal 公司热⻔的产品之⼀直到后来 Pivotal 将其开源, RabbitMQ 才逐渐⾛向⼤众RabbitMQ 发展到今天, 已经被越来越多的⼈认可, 尤其是互联⽹公司, 已经有着⼤规模的场景应⽤, 这和 它在易⽤性, 扩展性, 可靠性和⾼可⽤性等⽅⾯的卓越表现是分不开的. 接下来我们就⼀起来深⼊了解⼀ 下 RabbitMQ
RabbitMQ快速上手-Ubuntu安装
RabbitMQ已经包含在标准的Ubuntu仓库中, 然⽽包含的版本通常⽐最新的RabbitMQ发⾏版落后很 多可能提供的RabbitMQ版本已经不⽀持. RabbitMQ团队制作了⾃⼰的软件包并使⽤Cloudsmith 进⾏分发
具体操作可以参考: Installing on Debian and Ubuntu | RabbitMQ
由于该种⽅法安装⽐较复杂, 学习阶段, 咱们使⽤Ubuntu仓库中的版本来安装
安装Erlang
RabbitMq需要Erlang语⾔的⽀持在安装rabbitMq之前需要安装erlang
#更新软件包
sudo apt-get update
#安装erlang
sudo apt-get install erlang 查看erlang版本
erlErlang/OTP 22 [erts-10.6.4] [source] [64-bit] [smp:2:2] [ds:2:2:10] [asyncthreads:1]
Eshell V10.6.4 (abort with ^G)
退出命令:
halt(). 安装RabbitMQ
#更新软件包
sudo apt-get update
#安装rabbitmq
sudo apt-get install rabbitmq-server
#确认安装结果
systemctl status rabbitmq-server确认安装结果
systemctl status rabbitmq-server 安装RabbitMQ管理界⾯
默认是不安装管理界⾯的
rabbitmq-plugins enable rabbitmq_management 启动服务并访问
启动服务
若服务已经启动了, 此步省略
#启动rabbitmq
sudo service rabbitmq-server start 查看服务状态
systemctl status rabbitmq-server 通过 IP:port 访问界⾯
http:123.249.46.177:15672 默认⽤⼾名和密码都是: guest rabbitmq从3.3.0开始禁⽌使⽤guest/guest权限通过除localhost外的访问, 解除⽅法也有, 此处不多说 添加管理员⽤⼾
添加⽤⼾admin, 密码:admin
rabbitmqctl add_user ${账号} ${密码}
rabbitmqctl add_user admin admin 给⽤⼾添加权限
#rabbitmqctl set_user_tags ${账号} ${⻆⾊名称}
rabbitmqctl set_user_tags admin administrator
以下⻆⾊可选 RabbitMQ⽤⼾⻆⾊分为Administrator、Monitoring、Policymaker、Management、 Impersonator、None共六种⻆⾊
Administrator 超级管理员可登陆管理控制台(启⽤management plugin的情况下)可查看所 有的信息并且可以对⽤⼾策略(policy)进⾏操作Monitoring 监控者可登陆管理控制台(启⽤management plugin的情况下)同时可以查看 rabbitmq节点的相关信息(进程数内存使⽤情况磁盘使⽤情况等)Policymaker 策略制定者可登陆管理控制台(启⽤management plugin的情况下)同时可以对 policy进⾏管理。但⽆法查看节点的相关信息Management 普通管理者仅可登陆管理控制台(启⽤management plugin的情况下)⽆法看到 节点信息也⽆法对策略进⾏管理Impersonator 模拟者⽆法登录管理控制台None 其他⽤⼾⽆法登陆管理控制台通常就是普通的⽣产者和消费者
rabbitmqctl set_user_tags admin administrator 通过IP:port访问, 并使⽤刚才设置的⽤⼾名和密码登录 其他操作
修改端⼝号查找rabbitmq位置
whereis rabbitmq
rabbitmq: /usr/lib/rabbitmq /etc/rabbitmq新增配置⽂件rabbitmq.conf(在/etc/rabbitmq路径下创建rabbitmq.conf⽂件, 并添加以下内容)
#修改client端⼝为8942(默认为5672)
listeners.tcp.default8942
#修改管理界⾯端⼝为8943(默认为15672)
management.tcp.port8943
修改rabbitmq-defaults⽂件添加配置⽂件路径⽂件路径: /usr/lib/rabbitmq/lib/rabbitmq_server-3.8.30/sbin/rabbitmq-defaults编辑rabbitmq-defaults, 在⽂本最后添加如下代码
#添加配置路径到⽂件中保存退出
CONFIG_FILE/etc/rabbitmq/rabbitmq.conf重启RabbitMQ
sudo systemctl restart rabbitmq-server
服务相关
#启动服务
sudo systemctl start rabbitmq-server
#停⽌服务
sudo systemctl stop rabbitmq-server
#重启服务
sudo systemctl restart rabbitmq-server
#添加开机启动服务
sudo systemctl enable rabbitmq-server
#检查服务状态
sudo systemctl status rabbitmq-server
卸载RabbitMQ
停⽌RabbitMQ服务
sudo systemctl stop rabbitmq-serve
查找RabbitMQ安装情况
dpkg -l | grep rabbitmq
卸载rabbitmq已安装的相关内容
sudo apt-get purge --auto-remove rabbitmq-server
卸载Erlang查看erlang安装的相关列表
dpkg -l | grep erlang
卸载erlang已安装的相关内容
sudo apt-get purge --auto-remove erlang
以上就是RabbitMQ的概述和安装卸载过程了
