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

企业建网站有这个必要吗网站运营与建设

企业建网站有这个必要吗,网站运营与建设,wordpress添加侧栏,上海市黄页企业名录查询文章目录 前言一、死信队列二、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/871493/

相关文章:

  • 金华网站建设方案优化网站建设技术架构
  • 易语言如何做网站太原市今天新闻
  • 微博网站开发新建设电影院 网站
  • 公司网站建设系统网页广告拦截怎么设置
  • 南京建设网站内容cdn资源访问出现问题怎么办
  • 网站分析seo情况公司网站设计收费
  • 源码开发网站建设中国电子商务网站建设
  • 南京机关建设网站大连网站推广
  • html怎么做查询网站吗企业网站备案时间
  • 网易云网站开发电子商务网站建设课外实训
  • 电子商务网站建设需求概述58同城网站建设目的
  • 做网站 教程水果网店网站建设策划书
  • 自学网站建设作业有哪个网站可以做ppt赚钱
  • 丰宁建设局网站wordpress 伪静态 分页
  • 建设淘宝网站的市场分析做自己的视频网站
  • 建设银行甘肃省分行网站网站建设总结与
  • 牡丹江网站建设兼职黄页推广软件哪个好
  • 秦皇岛公司做网站qq网站访客获取系统
  • 清溪仿做网站好的网页制作公司有哪些
  • 东莞市主营网站建设平台微信小程序会员管理系统怎么做
  • 网上做家教哪个网站网站后台不显示文章内容
  • 外贸有哪些网站wordpress无法打开备份
  • 丹阳市住房建设管理局网站wordpress存档
  • 大连做网站哪家好一点wordpress音乐站主题
  • 济南智能网站建设报价余姚网站建设维护最新招聘信息
  • 国开网站怎么做创建网站为啥要钱
  • 青海互动网站建设怎么注销自己做的网站
  • 网站建设和维护怎么学建材网站建设公司
  • 网页设计网站开发需要什么软件一个彩票网站建设
  • 手游源码论坛品牌词优化