当前位置: 首页 > news >正文

鱼台网站建设比一网站建设

鱼台网站建设,比一网站建设,网站建设开发综合实训小结,虚拟主机的概念和功能文章目录 前言一、死信队列二、ActiveMQ 中的消息重发时间间隔和重发次数吗?总结 前言 死信队列ActiveMQ 中的消息重发时间间隔和重发次数吗? 一、死信队列 如果你想在消息处理失败后,不被服务器删除,还能被其他消费者处理或重试…

文章目录

  • 前言
  • 一、死信队列
  • 二、ActiveMQ 中的消息重发时间间隔和重发次数吗?
  • 总结


前言

  1. 死信队列
  2. ActiveMQ 中的消息重发时间间隔和重发次数吗?

一、死信队列

如果你想在消息处理失败后,不被服务器删除,还能被其他消费者处理或重试,可以关闭AUTO_ACKNOWLEDGE,将 ack 交由程序自己处理。那如果使用了 AUTO_ACKNOWLEDGE,消息是什么时候被确认的,还有没有阻止消息确认的方法?有!
消费消息有 2 种方法,一种是调用 consumer.receive()方法,该方法将阻塞直到获得并返回一条消息。这种情况下,消息返回给方法调用者之后就自动被确认了。另一种方法是采用 listener 回调函数,在有消息到达时,会调用 listener 接口的 onMessage 方法。在这种情况下,在 onMessage 方法执行完毕后,消息才会被确认,此时只要在方法中抛出异常,该消息就不会被确认。那么问题来了,如果一条消息不能被处理,会被退回服务器重新分配,如果只有一个消费者,该消息又会重新被获取,重新抛异常。就算有多
个消费者,往往在一个服务器上不能处理的消息,在另外的服务器上依然不能被处理。难道就这么退回–获取–报错死循环了吗?
在重试 6 次后,ActiveMQ 认为这条消息是“有毒”的,将会把消息丢到死信队列里。如果你的消息不见了,去 ActiveMQ.DLQ 里找找,说不定就躺在那里。

二、ActiveMQ 中的消息重发时间间隔和重发次数吗?

  1. ActiveMQ:是 Apache 出品,最流行的,能力强劲的开源消息总线。是一个完全支持 JMS1.1 和 J2EE 1.4规范的 JMS Provider 实现。
  2. JMS(Java 消息服务):是一个 Java 平台中关于面向消息中间件(MOM)的 API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。
    首先,我们得大概了解下,在哪些情况下,ActiveMQ 服务器会将消息重发给消费者,这里为简单起见,假定采用的消息发送模式为队列(即消息发送者和消息接收者)。
    ① 如果消息接收者在处理完一条消息的处理过程后没有对 MOM 进行应答,则该消息将由 MOM 重发.
    ② 如果我们队某个队列设置了预读参数(consumer.prefetchSize),如果消息接收者在处理第一条消息
    时(没向 MOM 发送消息接收确认)就宕机了,则预读数量的所有消息都将被重发!
    ③ 如果 Session 是事务的,则只要消息接收者有一条消息没有确认,或发送消息期间 MOM 或客户端某一方突然宕机了,则该事务范围中的所有消息 MOM 都将重发。
    ④ 说到这里,大家可能会有疑问,ActiveMQ 消息服务器怎么知道消费者客户端到底是消息正在处理中还没来得急对消息进行应答还是已经处理完成了没有应答或是宕机了根本没机会应答呢?其实在所有的客户端机器上,内存中都运行着一套客户端的 ActiveMQ 环境,该环境负责缓存发来的消息,负责维持着和ActiveMQ 服务器的消息通讯,负责失效转移(fail-over)等,所有的判断和处理都是由这套客户端环境来完成的。
    我们可以来对 ActiveMQ 的重发策略(Redelivery Policy)来进行自定义配置,其中的配置参数主要有以下几个:
    可用的属性
    属性 默认值 说明
l collisionAvoidanceFactor 默认值 0.15 
设置防止冲突范围的正负百分比,只有启用
useCollisionAvoidance 参数时才生效。
l maximumRedeliveries 默认值 6 
最大重传次数,达到最大重连次数后抛出异常。为-1 时不限制次数,为 0 时表示不进行重传。
l maximumRedeliveryDelay 默认值-1, 最大传送延迟,
只在 useExponentialBackOff 为 true 时有效(V5.5),假设首次重连间隔为 10ms,倍数为 2,那么第二次重连时间间隔为 20ms,第三次重连时间间隔为 40ms,当重连时间间隔大的最大重连时间间隔时,以后每次重连时间间隔都为最大重连时间间隔。
l initialRedeliveryDelay 默认值 1000L, 初始重发延迟时间
l redeliveryDelay 默认值 1000L, 重发延迟时间,
当 initialRedeliveryDelay=0 时生效(v5.4)
l useCollisionAvoidance 默认值 false,
启用防止冲突功能,因为消息接收时是可以使用多线程并发处理的,应该是为了重发的安全性,避开所有并发线程都在同一个时间点进行消息接收处理。所有线程在同一个时间点处理时会发生什么问题呢?应该没有问题,只是为了平衡 broker 处理性能,不会有时很忙,有时很空闲。
l useExponentialBackOff 默认值 false
启用指数倍数递增的方式增加延迟时间。
l backOffMultiplier 默认值 5重连时间间隔递增倍数,只有值大于 1 和启用 useExponentialBackOff参数时才生效。

总结

  1. 死信队列
  2. ActiveMQ 中的消息重发时间间隔和重发次数吗?
http://www.yayakq.cn/news/916659/

相关文章:

  • 建设厅企业锁在哪个网站登录国家网站域名
  • 网站建设后如何检测阿里网站建设需要准备什么
  • 公司做网站一般多少钱运营wordpress速度快
  • 高端品牌型 营销型网站建设购物网站类型
  • 网站的域名能修改么南昌网站设计哪家专业好
  • 网站建设中图片尺寸富阳区建设工程质监站网站
  • 昆山网站设计哪家好网站空间有什么用
  • 松原网站建设楚雄seo
  • 深圳 企业 网站建设个人备案网站可以做商城展示
  • 做网站怎样和客户沟通新昌品牌网站建设
  • 温州论坛网站首页移动端是指手机吗
  • 记录网站 自己做成都诗和远方网站建设
  • 大连网站制作机构苏州网络公司代理商
  • 佛山企业网站开发那个网站可以做雪花特效
  • 合肥专门做网站的公司有哪些推荐6个免费国外自媒体平台
  • 网站模板代码下载南京今天的最新消息
  • 企业网站搭建的优点建网站能多少带宽
  • 淮南市网站建设北京网站建设飞沐
  • 网站的转化率青岛网络公司有哪些
  • 刷题网站开发邯郸网站建设怎么做
  • 制作公司网站用什么软件从网上怎么做网站营销
  • 高手做网站浙江天力建设集团有限公司网站
  • 即时热榜网站 优化
  • 网站制作协议搜索引擎优化简称seo
  • 新乡网站建设那家好即时聊天app开发
  • 手机电商网站开发汉中建设工程招投标网
  • 普洱做网站的报价wap上网
  • 申请建设网站请示打开网页时网站顶部显示广告随后消失的广告怎么做
  • 制作京东一样的网站昆明互联网公司排名前十
  • 电商网站开发的意义网站建设服务器的选择方案