标签:快速 服务器 速度 服务 nload rac 有限公司 机器 edr
RabbitMQ是一套开源(MPL)的消息队列服务软件,是由LShift提供的一个Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的Erlang写成。所有主要的编程语言均有与代理接口通讯的客户端库。RabbitMQ由Rabbit科技有限公司开发,并提供对其的支持。起初,Rabbit科技是LSHIFT和CohesiveFT在2007年成立的合资企业,2010年4月被VMware旗下的SpringSource收购。RabbitMQ在2013年5月成为GoPivotal的一部分。
AMQP:高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。消息中间件主要用于组件之间的解耦,消息的发送者无需知道消息使用者的存在,反之亦然。AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全。RabbitMQ是一个开源的AMQP实现,服务端用erlang语言编写,支持多种客户端,如:Python、Ruby、.NET、Java、JMS,支持AJAX等。用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现较好。
1、可靠性(Reliability)
rabbitmq使用一些机制来保证可靠性,如持久化、传输确认、发布确认。
2、灵活的路由(Flexible Routing)
在消息进入队列之前,是通过Exchange来路由信息的。对于典型的路由功能,rabbitmq已经提供了一些内置的Exchange来实现。针对更复杂的路由功能,可以将多个Exchange绑定在一起,也可以通过插件机制实现自己的Exchange。
3、消息集群(Clustering)
多个RabbitMQ服务器可以组成一个集群,形成一个逻辑Broker(服务)。
4、高可用(Highly Available)
队列可以在集群中的机器上进行镜像,使得在部分节点出问题的情况下队列仍然可用,也就是具有可伸缩性。
5、多种协议(Multi-protocol)
rabbitmq支持多种消息队列协议,如STOMP、MQIT等。
6、多语言客户端(Many Clients)
rabbitmq几乎支持所有的常用语言,如Java、.net、Ruby、Python等。
7、管理界面(Mangement UI)
rabbitmq提供了一个易用的用户界面,使得用户可以监控和管理消息Broker的许多方面。
8、跟踪机制(Tracing)
如果消息异常,rabbitmq提供了消息跟踪机制,使用者可以找出发生了什么。
9、插件机制(Plugin System)
rabbitmq提供了许多插件来从多方面进行扩展,使用者也可以编写自己的插件。
参考博文:https://segmentfault.com/a/1190000019122774?utm_source=tag-newest
消息队列和RPC的区别与比较
RPC: 异步调用,及时获得调用结果,具有强一致性结果,关心业务调用处理结果。
消息队列:两次异步RPC调用,将调用内容在队列中进行转储,并选择合适的时机进行投递(错峰流控)。
核心概念:它是基于消息的模型,关心的是“通知”,而非“处理”。
rabbitmq常见使用场景:解耦、异步、削峰。
1、 解耦(为面向服务的架构(SOA)提供基本的最终一致性实现)
2、异步提升效率
场景说明:用户注册后,需要发注册邮件和注册短信。传统的做法有两种:串行的方式、并行方式。
(2)并行方式:将注册信息写入数据库成功后,发送注册邮件的同时发送注册短信。以上三个任务完成后,返回给客户端。与串行的差别是,并行的方式可以减少处理的时间。
3、流量削峰(流量控制)
流量削锋也是消息队列中的常用场景,主要是利用消息队列来进行流量控制,一般在秒杀或团抢活动中使用广泛。
应用场景:系统其他时间A系统每秒请求量就100个,系统可以稳定运行。系统每天晚间八点有秒杀活动,每秒并发请求量增至1万条,但是系统最大的处理能力只能每秒处理1000个请求,于是系统崩溃,服务器宕机。
之前架构:大量用户(100万用户)通过浏览器在晚上八点高峰期同时参与秒杀活动。大量的请求涌入我们的系统中,高峰期达到每秒钟5000个请求,大量的请求打到MySQL上,每秒钟预计执行3000条SQL。但是一般的MySQL每秒钟扛住2000个请求就不错了,如果达到3000个请求的话可能MySQL直接就瘫痪了,从而导致系统无法使用。但是高峰期过了之后,就成了低峰期,可能也就1万用户访问系统,每秒的请求数量也就50个左右,整个系统几乎没有任何压力。
引入MQ:100万用户在高峰期的时候,每秒请求有5000个请求左右,将这5000个请求写入MQ里面,系统A每秒最多只能处理2000请求,因为MySQL每秒只能处理2000个请求。系统A从MQ中慢慢拉取请求,每秒就拉取2000个请求,不要超过自己每秒能处理的请求数量即可。MQ每秒5000个请求进来,结果只有2000个请求出去,所以在秒杀期间(将近一小时)可能会有几十万或者几百万的请求积压在MQ中,并且这个短暂的高峰期积压是没问题的,因为高峰期过了之后,每秒就只有50个请求进入MQ了,但是系统还是按照每秒2000个请求的速度在处理,所以说只要高峰期一过,系统就会快速将积压的消息消费掉。我们在此计算一下,每秒在MQ积压3000条消息,1分钟会积压18万,1小时积压1000万条消息,高峰期过后,1个多小时就可以将积压的1000万消息消费掉。如下图所示:
4、引入消息队列的优点
引入消息队列可以对系统进行解耦、在流量很大时可以进行流量控制,进行流量削峰。
5、引入消息队列的缺点
以上部分参见博文:https://www.cnblogs.com/haixiang/p/10199754.html
1、由于RabbitMQ是使用erlang语言编写的,因此在安装rabbitmq之前需要安装erlang,需要注意的是安装路径都不要有空格。
erlang官网地址(下载比较慢):https://www.erlang.org/downloads
erlang国内下载镜像: https://www.erlang-solutions.com/resources/download.html
2、erlang环境变量设置
Erlang使用了环境变量HOMEDRIVE与HOMEPATH来访问配置文件.erlang.cookie,应注意这两个环境变量的有效性。需要设定环境变量ERLANG_HOME,并把%ERLANG_HOME%\bin加入到全局路径中。
环境变量的设置可参见博文:https://blog.csdn.net/weixin_40822435/article/details/105738375
3、RabbitMQ使用本地computer name作为服务器的地址,因此需要注意其有效性(不要有中文或者空格),或者直接解析为localhost / 127.0.0.1。
4、rabbitmq下载官方地址:https://www.rabbitmq.com/download.html
5、安装完成之后进入rabbitmq后台: http://localhost:15672/ 默认用户名和密码均为guest
有时候会安装失败,那么可以卸载之后重新安装,具体参见如下博文:
(1) https://blog.csdn.net/lishaojun0115/article/details/53145051 (彻底删除erlang)
(2) http://www.manongjc.com/article/17163.html (rabbitmq服务启动闪退问题解决)
6、rabbitmq安装之后没有在服务中显示RabbitMQ
在服务中没有看到RabbitMQ服务,则cmd进入rabbitmq安装sbin目录执行命令 rabbitmq-service.bat install 将rabbitmq服务安装到服务中,之后就能看到了。
前提:cmd进入rabbitmq安装目录sbin目录。
1、启动:执行 rabbitmq-server.bat start 命令启动rabbitmq服务。
2、关闭:执行 rabbitmqctl.bat stop 关闭rabbitmq服务。
标签:快速 服务器 速度 服务 nload rac 有限公司 机器 edr
原文地址:https://www.cnblogs.com/jasonboren/p/13279975.html