码迷,mamicode.com
首页 > 其他好文 > 详细

RabbitMQ 笔记一

时间:2017-08-29 09:28:13      阅读:153      评论:0      收藏:0      [点我收藏+]

标签:创建   cti   操作   消费者   消费   nfa   状态   阻塞   factor   

ConnectionFactory、Connection、Channel

       ConnectionFactory、Connection、Channel,这三个都是RabbitMQ对外提供的API中最基本的对象。不管是服务器端还是客户端都会首先创建这三类对象。
       ConnectionFactory为Connection的制造工厂。

       Connection是与RabbitMQ服务器的socket链接,它封装了socket协议及身份验证相关部分逻辑。

       Channel是我们与RabbitMQ打交道的最重要的一个接口,大部分的业务操作是在Channel这个接口中完成的,包括定义Queue、定义Exchange、绑定Queue与Exchange、发布消息等。

Queue

       Queue(队列)是RabbitMQ的内部对象,用于存储消息

  RabbitMQ中的消息都只能存储在Queue中,生产者(下图中的P)生产消息并最终投递到Queue中,消费者(下图中的C)可以从Queue中获取消息并消费。

  队列是有Channel声明的,而且这个操作是幂等的。同名的队列多次声明也只会创建一次。我们发送消息就是想这个声明的队列里发送消息

QueueingConsumer

       队列消费者,用于监听队列中的消息。调用nextDelivery方法时,内部实现就是调用队列的take方法。该方法的作用:获取并移除此队列的头部,在元素变得可用之前一直等待(如果有必要)。说白了就是如果没有消息,就处于阻塞状态。

RabbitMQ 笔记一

标签:创建   cti   操作   消费者   消费   nfa   状态   阻塞   factor   

原文地址:http://www.cnblogs.com/m2492565210/p/7446628.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!