如何在Spring TaskExecutor中重試

遵循我爲使用Spring 3 TaskExecutor發送異步郵件所做的代碼。代碼工作正常，我只想知道是否有任何郵件因任何原因無法發送，那麼它必須重新添加到隊列中，並且必須重試發送。如何在Spring TaskExecutor中重試

我已經谷歌搜索，但沒有得到重試政策的信息。

幫助將高度讚賞！

@Service 
public class AsyncMailSender implements MailSender { 

    /* Logger for Search-Controller Class */ 
    public static final Logger LOGGER = Logger.getLogger(AsyncMailSender.class); 

    @Autowired 
    private MailSender mailSender; 

    @Autowired 
    private TaskExecutor taskExecutor; 

    @Autowired 
    private VelocityEngine velocityEngine; 

    public void send(SimpleMailMessage simpleMessage) throws MailException { 
     Map<String, Object> modelMap = new HashMap<String, Object>(); 
     modelMap.put("user", "Manoj"); 
     simpleMessage.setText(VelocityEngineUtils.mergeTemplateIntoString(velocityEngine, "templates/email.vm", modelMap)); 
     taskExecutor.execute(new AsyncMailTask(simpleMessage)); 
    } 

    public void send(SimpleMailMessage[] simpleMessages) throws MailException { 
     for (SimpleMailMessage message : simpleMessages) { 
      send(message); 
     } 
    } 

    private class AsyncMailTask implements Runnable { 

     private SimpleMailMessage message; 

     private AsyncMailTask(SimpleMailMessage message) { 
      this.message = message; 
     } 

     public void run() { 
      LOGGER.info("Sending Emails" + message.getSubject()); 
      mailSender.send(message); 
     } 
    } 
}

來源

2013-01-01 Manoj Kathiriya

據我所知，目前還沒有辦法來配置與Spring 3的TaskExecutor重，有一個與相關的SPR。話雖如此，我認爲如果拋出任何異常，Spring會自動重試該方法。如果異常繼續發生，這可能會對您造成問題（在資源消耗方面）。

來源

2013-01-01 14:41:13 Swapnil

感謝這麼好的信息，我也去了SPR。想知道是否有任何方法來配置重試次數，所以如果發生相同的錯誤，那麼在某些數字之後，Spring將不會再次執行該任務。 –

這正是SPR的意義，它還沒有解決。我不認爲有任何內置的方式來配置它，你可能需要編寫你的應用程序來處理這些事情。 – Swapnil

Spring不會爲你做的

你要做的異常處理和排隊自己。 TaskExecutor本身具有固有的重試功能，因爲它只是在下一個配置的時間間隔內運行您的任務而無所謂。

來源

2013-01-01 20:03:00

這可能不是理想的，但你可以使用Spring-Retry你的任務裏面是這樣的：

@Service 
public class AsyncMailSender implements MailSender { 

    @Autowired 
    RetryTemplate retryTemplate; 

    private class AsyncMailTask implements Runnable { 

     private SimpleMailMessage message; 

     private AsyncMailTask(SimpleMailMessage message) { 
      this.message = message; 
     } 

     public void run() { 
      retryTemplate.execute(new RetryCallback<Void, PersistenceException>() { 

        LOGGER.info("Sending Emails" + message.getSubject()); 
        mailSender.send(message); 

        return null; 
       } 
      }); 

     } 
    }

可以配置RetryTemplate這樣的：

@Configuration 
public class RetryConfiguration { 

    @Bean 
    RetryTemplate retryTemplate() { 

     RetryTemplate template = new RetryTemplate(); 

     TimeoutRetryPolicy policy = new TimeoutRetryPolicy(); 
     policy.setTimeout(30000L); 

     template.setRetryPolicy(policy); 

     ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy(); 
     template.setBackOffPolicy(backOffPolicy); 

     return template; 
    } 
}

您也可能會發現Spring-Batch有用。

來源

2014-10-30 21:51:00 JBCP

如何在Spring TaskExecutor中重試

回答

相關問題