RabbitMQ 01 概述

什么是消息队列

进行大量的远程调用时,传统的Http方式容易造成阻塞,所以引入了消息队列的概念,即让消息排队,按照队列进行消费。

它能够将发送方发送的信息放入队列中,当新的消息入队时,会通知接收方进行处理,一般消息发送方称为生产者,接收方称为消费者

这样所有的请求,都可以丢到消息队列中,再由消费者取出,不再是直接连接消费者的形式了,而是加了一个中间件,这是一种很好的解耦方案。并且在高并发的情况下,由于消费者能力有限,消息队列也能起到一个削峰填谷的作用,堆积一部分的请求,再由消费者来慢慢处理,而不会像直接调用那样请求蜂拥而至。

消息队列组件

ActiveMQ、RabbitMQ、RocketMQ、Kafka是目前主流的消息队列组件。它们的特点如下:

综合以上因素,这里选择RabbitMQ作为消息队列组件进行演示。原因如下:

  • 吞吐量虽然不高,但中小型项目完全足够。
  • 时效性强。延迟达到微妙级别,较同类产品延迟最低。
  • 可用性强。提供了完善的高可用实现机制。
  • 可靠性强。基本不会丢包。
  • 并发能力强。基于Erlang开发,提供了丰富的交换机功能,性能好、延时低。
  • 开源免费。没有使用成本,且社区活跃度高,产品稳定。

消息队列组件的功能和实现是大同小异的,学习好一个组件就可以做到一通百通,而且还有Spring Cloud Stream这样的消息队列连接组件,可以屏蔽各消息队列组件的差异性,使用统一的标准调用消息队列组件。

所以,想要掌握消息队列,从RabbitMQ入手是一个比较好的选择。

RabbitMQ

官方网站:https://www.rabbitmq.com

RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的,而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。

Rabbit科技有限公司开发了RabbitMQ,并提供对其的支持。

  • 起初,Rabbit科技是LSHIFT和CohesiveFT在2007年成立的合资企业。
  • 2010年4月被VMware旗下的SpringSource收购。
  • RabbitMQ在2013年5月成为GoPivotal的一部分。

其特点如下:

  • 拥有数万计的用户,是最受欢迎的开源消息队列之一,从T-Mobile到Runtastic,RabbitMQ在全球范围内用于小型初创企业和大型企业。
  • 轻量级,易于在本地和云端部署,它支持多种消息协议。
  • 可以部署在分布式和联合配置中,以满足大规模、高可用性要求。
  • 在许多操作系统和云环境中运行,并为大多数流行语言提供了广泛的开发者工具

运行过程:

  • 生产者(Publisher):生产消息的终端。
  • 信道(Channel):服务端和客户端连接都会使用一个Channel,再通过Channel去访问到RabbitMQ服务器。这里的通信协议不是http,而是amqp协议。
  • 虚拟主机(Virtual Host):类似于环境隔离,不同环境都可以单独配置一个Virtual Host,每个Virtual Host可以包含很多个Exchange和Queue,每个Virtual Host相互之间不影响。
  • 交换机(Exchange):根据请求,转发给相应的消息队列,每个队列都可以绑定到Exchange上,这样Exchange就可以将数据转发给队列了,可以存在很多个,不同的Exchange类型可以用于实现不同消息的模式。
  • 消息队列(Queue):消息队列本体,生产者所有的消息都存放在消息队列中,等待消费者取出。
  • 消费者(Consumer):消费消息的终端。

猜你喜欢

转载自blog.csdn.net/qq_37770674/article/details/130436842