首页 > 程序开发 > 软件开发 > 其他 >

RabbitMQ简介、信道(channel)

2018-04-11

RabbitMQ简介、信道(channel)。

一、RabbitMQ简介

RabbitMQ是使用Erlang编写的消息队列,采用AMQP协议传输

二、信道(channel)

信道是建立在真实的TCP连接内的虚拟连接。AMQP的命令都是通过信道发送出去的,每条信道都会被指派一个唯一ID。一个TCP连接,对应多个信道,理论上无限制,减少TCP创建和销毁的开销,实现共用TCP的效果

注:一个生产者或一个消费者与MQ服务器之间只有一条TCP连接

三、虚拟主机(vhost)

每一个vhost可以理解为一个RabbitMQ服务器,拥有自己的队列、交换器、绑定、权限机制

四、交换器(exchange)

1、headers交换器:允许匹配AMQP消息的header而非路由键

2、direct交换器:路由键匹配,消息就被投递到对应的队列

3、fanout交换器:会将收到的消息广播到绑定的队列上

4、topic交换器:使来自不同源头的消息能够到达同一个队列

五、队列(queue)

1、推模式:通过AMQP的basic.consume命令订阅,有消息会自动接收,吞吐量高

2、拉模式:通过AMQP的bsaic.get命令

注:当队列拥有多个消费者时,队列收到的消息将以循环的方式发送给消费者。每条消息只会发送给一个订阅的消费者

六、持久化(duration)

开启持久化功能,需同时满足:消息投递模式选择持久化、交换器开启持久化、队列开启持久化

七、确认机制(ack)

1、发送方确认模式:消息发送到交换器–发送完毕–>消息投递到队列或持久化到磁盘异步回调通知生产者

2、消费者确认机制:消息投递消费者-ack-删除该条消息-投递下一条

注:收到ACK前,不会把消息再次发送给该消费者,但是会把下一条消息发送给其他消费者

八、消费者拒绝策略

1、断开连接,消息重新入队,发送给下一个消费者

2、reject命令,根据参数确定消息重新入队还是丢弃

相关文章
最新文章
热点推荐