0
点赞
收藏
分享

微信扫一扫

【Redis】Transaction(事务)

腾讯优测 2023-07-13 阅读 69

I. RabbitMQ的基本概念

1. 生产者/消费者

  • 生产者(Producer)
    消息的创建者。
    负责创建和推送数据到消息服务器。

  • 消费者(Consumer)
    消息的接收方。
    负责接收消息和处理数据。

2. 消息队列(Queue)

消息队列是RabbitMQ的内部对象,用于存储生产者的消息直到发送给消费者,它是消费者接收消息的地方。

消息队列的重要属性:

  • 持久性
    broker重启前都有效。
  • 自动删除
    在所有消费者停止使用之后自动删除。
  • 惰性
    没有主动声明队列,调用会导致异常。
  • 排他性
    -一旦启用,声明它的消费者才能使用。

3. 交换机(Exchange)

交换机用于接收,分配消息。

1. 生产者要先指定一个routing key,然后将消息发送到交换机。
2. routing key需要与exchange type和binding key联合使用才能最终生效。
3. 交换机将消息路由到一个或多个队列中,或丢弃。

交换机包含4中类型: direct, topic, fanout, headers。

  • direct(直连交换机)
具有路由功能的交换机,绑定到此交换机的时候需要指定一个routing_key,交换机发送消息的时候需要routing_key,会将消息发送道对应的队列。

先匹配,再投送

在绑定队列时会设定一个routing key(通常是队列的名字)。
只有在消息的routing key与队列匹配时,消息才会被交换机投送到绑定的队列中。

  • topic(主题交换机)

    在直连交换机基础上增加模式匹配,也就是对routing_key进行模式匹配,*代表一个单词,#代表多个单词。

    按规则转发消息
在这种交换机模式下,路由键(routing key)必须是一串字符,用"."隔开。
路由模式必须包含一个星号"*", 主要用于匹配路由键指定位置的一个单词。
* 匹配一个单词。
# 匹配0个或多个单词。
eg:
binding key:                 *.com.#
匹配的routing key:     cn.com,  us.com.aa
不匹配:                         com.bb

  • headers(首部交换机)
    忽略routing_key,使用Headers信息(一个Hash的数据结构)进行匹配,优势在于可以有更多更灵活的匹配规则。
    根据应用程序消息的特定属性进行匹配

  • fanout(扇形交换机)
    广播消息到所有队列,没有任何处理,速度最快。
    消息广播的模式

4. 消息确认

消息确认是指当一个消息从队列中投递给消费者(consumer)后,消费者会通知一下消息代理(broker)

消息确认可以自动,也可以由处理消息的开发者手动执行。
当启用消息确认后,消息代理需要收到来自消费者的确认回执后,才完全将消息从队列中删除。

 
 

II. 七种队列模式

1. 简单模式(Hello World)

做最简单的事情,一个生产者对应一个消费者,RabbitMQ相当于一个消息代理,负责将A的消息转发给B。

单生产者,单消费者,单队列。


应用场景:

2. 工作队列模式(Work queues)

在多个消费者之间分配任务(竞争的消费者模式),一个生产者对应多个消费者。

适用于资源密集型任务, 单个消费者处理不过来,需要多个消费者进行处理的场景。

单生产者,多消费者,单队列。


应用场景:

3. 发布订阅模式(Publish/Subscribe)

一次向许多消费者发送消息,将消息将广播到所有的消费者。

单生产者,多消费者,多队列。

应用场景:

结构如下:

  • 一个fanout类型交换机扇出两个消息队列,分别为缓存消息队列、数据库消息队列
  • 一个缓存消息队列对应着多个缓存消费者
  • 一个数据库消息队列对应着多个数据库消费者

4. 路由模式(Routing)

根据Routing Key有选择地接收消息。

多消费者,选择性多队列,每个队列通过routing key全文匹配。

应用场景:

5. 主题模式(Topics)

主题交换机方式接收消息,将routing key和模式进行匹配。

多消费者,选择性多队列,每个队列通过模式匹配。

应用场景:

6. 远程过程调用(RPC)

在远程计算机上运行功能并等待结果。

应用场景:

7. 发布者确认(Publisher Confirms)

与发布者进行可靠的发布确认,发布者确认是RabbitMQ扩展,可以实现可靠的发布。

应用场景:

 
https://www.cnblogs.com/davidgu/p/14702449.html

举报

相关推荐

0 条评论