[大数据]springboot整合rabbitmq 五种模式及死信队列的demo代码

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秒未能处理成功则进入死信队列，进行异常订单的处理