• RabbitMQ 5种工作模式介绍和Springboot具体实现


     RabbitMQ有5中工作模式:简单模式、工作队列模式、发布/订阅模式、路由模式和主题模式

    简单模式(Simple Mode)

    简单模式是最基本的工作模式,也是最简单的模式。在简单模式中,生产者将消息发送到一个队列中,然后消费者从该队列中接收并处理消息。这种模式下,一个生产者可以发送多个消息,但只有一个消费者能够接收和处理这些消息。简单模式适用于单个生产者和单个消费者的场景。

    具体实现

    1. 导入依赖、在依赖文件配置rabbitmq(消费者和生产者程序都要实现)

    1. <dependency>
    2. <groupId>org.springframework.bootgroupId>
    3. <artifactId>spring-boot-starter-amqpartifactId>
    4. dependency>
    1. spring:
    2. rabbitmq:
    3. host: 192.168.10.100 # 自己的虚拟机IP
    4. port: 5672 # 端口
    5. virtual-host: /root # 虚拟主机
    6. username: root # 用户名
    7. password: root # 密码

    2. 创建消费者(一个程序)

    1. @Component
    2. public class SimpleModeProducer {
    3. @Autowired
    4. private RabbitTemplate rabbitTemplate;//注入中央类
    5. public void sendMessage(String queueName, String message) {
    6. rabbitTemplate.convertAndSend(queueName, message);
    7. System.out.println("发送的消息: " + message);
    8. }
    9. }

    3.创建消费者(另一个程序)

    1. @Component
    2. public class SimpleModeConsumer {
    3. @RabbitListener(queues = "simple.queue")//监听队列,自动检测
    4. public void receiveMessage(String message) {
    5. System.out.println("接收到的消息: " + message);
    6. }
    7. }

    4. 测试(在生产者程序)

    1. @SpringBootTest
    2. public class SimpleModeTest {
    3. @Autowired
    4. private SimpleModeProducer producer;
    5. @Test
    6. public void testSimpleMode() {
    7. producer.sendMessage("simple.queue","hello, rabbitmq!");
    8. }
    9. }

    工作队列模式(Work Queue Mode)

    工作队列模式也被称为任务队列模式,在工作队列模式中,生产者将消息发送到一个队列中,多个消费者同时监听该队列,并竞争地接收消息进行处理。每个消息只能被一个消费者接收,确保消息的唯一性。工作队列模式可以实现任务的并行处理,提高系统的处理能力。

    发布/订阅模式(Publish/Subscribe Mode)

    发布/订阅模式将消息发送到交换机(exchange),然后交换机将消息广播给所有绑定的队列。每个队列都有自己的消费者,从而实现了消息的广播。在发布/订阅模式中,生产者将消息发送到交换机,而不是直接发送到队列。交换机根据绑定的队列将消息进行广播。这种模式适用于需要将消息广播给多个消费者的场景。

    路由模式(Routing Mode)

    路由模式在发布/订阅模式的基础上增加了路由键(routing key)的概念。生产者将消息发送到交换机,并指定一个路由键。交换机根据路由键的匹配规则将消息发送到相应的队列。消费者可以选择订阅特定的路由键,只接收符合条件的消息。这种模式适用于需要根据消息的属性或条件进行消息路由的场景。

    主题模式(Topic Mode)

    主题模式是路由模式的扩展,它使用通配符来匹配路由键。生产者将消息发送到交换机,并指定一个主题(topic)。交换机根据主题的模式匹配将消息发送到符合条件的队列。主题模式可以实现更灵活的消息路由,可以根据不同的主题将消息发送给不同的队列。这种模式适用于需要根据消息的主题进行灵活路由的场景。

  • 相关阅读:
    银河麒麟 electron loadURL打不开,loadFile 传参
    python之Cp、Cpk、Pp、Ppk
    Springcloud----Sentinel微服务保护
    C语言学习之路(工具篇)—— Qt Creator的使用
    ChatGPT当导购员!全球最大超市,全面应用生成式AI
    ASP.NET Core中创建中间件的几种方式
    快速解决 Resource not accessible by integration
    Redis-SpringBoot实战与缓存问题
    线性表之顺序表(干货满满的分享来啦~内含顺序表全部函数代码~
    CSS Grid详解
  • 原文地址:https://blog.csdn.net/DU9999999/article/details/133581427