消息驱动bean，并在指数后退的情况下重试

Question

我有一个要求，如果我从消息驱动bean调用的服务（Restful服务）关闭或没有返回成功，我需要将消息回滚到队列，等待一段时间（指数），然后再次从队列读取消息，并尝试连接到服务。

我正在尝试的是：

在OnMessage方法中，如果我从调用Restful服务的服务接收到异常，我将使用messageDrivenContext回滚。setRollBackOnly（）我可以执行类似于线程的操作。睡眠（重试等待时间）；

但是如何确保重试_等待_时间以指数级增长？

也许我需要保持豆子的状态，但有人能建议我怎么做吗？

Answer 1

根据您的设置，有多种方法可以实现这一点。如果所有消息都将调用相同的服务，您可以在MDB上下文中定义一个全局限制参数，该参数定义让MDBHibernate的时间。您可以使用基本的指数延迟，例如：

final int throttleTime = 60;  //Assume we delay 60 sec before retry
int throttle = 1;

private int getThrottle(){
  throttle = throttleTime * throttle;
  return throttle;
}

private void resetThrottle(){
  throttle = 1;
}

public void onMessage(Message message){
  try{
     service.invoke();
  } catch (InvocationException e) {
    try{
      Thread.sleep(getThrottle()*1000);
      onMessage(message);
    } catch (InterruptedException e) {
      logger.error(e.getMessage());
    }
  } finally {    
    resetThrottle();
  }
}       

注意，当MDB向容器抛出异常时，一些应用服务器已经逐渐增加了读取消息的重试时间。同样，一些排队系统允许配置在队列中的特定时间显示消息。检查您的基础设施的规格在该主题中描述了什么。