网站上传的工具,网站建设企业建站,虚拟空间的网站赚钱吗,网上做实验的网站Hi~#xff01;这里是奋斗的明志#xff0c;很荣幸您能阅读我的文章#xff0c;诚请评论指点#xff0c;欢迎欢迎 ~~ #x1f331;#x1f331;个人主页#xff1a;奋斗的明志 #x1f331;#x1f331;所属专栏#xff1a;RabbitMQ #x1f4da;本系列文章为个人学… Hi~这里是奋斗的明志很荣幸您能阅读我的文章诚请评论指点欢迎欢迎 ~~ 个人主页奋斗的明志 所属专栏RabbitMQ 本系列文章为个人学习笔记在这里撰写成文一为巩固知识二为展示我的学习过程及理解。文笔、排版拙劣望见谅。 Ubuntu 环境安装 前言一、什么是MQ消息队列MQ多用于分布式系统之间进行通信 二、MQ的作用1、异步解耦2、流量削峰3、消息分发4、延迟通知 三、为什么选择 RabbitMQ1、Kafka2、RocketMQ3、RabbitMQ 四、RabbitMQ 快速上手1、Ubuntu 环境安装2、安装Erlang3、查看erlang版本 五、安装RabbitMQ1、安装2、确认安装结果 六、安装RabbitMQ管理界面七、启动服务并访问1、通过 IP:port 访问界面2、添加管理员用户3、给用户添加权限4、通过IP:port访问, 并使用刚才设置的用户名和密码登录5、通过set设置权限6、添加用户7、添加虚拟机 前言 Rabbit, 兔子的意思 互联网行业很多公司, 都喜欢用动物命名产品, 或者作为公司的logo, 吉祥物. 比如: 腾讯的企鹅, 京东的狗, 美团的袋鼠, 携程的海豚,阿里就更多了, 蚂蚁, 飞猪,天猫,菜鸟, 闲鱼, 盒马… 更是以一己之力, 组建了一个动物园… Rabbit 也是⼀个公司名. MQ ( message queue ) 消息队列 的意思 , RabbitMQ 是 Rabbit企业下的⼀个消息队列产品. RabbitMQ 是⼀个实现了 AMQP 的 消息队列 服务,是当前主流的消息中间件之⼀. AMQP即Advanced Message Queuing Protocol(⾼级消息队列协议)是⼀个通⽤的应⽤层协议提供统⼀消息服务的协议, 为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息并不受客户端或中间件, 开发语言等条件的限制。 在互联网架构中, 会经常使用MQ来作为消息通信服务. 接下来我们看下什么是MQ 一、什么是MQ消息队列 MQ( Message queue ), 从字面意思上看, 本质是个队列, FIFO 先⼊先出只不过队列中存放的内容 是消息(message)⽽已. 消息可以非常简单,比如只包含文本字符串, JSON等,也可以很复杂, 比如内嵌对象. 在日常生活中例如手机、水杯…可能会进行一些排队摆放 MQ多用于分布式系统之间进行通信
系统之间的调用通常有两种方式同步通信 直接调用对方的服务, 数据从一端发出后立即就可以达到另⼀端 异步通信 数据从⼀端发出后先进入⼀个容器进行临时存储当达到某种条件后再由这个容器发送给另⼀端. 容器的⼀个具体实现就是MQ( message queue ) RabbitMQ 就是MQ的⼀种实现 例如 打电话客服直接响应 客服记录下来过一段时间24小时内进行回复 二、MQ的作用
MQ主要工作是接收并转发消息, 在不同的应用场景下可以展现不同的作用 可以把MQ想象成一个仓库. 采购部门进货之后, 把零件放进仓库里 生产部门从仓库中取出零件, 并加工成产品. MQ和仓库的区别是, 仓库里放的是物品, MQ里放的是消息 仓库负责存储物品,并转发物品,MQ负责存储和转发消息 1、异步解耦
在业务流程中, ⼀些操作可能非常耗时, 但并不需要即时返回结果. 可以借助MQ把这些操作异步化, 比如用户注册后发送注册短信或邮件通知, 可以作为异步任务处理, 而不必等待这些操作完成后才告知用户注册成功 2、流量削峰
在访问量剧增的情况下, 应用仍然需要继续发挥作用, 但是这样的突发流量并不常见. 如果以能处理这类峰值为标准而投入资源,无疑是巨大的浪费. 使用MQ能够使关键组件支撑突发访问压力, 不会因为突发流量而崩溃. 比如秒杀或者促销活动, 可以使用MQ来控制流量, 将请求排队, 然后系统根据自己的处理能力逐步处理这些请求. 例如12306 节假日的时候进行买票不可能在这个时候买入多台机器 商场人多的时候进行排队
3、消息分发
当多个系统需要对同⼀数据做出响应时, 可以使用MQ进行消息分发. 比如支付成功后, 支付系统可以向MQ发送消息, 其他系统订阅该消息, 而无需轮询数据库.
4、延迟通知
在需要在特定时间后发送通知的场景中, 可以使用MQ的延迟消息功能, 比如在电⼦商务平台中如果用户下单后⼀定时间内未⽀付可以使用延迟队列在超时后自动取消订单 例如会议时间提前通知
… 三、为什么选择 RabbitMQ
⽬前业界有很多的MQ产品, 例如RabbitMQ, RocketMQ, ActiveMQ, Kafka, ZeroMQ等, 也有直接使用Redis充当消息队列的案例, 这些消息队列, 各有侧重, 也没有好坏, 只有适合不适合, 在实际选型时, 需要结合自身需求以及MQ产品特征, 综合考虑
以下我们介绍⼀下当前最主流的3种MQ产品
1、Kafka
Kafka⼀开始的目的就是用于日志收集和传输追求高吞吐量, 性能卓越, 单机吞吐达到⼗万级, 在日志领域比较成熟, 功能较为简单主要⽀持简单的 MQ 功能, 如果有⽇志采集需求,肯定是首kafka了。
2、RocketMQ
RocketMQ采⽤Java语⾔开发, 由阿⾥巴巴开源, 后捐赠给了Apache. 它在设计时借鉴了Kafka并做出了⼀些自己的改进, ⻘出于蓝⽽胜于蓝, 经过多年双⼗⼀的洗礼, 在 可⽤性、可靠性以及稳定性等⽅⾯都有出⾊的表现. 适合对于可靠性⽐较⾼,且并发⽐较⼤的场景, ⽐ 如互联⽹⾦融. 但⽀持的客户端语⾔不多, 且社区活跃度⼀般
3、RabbitMQ
采⽤Erlang语言开发, MQ 功能⽐较完备, 且几乎⽀持所有主流语言开源提供的界面也非常友好, 性能较好, 吞吐量能达到万级, 社区活跃度也⽐较高比较适合中小型公司, 数据量没那么大 且并发没 那么高的场景.
四、RabbitMQ 快速上手
接下来我们来进行RabbitMQ的安装, 并进行入门程序的演示,让大家对于RabbitMQ有⼀个更加直观的感受. RabbitMQ 是⼀套开源的消息队列服务软件, 基于 Erlang 语言编写, 所以安装RabbitMQ之前, 需要先安装部署 Erlang 环境, 再安装 RabbitMQ 环境. RabbitMQ大多部署在Linux操作系统 1、Ubuntu 环境安装 RabbitMQ已经包含在标准的Ubuntu仓库中, 然而包含的版本通常比最新的RabbitMQ发⾏版落后很多可能提供的RabbitMQ版本已经不⽀持. RabbitMQ团队制作了自己的软件包并使Cloudsmith 进行分发 具体操作可以参考: https://www.rabbitmq.com/docs/install-debian 由于该种方法安装比较复杂, 学习阶段, 咱们使⽤Ubuntu仓库中的版本来安装
2、安装Erlang RabbitMq需要Erlang语言的支持在安装rabbitMq之前需要安装erlang #更新软件包
sudo apt-get update
#安装erlang
sudo apt-get install erlang22 以上的版本会出现以下这个界面 这个时候按Esc键就行 出现以下界面就好了 3、查看erlang版本
roothcss-ecs-0bb1:~# erl
Erlang/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(). Ctrl c 也能退出 五、安装RabbitMQ
1、安装
#更新软件包
sudo apt-get update
#安装rabbitmq
sudo apt-get install rabbitmq-server
#确认安装结果
systemctl status rabbitmq-server这里也会出现紫色的跟上面操作一样 按 Esc 键 2、确认安装结果 表示安装成功 六、安装RabbitMQ管理界面 默认是不安装管理界⾯的 roothcss-ecs-0bb1:~# rabbitmq-plugins enable rabbitmq_management
#启动3个插件七、启动服务并访问
1、通过 IP:port 访问界面
http://110.41.51.65:15672/ (15672 为默认端⼝号, 云服务器需要开启端⼝)) 默认⽤户名和密码都是: guest rabbitmq从3.3.0开始禁⽌使⽤guest/guest权限通过除localhost外的访问, 解除方法也有 对阿里云的服务器的防火墙进行设置 2、添加管理员用户 添加用户 admin , 密码: admin # rabbitmqctl add_user ${账号} ${密码}
rabbitmqctl add_user admin admin3、给用户添加权限
#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 其他⽤户⽆法登陆管理控制台通常就是普通的⽣产者和消费者
4、通过IP:port访问, 并使用刚才设置的用户名和密码登录 重点了解 这里的虚拟机是一个逻辑上的隔离 类似于 mysql 的database 5、通过set设置权限 6、添加用户 添加成功
7、添加虚拟机 使用哪个用户的设置的虚拟机就对这个有一定的权限
