ActiveMQ Redelivery Policy（讯息重发策略）

ActiveMQ Redelivery Policy（消息重发策略）

转载自?http://windows9834.blog.163.com/blog/static/2734500420131195224532/

?

官方文档：http://activemq.apache.org/redelivery-policy.html
在事务控制里抛出异常,txManager会进行rollback处理.(在activeMQ里,消息默认会redelivery到客户端6次,如果继续异常,消息会放到deadletter queue里(ActiveMQ.DLQ))。

在以下三种情况中，消息会被再次传送给消费者：

1．在使用事务的Session中，调用rollback()方法；

2．在使用事务的Session中，调用commit()方法之前就关闭了Session;

3．在Session中使用CLIENT_ACKNOWLEDGE签收模式，并且调用了recover()方法。

可以通过设置ActiveMQConnectionFactory和ActiveMQConnection来定制想要的再次传送策略。

当消息被再次投递到客户端时的详细信息在?Message Redelivery and DLQ Handling?章节能找到详细的说明。
你可以在ActiveMQConnectionFactory 或ActiveMQConnection类中配置RedeliveryPolicy属性，用来定义重传策略的具体细节。
您可以使用Java代码，Spring配置或配置URI字符串来定义重传策略。

可用的属性?属性默认值说明??collisionAvoidanceFactor?0.15?设置防止冲突范围的正负百分比，只有启用useCollisionAvoidance参数时才生效。?maximumRedeliveries?6?最大重传次数，达到最大重连次数后抛出异常。为-1时不限制次数，为0时表示不进行重传。?maximumRedeliveryDelay?-1?最大传送延迟，只在useExponentialBackOff为true时有效（V5.5），假设首次重连间隔为10ms，倍数为2，那么第二次重连时间间隔为 20ms，第三次重连时间间隔为40ms，当重连时间间隔大的最大重连时间间隔时，以后每次重连时间间隔都为最大重连时间间隔。?initialRedeliveryDelay?1000L?初始重发延迟时间?redeliveryDelay?1000L?重发延迟时间，当initialRedeliveryDelay=0时生效（v5.4）?useCollisionAvoidance?false?启用防止冲突功能，因为消息接收时是可以使用多线程并发处理的，应该是为了重发的安全性，避开所有并发线程都在同一个时间点进行消息接收处理。所有线程在同一个时间点处理时会发生什么问题呢？应该没有问题，只是为了平衡broker处理性能，不会有时很忙，有时很空闲。?useExponentialBackOff?false?启用指数倍数递增的方式增加延迟时间。?backOffMultiplier?5?重连时间间隔递增倍数，只有值大于1和启用useExponentialBackOff参数时才生效。

官方文档有些参数功能说得不是很清楚，如collisionAvoidanceFactor，那只能查看源代码了，
可以查看org.apache.activemq.ActiveMQMessageConsumer类中的rollback()方法：

publicvoid rollback()throwsJMSException{

......

finalint currentRedeliveryCount = lastMd.getMessage().getRedeliveryCounter();
if(currentRedeliveryCount >0){
redeliveryDelay = redeliveryPolicy.getNextRedeliveryDelay(redeliveryDelay);
}else{
redeliveryDelay = redeliveryPolicy.getInitialRedeliveryDelay();
}

......

}

先获取重发次数，如果是第一次重发则延迟时间为initialRedeliveryDelay，如果不是第一次重发则延迟时间为redeliveryDelay = redeliveryPolicy.getNextRedeliveryDelay(redeliveryDelay);这里的redeliveryDelay参数是前一次重发的延迟时间。

publiclong getNextRedeliveryDelay(long previousDelay){
long nextDelay;
if(previousDelay ==0){
nextDelay = redeliveryDelay;
}elseif(useExponentialBackOff && backOffMultiplier >1){
nextDelay =(long)(previousDelay * backOffMultiplier);
if(maximumRedeliveryDelay !=-1&& nextDelay > maximumRedeliveryDelay){
// in case the user made max redelivery delay less than redelivery

delay for some reason.
nextDelay =Math.max(maximumRedeliveryDelay, redeliveryDelay);
}
}else{
nextDelay = previousDelay;
}
if(useCollisionAvoidance){
/*
* First random determines +/-, second random determines how far to
* go in that direction. -cgs
*/
Random random = getRandomNumberGenerator();
double variance =(random.nextBoolean()? collisionAvoidanceFactor :

-collisionAvoidanceFactor)* random.nextDouble();
nextDelay += nextDelay * variance;
}
return nextDelay;
}

计算下一次重发延迟时间时，当启用指数倍数增长方式useExponentialBackOff=true，且增长倍数backOffMultiplier > 1时，下一次延迟时间为previousDelay * backOffMultiplier，这里的previousDelay为前一次延迟重发的时间。

collisionAvoidanceFactor这个参数spring中是不能直接注入的，注入方法为：

publicvoid setCollisionAvoidancePercent(short collisionAvoidancePercent){
this.collisionAvoidanceFactor = collisionAvoidancePercent *0.01d;
}

这里的collisionAvoidancePercent是个短整形，比如15，则方法直接计算为15%。在spring中注入方式为：

<propertyname="collisionAvoidancePercent"value="15"/>

如果useCollisionAvoidance=true，则nextDelay += nextDelay * variance;这里的variance是一个随机的正负值，Random.nextDouble()的范围是：0.0d到1.0d，当redeliveryDelay=1000L，collisionAvoidanceFactor值为0.15时，那么正负variance的范围就是：-0.15到+0.15，那么最后nextDelay的值范围就是：1000+1000*-15%~1000+1000*15%，即在850~1150范围内波动。