RabbitMQ系列(二)--基础组件 - Diamond-Shine - 博客园

来源: RabbitMQ系列(二)–基础组件 – Diamond-Shine – 博客园

声明:对于RabbitMQ的学习基于某课网相关视频和《RabbitMQ实战指南》一书,后续关于RabbitMQ的博客都是基于二者

一、什么是RabbitMQ

RabbitMQ是开源代理和队列服务器,通过普通协议在不同的应用之间共享数据,使用Erlang编写(Erlang进行数据交换的性能很好,

和原生socket一样好的延迟响应效果),基于AMQP协议

二、AMQP

AMQP高级消息队列协议:具有现代特征的二进制协议,和JMS有点像,模型如下:

AMQP核心概念

1、Server:Broker,接受client连接,实现AMQP实体服务

2、Connection:应用程序和Broker的网络连接

3、Channel:网络信道,读写都是在Channel中进行(NIO的概念),包括对MQ进行的一些操作(例如clear queue等)都是在Channel中进行,

客户端可建立多个Channel,每个Channel代表一个会话任务

4、Message:由properties(有消息优先级、延迟等特性)和Body(消息内容)组成

5、Virtual host:用于消息隔离(类似Redis 16个db这种概念),最上层的消息路由,一个包含若干Exchange和Queue,同一个里面Exchange

和Queue的名称不能存在相同的。

6、Exchange:Routing and Filter

7、Binding:把Exchange和Queue进行Binding

8、Routing key:路由规则

9、Queue:物理上存储消息

三、哪些大厂在使用RabbitMQ,为什么?

滴滴、美团、头条、去哪儿。。。。都再使用RabbitMQ

原因:

1、开源、性能优秀、能保证稳定性,提供可靠性消息投递模式confirm、返回模式return,和springAMQP完美整合、API丰富

2、集群模式丰富,表达式配置,HA模式,镜像队列模式

3、保证数据不丢失的前提下做到高可靠性、高可用性

四、RabbitMQ基础组件

1、Exchange:

如果不指定Exchange的话,RabbitMQ默认使用,(AMQP default)注意一下,需要将routing key等于queue name相同

2、name、type:

fanout(效率最好,不需要routing key,routing key如何设置都可以)、direct、topic(#一个或多个,*一个)、headers

3、Auto Delete:

当最后一个Binding到Exchange的Queue删除之后,自动删除该Exchange

4、Binding:

Exchange和Queue之间的连接关系,Exchange之间也可以Binding

5、Queue:

实际物理上存储消息的

6、Durability:

是否持久化,Durable:是,即使服务器重启,这个队列也不会消失,Transient:否

7、Exclusive:

这个queue只能由一个exchange监听restricted to this connection,使用场景:顺序消费

8、Message:

由properties(有消息优先级、延迟等特性)和Body(Payload消息内容)组成,还有content_type、content_encoding、priority

correlation_id、reply_to、expiration、message_id等属性

五、安装

本人很早之前在centos安装过了,具体步骤都忘了,大家可以百度一下,有一大堆呢,比较推荐Docker安装,很方便

需要注意:注意rabbitMQ和erlang版本的对应,而且服务器的host name不要瞎改,当初RabbitMQ一直启动报错,就是这个原因,搞了两天,真的

蛋疼,先要确定erlang安装成功,然后按照RabbitMQ

浏览器可视化工具:rabbitmq-plugins enable rabbitmq_management  用户名、密码:guest guest

 

赞(0) 打赏
分享到: 更多 (0)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