当前位置： 首页 > wzjs >正文

seo网站地图百度seo优化是做什么的

wzjs 2025/8/6 4:35:46
seo网站地图,百度seo优化是做什么的,wordpress163邮件,铜川做网站分布式中间件：RabbitMQ死信队列和延迟队列 引言 在分布式系统的开发中，消息队列是一种常用的通信机制，它可以帮助我们实现系统之间的解耦、异步处理和流量削峰等功能。RabbitMQ 作为一款功能强大的消息队列中间件，提供了许多高级…

分布式中间件：RabbitMQ死信队列和延迟队列

引言

在分布式系统的开发中，消息队列是一种常用的通信机制，它可以帮助我们实现系统之间的解耦、异步处理和流量削峰等功能。RabbitMQ 作为一款功能强大的消息队列中间件，提供了许多高级特性，其中死信队列和延迟队列在实际应用中非常实用。本文将详细介绍 RabbitMQ 的死信队列和延迟队列，并结合具体的代码示例进行讲解。

RabbitMQ 配置类

首先，我们来看一个 RabbitMQ 的配置类，这个配置类定义了一些基本的 RabbitMQ 配置，包括单一消费者实例配置、多个消费者实例配置以及自定义的 RabbitMQ 发送消息组件。

@Configuration
public class RabbitmqConfig {@Autowiredprivate Environment environment; // 注入rabbitmq环境@Autowiredprivate CachingConnectionFactory connectionFactory; // 注入rabbitmq连接工厂@Autowiredprivate SimpleRabbitListenerContainerFactoryConfigurer factoryConfigurer; // 注入rabbitmq配置// 单一消费者实例配置@Bean("singleListenerContainer")public SimpleRabbitListenerContainerFactory singleListenerContainer() {// 创建一个监听容器工厂SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();// 设置连接工厂factory.setConnectionFactory(connectionFactory);// 设置消息转换器factory.setMessageConverter(new Jackson2JsonMessageConverter());// 设置并发消费factory.setConcurrentConsumers(1);// 设置最大并发消费factory.setMaxConcurrentConsumers(1);// 设置最大单条消费消息factory.setPrefetchCount(1);return factory;}// 多个消费者实例@Bean("multiListenerContainer")public SimpleRabbitListenerContainerFactory multiListenerContainer() {// 创建一个监听容器工厂SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();// 设置连接工厂factoryConfigurer.configure(factory, connectionFactory);// 设置消息转换器factory.setMessageConverter(new Jackson2JsonMessageConverter());// 设置手动提交factory.setAcknowledgeMode(AcknowledgeMode.NONE);// 设置并发消费factory.setConcurrentConsumers(10);// 设置最大并发消费factory.setMaxConcurrentConsumers(20);// 设置最大单条消费消息factory.setPrefetchCount(10);return factory;}// 自定义RabbitMQ发送消息组件@Beanpublic RabbitTemplate rabbitTemplate() {// 设置消息发送确认connectionFactory.setPublisherConfirms(true);// 设置消息发送返回connectionFactory.setPublisherReturns(true);// 创建rabbitTemplateRabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);// 设置消息发送确认回调rabbitTemplate.setMandatory(true);// 设置消息发送确认回调rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {if (ack) {System.out.println("消息发送成功");} else {System.out.println("消息发送失败:" + cause + correlationData.toString());}});// 设置消息发送返回回调rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {System.out.println("消息丢失：exchange:" + exchange + ",route:" + routingKey + ",replyCode:" + replyCode + ",replyText:" + replyText);});// 设置消息转换器rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());return rabbitTemplate;}
}

