RabbitMQ理论

消息 = 有效载荷(数据) + 标签(包含载荷和收件人的信息)

信道:你的应用于RabbitMQ代理服务器之间的TCP连接(有唯一的ID),信道主要解决了每一个线程单独TCP连接造成的性能瓶颈。

AMQP:高级消息队列协议(Advance Message Queuing protocol)

AMQP 栈 = 交换器 + 队列 + 虚拟主机 (提高了吞吐量)

交换器类型:

direct(默认):按照路由键分发

fanout:广播分发给每一个订阅者

topic: 按照主题分发

headers(只匹配消息的header,很少用)

交换器与队列之间存在绑定。

如何让消息持久化?

1:将消息表示为持久化的:

durable属性设置为true 、投递模式 delivery model 设置为2

2:必须发布到持久化的交换器中,并且到达持久化的队列中

这样的消息会写入磁盘持久化日志文件(写好之后才会响应给生产者,消息被消费之后要标为等待垃圾收集。)

命令:

1:自动接收消费信息:basic.consume:

2:只获取单条信息:basic.get

3:丢弃一条消息:将requeue设置为false,消息放入死亡队列

4:创建队列:queue.declare(不指定队列的名字,会返回随机名称,在订阅和绑定时都会用到队列名称,匿名队列在构建RPC应用时会很有用)

5:队列的设置:

exclusive:true 表示私有队列,只有自己的应用能够订阅。

auto-delete:true 表示最后一个消费者取消订阅之后,队列自动移除

exclusive + auto-delete这两个命令常常组合在一起使用。

6:如何检测队列是否存在?

设置 queue.declare的passive属性为true,队列会让queue.declare返回成功,否则返回错误

7:查看运行的虚拟机:rabbitmpctl list vhost

多个消费者订阅了同一个队列:按照一个订阅者一条消息公平分发(因此具有负载均衡的作用),消费者受到消息必须向RabbitMQ回复确认(basic.ack),RabbitMQ将消息从队列里面删除。在应用崩溃时,RabbitMQ没有受到确认,会将消息分发给下一个订阅者,且不会再为此订阅者分发消息,人为该订阅者已经挂掉。

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zwdpjj.html