没有合适的资源？快使用搜索试试~ 我知道了~

文库首页网络技术网络基础RabbitMQ 3.9( 续 ).doc

RabbitMQ 3.9( 续 ).doc

1.该资源内容由用户上传，如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款（资源遇到问题，请及时私信上传者）

版权申诉

技术资料

0 下载量 182 浏览量 2022-07-08 18:28:03 上传评论收藏 2.35MB DOC 举报

温馨提示

试读

27页

RabbitMQ 3.9( 续 ).doc

资源推荐

资源详情

资源评论

RabbitMQ 3.9( 续 )

前言

基础篇链接：https://www.cnblogs.com/xiegongzi/p/16229678.html

3.9、延迟队列 - 重要

3.9.1、延迟队列概念

这个玩意儿要表达的意思其实已经见过了，就是死信队列中说的 TTL 消息过期，但是文

字表达得换一下

所谓的延迟队列：就是用来存放需要在指定时间内被处理的元素的队列，其内部是有序的

使用场景：

1、支付时，订单在 30 分钟以内未支付则自动取消支付

2、退款，用户发起退款，在 3 天以后商家还未处理，那官方便介入其中进行处理

..........

玩延迟队列需要具备的条件：

1、具备死信队列知识

2、具备 TTL 知识

然后将这二者结合，加一些东西，上好的烹饪就做好了

实现如下的逻辑

P：生产者

X：正常交换机

Y：死信交换机

QA、QB：正常队列

QD：死信队列

XA、XB：正常交换机、正常队列的 routing key

YD：死信交换机、死信队列的 routing key

3.9.2、集成 SpringBoot

3.9.2.1、依赖

org.springframework.boot

spring-boot-starter-amqp

org.springframework.amqp

spring-rabbit-test

test

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-test

test

3.9.2.2、yml 文件配置

# RabbitMQ 的配置

spring:

rabbitmq:

host: 自己服务器 ip

port: 5672

username: admin

password: admin

# 要是有 Vhost 也可以进行配置

3.9.2.4、RabbitMQ 配置

package cn.zixieqing.config;

import org.springframework.amqp.core.*;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import java.util.HashMap;

@Configuration

public class MqConfig {

/**

* 正常交换机名称

private static final String TTL_NORMAL_EXCHANGE = “X”;

/**

* 死信交换机名称

private static final String TTL_DEAD_LETTER_EXCHANGE = “Y”;

/**

* 正常队列名称

private static final String TTL_NORMAL_QUEUE_A = “QA”;

private static final String TTL_NORMAL_QUEUE_B = “QB”;

/**

* 死信队列名称

private static final String TTL_DEAD_LETTER_QUEUE_D = “QD”;

/**

* 正常交换机和正常队列 A 的 routing key

private static final String TTL_NORMAL_EXCHANGE_BIND_QUEUE_A = “XA”;

/**

* 正常交换机和正常队列 B 的 routing key

private static final String TTL_NORMAL_EXCHANGE_BIND_QUEUE_B = “XB”;

/**

* 正常队列和死信交换机及死信交换机与死信队列的 routing key

private static final String

TTL_NORMAL_QUEUE_AND_DEAD_LETTER_EXCHANGE_AND_DEAD_LETTER_QUE

UE_BIND = “YD”;

/**

* 声明正常交换机

@Bean(“xExchange”)

public DirectExchange xExchange() {

// 直接创建是什么类型的交换机加上交换机名字就可以了

return new DirectExchange(TTL_NORMAL_EXCHANGE);

}

/**

* 声明死信交换机

@Bean(“yExchange”)

public DirectExchange yExchange() {

return new DirectExchange(TTL_DEAD_LETTER_EXCHANGE);

}

/**

* 声明正常队列 QA 并绑定死信交互机 Y

@Bean(“queueA”)

public Queue queueA() {

// initialCapacity 这里的 map 大小值：(存的元素个数 / 负载因子 0.75) + 1

HashMap params = new HashMap(5);

params.put(“x-dead-letter-exchange”, TTL_DEAD_LETTER_EXCHANGE);

params.put(“x-dead-letter-routing-key”,

TTL_NORMAL_QUEUE_AND_DEAD_LETTER_EXCHANGE_AND_DEAD_LETTER_QUE

UE_BIND);

params.put(“x-message-ttl”, 10 * 1000);

// 构建队列并传入相应的参数

return QueueBuilder.durable(TTL_NORMAL_QUEUE_A)

.withArguments(params)

.build();

}

/**

* X 正常交换机和 QA 正常队列绑定

@Bean

public Binding xChangeBindingQueueA(@Qualifier(“queueA”) Queue queueA,

@Qualifier(“xExchange”) DirectExchange

xExchange) {

return BindingBuilder.bind(queueA)

.to(xExchange)

.with(TTL_NORMAL_EXCHANGE_BIND_QUEUE_A);

}

/**

* 声明正常队列 QB 并绑定死信交换机 Y

@Bean(“queueB”)

public Queue queueB() {

initialCapacity map 初始值：(存的元素个数 / 负载因子 0.75) + 1

HashMap params = new HashMap(5);

params.put(“x-dead-letter-exchange”, TTL_DEAD_LETTER_EXCHANGE);

params.put(“x-dead-letter-routing-key”,

TTL_NORMAL_QUEUE_AND_DEAD_LETTER_EXCHANGE_AND_DEAD_LETTER_QUE

UE_BIND);

params.put(“x-message-ttl”, 40 * 1000);

剩余26页未读，继续阅读

评论收藏

内容反馈

1.该资源内容由用户上传，如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款（资源遇到问题，请及时私信上传者）

版权申诉

资源评论

资源反馈

评论星级较低，若资源使用遇到问题可联系上传者，3个工作日内问题未解决可申请退款~

书博教育

粉丝: 1
资源: 2837

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

RabbitMQ 3.9( 续 ).doc

RabbitMQ.doc

RabbitMQ实战.doc

RabbitMQ环境搭配.doc

RabbitMQ的工作队列和路由.doc

RabbitMQ安装包，版本：rabbitmq-server-3.9.11.exe

RabbitMQ3.9.15安装包及安装文档

rabbitmq 3.9.11 + Erlang 23.2

rabbitmq3.9.10.zip

rabbitmq-server-3.9.12

RabbitMQ入门到进阶(Spring整合RabbitMQ&amp;SpringBoot整合RabbitMQ).doc

Windows环境下安装RabbitMQ（消息队列一）.doc

Work库：free spire.doc.jar 3.9.0 jar 包

成都市公共交通集团公司信息化建设.3.9.doc

3.9-弧长及扇形面积教（学）案(九年级下册).doc

otp_src_23.0.tar.gz rabbitmq3.9.9.zip

rabbitmq-server-3.9.13-1.el7.noarch.rpm

RabbitMQ3.9.13和ErLang24.2版本

rabbitmq-server-windows-3.9.13

rabbitmq-server-3.9.16.exe

spire.doc.free-3.9.0.jar

spire.doc.free-3.9.0

RabbitMQ-3.7.2+安装手册.doc

火炬技术协议3.9.doc

spire-doc(3.9.0).rar

rabbitmq-server-3.9.13.exe

rabbitmq-server windows安装包

rabbitmq-server-3.9.10.rar

rabbitmq-server-3.9.13

rabbitMQ安装部署.docx

最新资源

RabbitMQ入门到进阶(Spring整合RabbitMQ&SpringBoot整合RabbitMQ).doc