代码解释

  1. 单一消费者实例配置（singleListenerContainer）：

    • 创建了一个 SimpleRabbitListenerContainerFactory 实例，用于处理单一消费者的消息监听。
    • 设置了连接工厂、消息转换器、并发消费者数量、最大并发消费者数量和最大单条消费消息数量。

  2. 多个消费者实例配置（multiListenerContainer）：

    • 同样创建了一个 SimpleRabbitListenerContainerFactory 实例，用于处理多个消费者的消息监听。
    • 配置了手动提交模式，设置了更大的并发消费者数量和最大并发消费者数量。

  3. 自定义 RabbitMQ 发送消息组件（rabbitTemplate）：

    • 设置了消息发送确认和返回机制。
    • 定义了消息发送确认回调和返回回调，用于处理消息发送成功和失败的情况。
    • 设置了消息转换器，使用 Jackson2JsonMessageConverter 进行消息的序列化和反序列化。

死信队列

什么是死信队列

死信队列（Dead Letter Queue）是一种特殊的队列，当消息满足某些条件时，会被发送到死信队列中。这些条件包括：

  • 消息被拒绝（basic.reject 或 basic.nack）并且 requeue 参数设置为 false。
  • 消息过期（TTL）。
  • 队列达到最大长度。

死信队列的应用场景

  • 消息重试：当消息处理失败时，可以将消息发送到死信队列，经过一定的处理后再重新发送到原队列进行重试。
  • 记录失败消息：将失败的消息存储在死信队列中，方便后续的排查和处理。

代码示例

以下是一个简单的死信队列配置示例：

@Configuration
public class DeadLetterConfig {// 正常交换机public static final String NORMAL_EXCHANGE = "normal.exchange";// 正常队列public static final String NORMAL_QUEUE = "normal.queue";// 死信交换机public static final String DEAD_LETTER_EXCHANGE = "dead.letter.exchange";// 死信队列public static final String DEAD_LETTER_QUEUE = "dead.letter.queue";// 路由键public static final String ROUTING_KEY = "normal.routing.key";// 声明正常交换机@BeanDirectExchange normalExchange() {return new DirectExchange(NORMAL_EXCHANGE);}// 声明死信交换机@BeanDirectExchange deadLetterExchange() {return new DirectExchange(DEAD_LETTER_EXCHANGE);}// 声明正常队列并绑定死信交换机@BeanQueue normalQueue() {Map<String, Object> args = new HashMap<>();// 设置死信交换机args.put("x-dead-letter-exchange", DEAD_LETTER_EXCHANGE);// 设置死信路由键args.put("x-dead-letter-routing-key", ROUTING_KEY);return new Queue(NORMAL_QUEUE, true, false, false, args);}// 声明死信队列@BeanQueue deadLetterQueue() {return new Queue(DEAD_LETTER_QUEUE, true);}// 绑定正常队列和正常交换机@BeanBinding normalBinding() {return BindingBuilder.bind(normalQueue()).to(normalExchange()).with(ROUTING_KEY);}// 绑定死信队列和死信交换机@BeanBinding deadLetterBinding() {return BindingBuilder.bind(deadLetterQueue()).to(deadLetterExchange()).with(ROUTING_KEY);}
}

代码解释

  1. 交换机和队列的声明：

    • 声明了正常交换机、正常队列、死信交换机和死信队列。
    • 在正常队列的声明中，通过 args 参数设置了死信交换机和死信路由键。

  2. 绑定关系：

    • 将正常队列绑定到正常交换机，将死信队列绑定到死信交换机。

延迟队列

什么是延迟队列

延迟队列是一种可以让消息在指定的时间后才被消费的队列。在 RabbitMQ 中，可以通过消息的 TTL（Time To Live）和死信队列来实现延迟队列的功能。

延迟队列的应用场景

  • 订单超时处理：当用户下单后，如果在一定时间内没有支付，可以使用延迟队列来处理订单超时的情况。
  • 缓存刷新：定期刷新缓存，可以使用延迟队列来实现定时任务。

代码示例

以下是一个简单的延迟队列配置示例：

