rabbitmq核心概念理解

2019-12-06 本文已影响0人只会写一点点代码

1、Connection（连接rabbitmq)
rabbitmq是遵循AMQP协议的，换句话说其实rabbitmq就是erlang语言实现的AMQP协议的封装，AMQP说到底就是一个通讯协议，协议就一定会包含报文的交互，协议就是人为规定好的，我们只要遵从AMQP协议定义好的命令，就如同我们熟悉的http协议一样，GET，POST等方法在AMQP中也有相应的命令在生产者和消费者连接到rabbitmq的流转过程下图所示：

rabbitmq生产者.png

rabbitmq 消费者.png
2、信道(channel)
上图还出现了一个channel的名称，我们知道其实建立连接以后其实就可以发送命令得到响应了，那为什么会出现信道这个概念呢，当建立了连接以后，其实就是创建了一个TCP连接，rabbitmq的信道就是在connection的基础上建立的，每个信道都会分配唯一的标示，而AMQP的指令都是通过信道传输的。

那我们思考为什么需要设计信道这个概念呢？
因为对于操作系统来说创建和销毁连接是一个很消耗性能的操作，当遇到高峰的时候，性能会出现瓶颈，rabbitmq采用多路复用的方式进行管理连接，信道复用了TCP连接，节省了资源提高了性能，到流量不大的时候，多个信道可以复用一个Connection。如图所示：
信道和连接.png
3、生产者和消费者
rabbitmq是依据生产者消费者模型，在官方文档中rabbitmq是这样的介绍自己的。

You can think about it as a post office: when you put the mail that you want posting in a post 
box, you can be sure that Mr. or Ms. Mailperson will eventually deliver the mail to your 
recipient. In this analogy, RabbitMQ is a post box, a post office and a postman.

生产者：生产者顾名思义就是消息的创建方，然后将创建好的消息发送到rabbitmq broker中；
broker：消息中间件的服务节点，换句话说就是一个rabbitmq服务；
消费者：消息的消费方，注意消费者只知道消费，他不知道生产这个消息的人是谁，但是谁也不重要；
4、队列(Queue)
rabbitmq中的一个内置的对象，就是一条队列，rabbitmq的消息只能存在队列里面
producer consumer.png
消费者订阅或者是监听一个队列，就可以获取到生产者发布到这个队列的数据，一个队列可以有多个消费者，但是rabbitmq不支持广播的操作，多个消费者监听同一条队列，队列的消息会被平均分摊到多个消费者身上。
5、交换器，路由键，绑定关系(exchange,Routingkey,Binding)
交换器也是rabbitmq的一个内置对象，生产者生产完消息不是一下子就扔到队列中，而是先要经过一层交换器，交换器根据消息的类型路由到一个或多条队列中，如果找不到目标，可能会消息丢失或者返回给生产者。
交换器.png
那交换器是如何路由的，它是如何知道那条消息该被送到哪？
当生产者发送消息的时候，会对消息进行一个标示，就是标示消息应该被发送到哪一条队列，rabbitmq叫这个标示为路由键RoutingKey，而这个路由键必须和交换机类型绑定在一起才可以使用。
绑定：绑定是就rabbitmq把交换器和队列关联起来的一种方式，在绑定的时候会指定一个BindingKey
结论：这三种概念的关系我们来捋一下，当生产者发送消息到交换器的时候需要一个Routingkey，当bindingkey和Routingkey相同的时候就知道这个消息该送到哪个队列了，这几个概念确实比较绕，让人摸不得头脑。
沿用rabbitmq官方文档的比喻，把rabbitmq比喻为邮局，那交换器就是邮局门口的一个邮筒，生产者就是一个来寄件人，他把消息封装在信封里，但是信封上必须写上一些信息，这个信息就包含了地址，这个地址就是RoutingKey，比如寄到XX大学，而bindingkey就是这个邮筒会到的地址，如果一看这个新建信件的地址和这个邮筒的地址一致，那皆大欢喜，走你，就去了该去的地方，如果地址错了，不好意思，丢掉或者原路返回。其实在一定情况下这两个玩意就是一个东西。有没有发现。都是地址嘛。所以这个和交换器的类型有关。
6、交换器的类型
1、fanout
此种交换器会将接收到的消息发送给所有与该交换器绑定的队列中；
这个类型的队列就会无视BindingKey。
2、direct
此种交换器会把消息发送到RoutingKey和BindingKey相匹配的队列中；

       //定义一个direct的类型的交换器 名字叫hello
        channel.exchangeDeclare("hello","direct");

        //定义一条队列，名字叫helloWorld
        channel.queueDeclare("helloWorld",true,false,false,null);

        //将队列和交换机进行一个绑定
        channel.queueBind("helloWorld","hello","hello");

Queue.BindOk queueBind(String queue, String exchange, String routingKey) throws IOException;
这个是java的绑定源代码，绑定关系不是应该使用BindingKey吗？这里使用了Routingkey
因为direct类型必须要RoutingKey和BindingKey一摸一样才匹配，这样就给我们了一个潜台词
这两个玩意就是一个东西。
channel.basicPublish("hello","hello",MessageProperties.TEXT_PLAIN,"pujinwen".getBytes());

3、topic
这是因为direct的不灵活性，因为一个全等于，让很多业务没办法写，所以出来了topic，他支持一个Routingkey和bindingKey的模糊匹配。支持模糊匹配符号。

4、header
性能很差 ,就不介绍了，是根据发送信息的信息header内容做匹配；

官方文档把这个BindingKey认为是一种特殊的Routingkey，所以我们都称之为路由键，

rabbitmq核心概念理解

猜你喜欢

热点阅读