欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

springboot整合rabbitmq 五种模式及死信队列的demo代码

程序员文章站 2022-07-12 12:28:40
...

1、pom文件需要增加amqp依赖

		<!--rabbitmq amqp的起步依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

2、配置文件增加rabbitmq配置参数

spring:
  rabbitmq:
        host: 127.0.0.1
        port: 5672
        #virtual-host: /hello
        #此处需要登录http://localhost:15672 平台进行新建用户,并且注意赋予权限
        username: test
        password: 123456
    main:
        #允许其他bean的覆盖
        allow-bean-definition-overriding: true

3、demo 代码,内附详细说明

demo代码链接: springboot整合rabbitmq 五种模式及死信队列的demo代码.

rabbitmq 五种模式:

简单模式(easy):一个生产者对应一个消费者(单对单)
工作模式(work):一个生产者对应一个消费者(单对多 ),但是只有一个消费者可以获取消息
发布/订阅模式(fanout): 队列绑定到交换机,每个队列都能收到消息
路由模式(direct): 队列绑定到交换机,根据key 路由键规则发送,指定一个队列获取消息
主题模式(topic): 队列绑定到交换机,根据路由规则进行发送,满足规则就能接收消息
*注意:上述模式 同个队列的消费者轮询接收消息

死信队列:当一个消息在队列中死亡则进入死信消息队列
应用场景:例如:订单队列接收超过10秒未能处理成功则进入死信队列,进行异常订单的处理

相关标签: mq