@Configuration
public class DelayQueueConfig {// 延迟交换机public static final String DELAY_EXCHANGE = "delay.exchange";// 延迟队列public static final String DELAY_QUEUE = "delay.queue";// 死信交换机public static final String DEAD_LETTER_EXCHANGE = "dead.letter.exchange";// 死信队列public static final String DEAD_LETTER_QUEUE = "dead.letter.queue";// 路由键public static final String ROUTING_KEY = "delay.routing.key";// 声明延迟交换机@BeanDirectExchange delayExchange() {return new DirectExchange(DELAY_EXCHANGE);}// 声明死信交换机@BeanDirectExchange deadLetterExchange() {return new DirectExchange(DEAD_LETTER_EXCHANGE);}// 声明延迟队列并绑定死信交换机@BeanQueue delayQueue() {Map<String, Object> args = new HashMap<>();// 设置死信交换机args.put("x-dead-letter-exchange", DEAD_LETTER_EXCHANGE);// 设置死信路由键args.put("x-dead-letter-routing-key", ROUTING_KEY);// 设置消息的 TTLargs.put("x-message-ttl", 5000); // 5 秒return new Queue(DELAY_QUEUE, true, false, false, args);}// 声明死信队列@BeanQueue deadLetterQueue() {return new Queue(DEAD_LETTER_QUEUE, true);}// 绑定延迟队列和延迟交换机@BeanBinding delayBinding() {return BindingBuilder.bind(delayQueue()).to(delayExchange()).with(ROUTING_KEY);}// 绑定死信队列和死信交换机@BeanBinding deadLetterBinding() {return BindingBuilder.bind(deadLetterQueue()).to(deadLetterExchange()).with(ROUTING_KEY);}
}

代码解释

  1. 交换机和队列的声明：

    • 声明了延迟交换机、延迟队列、死信交换机和死信队列。
    • 在延迟队列的声明中，通过 args 参数设置了死信交换机、死信路由键和消息的 TTL。

  2. 绑定关系：

    • 将延迟队列绑定到延迟交换机，将死信队列绑定到死信交换机。

总结

本文介绍了 RabbitMQ 的死信队列和延迟队列的概念、应用场景，并结合具体的代码示例进行了详细的讲解。死信队列和延迟队列在分布式系统中非常实用，可以帮助我们处理消息失败、实现定时任务等功能。通过合理使用这些特性，可以提高系统的可靠性和稳定性。

希望本文对你理解 RabbitMQ 的死信队列和延迟队列有所帮助。如果你有任何疑问或建议，欢迎在评论区留言。

http://www.dtcms.com/wzjs/236554.html

相关文章：

  • 辽宁省阜蒙县建设局网站zac seo博客
  • 在线做动漫图片视频在线观看网站我要看今日头条
  • 网站后台建设公司站长工具排名查询
  • 招聘网站哪个平台比较好seo搜索引擎优化视频
  • 网站跟网页的区别谷歌关键词分析工具
  • 网站深度功能企业网站模板html
  • 如何做服装的微商城网站建设kol营销模式
  • 河北建设工程造价信息网站中国十大热门网站排名
  • 深圳科技网站建设查关键词的排名工具
  • 客套企业名录搜索软件搜索引擎优化的基本原理
  • 官方网站建设报价表网站优化软件费用
  • 高清的宝安网站推广百度推广怎么看关键词排名
  • 网站备案密码通管局新闻10条摘抄大全
  • 福州网站建设设计公司广州seo网站公司
  • 番禺有经验的网站建设关键词热度分析工具
  • 网站建设文化代理商对seo的认识和理解
  • 嵊州做网站中山网站seo优化
  • 营销型网站开发方案品牌营销策划案例
  • c2c网站功能静态网页制作
  • 做网站的环境配置优化系统
  • 建设购物网站的意义qq空间秒赞秒评网站推广
  • 门户网站开发设计报告关键词优化策略有哪些
  • 做最好的美食分享网站企业网站怎么制作
  • 网站建设所需域名建站系统有哪些
  • 网站兼容如何制作简易网站
  • 企业网站页头背景图怎样把广告放到百度
  • 花店做网单的网站搜索引擎的作用
  • 知名做网站费用重庆seo代理
  • 设计类专业网站网络运营需要学什么
  • 偷拍小情侣酒店做爰网站深圳关键词优化平台