Spring RabbitMQ死信机制原理实例详解

 更新时间:2020年03月02日 14:53:24   作者:白眉大虾  
这篇文章主要介绍了Spring RabbitMQ死信机制原理实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

死信队列:没有被及时消费的消息存放的队列,消息没有被及时消费有以下几点原因:

  • 1.有消息被拒绝(basic.reject/ basic.nack)并且requeue=false
  • 2.队列达到最大长度
  • 3.消息TTL过期

采用死信机制的好处是可以提高系统的稳定性,当消息消费失败后,消息进入死信队列,可以对消息进行补偿,可以达到最终一致性的目标.

具体例子如下:

@Bean
public Queue deadQueue() {
  return new Queue(DEAD_QUEUE_NAME, true);
}

@Bean
public DirectExchange deadExchange() {
  return new DirectExchange(DEAD_EXCHANGE_NAME);
}

@Bean
public Binding bindingDeadExchange(Queue deadQueue, DirectExchange deadExchange) {
  return BindingBuilder.bind(deadQueue).to(deadExchange).with(DEAD_ROUTING_KEY);
}

@Bean
Queue directQueue() {
  Map<String, Object> args = new HashMap<>(2);
  args.put("x-dead-letter-exchange", DEAD_EXCHANGE_NAME);
  args.put("x-dead-letter-routing-key", DEAD_ROUTING_KEY);
  return new Queue(DIRECT_QUEUE_NAME, true, false, false, args);
}

只要简易的配置,这样消费失败的消息就能被收集起来,后续我们可以实现一个死信消费者,将死信消息进行补偿。

如果是想手动补偿,可以将死信消息存入数据库,做一个管理页面去做补偿.

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Java序列化中子类、父类构造函数问题实例分析

    Java序列化中子类、父类构造函数问题实例分析

    这篇文章主要介绍了Java序列化中子类、父类构造函数问题,结合实例形式分析了java父类与子类构造函数中序列化接口调用相关操作技巧与使用注意事项,需要的朋友可以参考下
    2019-09-09
  • Java环境配置与编译运行详解

    Java环境配置与编译运行详解

    这篇文章主要为大家详细介绍了Java环境配置与编译运行的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-03-03
  • Spring AOP的使用详解

    Spring AOP的使用详解

    这篇文章主要介绍了Spring AOP的使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-05-05
  • linux下执行java程序的sh脚本分享

    linux下执行java程序的sh脚本分享

    这篇文章主要介绍了linux下执行java程序的sh脚本,仅供参考,但是设置的时候环境变量是最重要的,我就是环境变量一直不对,总是按网上查到的来,不明白怎么回事,才一直出错,其实环境变量就是你要执行的java程序所在的位置
    2014-09-09
  • 关于java中多个JDK和切换版本介绍

    关于java中多个JDK和切换版本介绍

    大家好,本篇文章主要讲的是关于java中多个JDK和切换版本介绍,感兴趣的同学赶快来看一看吧,对你有帮助的话记得收藏一下,方便下次浏览
    2022-01-01
  • springboot 接口返回字符串带引号的问题解决

    springboot 接口返回字符串带引号的问题解决

    本文主要介绍了springboot 接口返回字符串带引号的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-04-04
  • mybatis集成到spring的方式详解

    mybatis集成到spring的方式详解

    这篇文章主要介绍了mybatis是如何集成到spring的,将mybatis集成到spring之后,就可以被spring的ioc容器托管,再也不用自己创建SqlSessionFactory 、打开SqlSession等操作,本文结合实例代码给大家介绍的非常详细,需要的朋友可以参考下
    2023-05-05
  • Java中如何保证缓存一致性问题

    Java中如何保证缓存一致性问题

    这篇文章主要介绍了Java中如何保证缓存一致性问题,文章将通过主题提出的问题展开一些解决方案分析,需要的小伙伴可以参考一下
    2022-04-04
  • Java子类实例化总是默认调用父类的无参构造操作

    Java子类实例化总是默认调用父类的无参构造操作

    这篇文章主要介绍了Java子类实例化总是默认调用父类的无参构造操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-10-10
  • java基础的详细了解第七天

    java基础的详细了解第七天

    这篇文章对Java编程语言的基础知识作了一个较为全面的汇总,在这里给大家分享一下。需要的朋友可以参考,希望能给你带来帮助
    2021-08-08

最新评论