1.RabbitMQ简介
一、RabbitMQ简介
1、什么是RabbitMQ
1.1.1、简介
RabbitMQ是一个广泛使用的消息服务器,采用Erlang语言编写,是一种开源的、实现了 AMQP(高级消息队列协议)的消息中间件；
RabbitMQ最初起源于金融系统,它的性能及稳定性都非常出色；
AMQP协议(http://www.amqp.org)即高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计；
1.1.2、相关网址
官网:https://www.rabbitmq.com
Github:https://github.com/rabbitmq
rabbitmq-java-client:https://github.com/rabbitmq/rabbitmq-java-client
1.1.3、消息中间件
MQ=Message Queue
简单来说消息中间件就是指保存数据的一个容器(服务器),可以用于两个系统之间的数据传递
消息中间件一般有三个主要角色:生产者、消费者、消息代理(消息队列、消息服务器)；
rabbitmq-java-client rabbitmq-server rabbitmq-java-client
生产者发送消息到消息服务器,然后消费者从消息代理(消息队列)中获取数据并进行处理；
1.1.4、常用的消息中间件
目前比较主流的几个消息中间件
- RabbitMQ
- kafka(大数据领域)
- RocketMQ(阿里巴巴开源):献给Apache组织
- pulsar(最近一两年流行起来的)
2、MQ的应用场景
1.2.1、异步提速
-
同步是阻塞的(会造成等待)
采用同步方式,用户从注册到响应成功,需要先保存注册信息,再发送邮件通知,邮件发送成功后再发送短信通知,短信发送成功后才通知用户成功,用户体验不好
-
异步是非阻塞的(不会等待)
采用异步方式,保存用户信息后,短信通知和邮件通知消息写入MQ(耗时极短),极大的缩短了响应时间
大流量高并发请求、批量数据传递,就可以采用异步处理,提升系统吞吐量；
1.2.2、系统解耦
多个系统之间不需要直接交互,通过消息进行业务流转；
比如A系统向MQ发送业务消息,其它系统按需接收A系统发送的消息并进行相应的处理即可
省去了A系统调用B系统、调用C系统、调用D系统等过程,实现了系统间的解耦合
1.2.3、流量削峰
高负载请求/任务的缓冲处理；
当短时间内有大量请求到了,可以将请求发送到消息队列,又客户端匀速的消费消息,不会对系统造成巨大的压力
1.2.4、日志处理
主要是用kafka这个服务器来做；
日志处理是指将消息队列用于在日志处理中
-
Kafka解决大量日志传输的问题
loger.info(…)
-
ELK 日志处理解决方案
日志处理是指将消息队列用于在日志处理中
-
Kafka解决大量日志传输的问题
loger.info(…)
-
ELK 日志处理解决方案
loger.error(…) -->logstash收集消息–> 发送消息的kafka --> elastic search(es) -->Kibana ELK日志处理平台