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);
}

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

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

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

相关文章

  • Mybatis中输入输出映射与动态Sql图文详解

    Mybatis中输入输出映射与动态Sql图文详解

    这篇文章主要给大家介绍了关于Mybatis中输入输出映射与动态Sql的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-02-02
  • java实现简单计算器

    java实现简单计算器

    这篇文章主要为大家详细介绍了java实现简单计算器,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-12-12
  • 详解java整合solr5.0之solrj的使用

    详解java整合solr5.0之solrj的使用

    本篇文章主要介绍了详解java整合solr5.0之solrj的使用 ,具有一定的参考价值,有兴趣的可以了解下
    2017-06-06
  • SSM框架中测试单元的使用 spring整合Junit过程详解

    SSM框架中测试单元的使用 spring整合Junit过程详解

    这篇文章主要介绍了SSM框架中测试单元的使用 spring整合Junit过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • Java Web实现文件上传和下载接口功能详解

    Java Web实现文件上传和下载接口功能详解

    这篇文章主要为大家详细介绍了Java Web实现文件上传和下载接口功能的相关知识,文中的示例代码讲解详细,对我们学习有一定的借鉴价值,需要的可以参考一下
    2022-12-12
  • 一文教会你使用Java中的枚举Enmu

    一文教会你使用Java中的枚举Enmu

    枚举是 Java 中的一种特殊类型,它用于表示一组固定值,这篇文章就是来和大家讲讲枚举的作用与具体使用,感兴趣的小伙伴可以跟随小编一起学习一下
    2023-06-06
  • java操作elasticsearch的案例解析

    java操作elasticsearch的案例解析

    这篇文章主要介绍了java操作elasticsearch的案例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-10-10
  • 深入了解JAVA HASHMAP的死循环

    深入了解JAVA HASHMAP的死循环

    HASHMAP基于哈希表的 Map 接口的实现。此实现提供所有可选的映射操作,并允许使用 null 值和 null 键。(除了非同步和允许使用 null 之外,HashMap 类与 Hashtable 大致相同。)下面小编来带大家详细了解下吧
    2019-06-06
  • java中如何使用泛型方法比较大小

    java中如何使用泛型方法比较大小

    这篇文章主要介绍了java中如何使用泛型方法比较大小,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-04-04
  • 解决spring 处理request.getInputStream()输入流只能读取一次问题

    解决spring 处理request.getInputStream()输入流只能读取一次问题

    这篇文章主要介绍了解决spring 处理request.getInputStream()输入流只能读取一次问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-09-09

最新评论