博客

支付系统异步通知承接上文：

DelayQueue实现支付系统异步通知

本篇介绍通过spring-retry来实现支付系统异步通知功能。

1、添加所需的jar

Xml代码

1. <dependency>
2. <groupId>org.springframework.retry</groupId>
3. <artifactId>spring-retry</artifactId>
4. <version>1.1.2.RELEASE</version>
5. </dependency>

2、实现任务重试服务

Java代码

1. package com.huatech.service;
3. import java.io.IOException;
4. import java.net.URISyntaxException;
5. import java.util.HashMap;
7. import org.slf4j.Logger;
8. import org.slf4j.LoggerFactory;
9. import org.springframework.retry.RetryException;
10. import org.springframework.retry.annotation.Backoff;
11. import org.springframework.retry.annotation.EnableRetry;
12. import org.springframework.retry.annotation.Retryable;
13. import org.springframework.stereotype.Service;
15. import com.huatech.common.delay.RetMessage;
16. import com.huatech.common.util.HttpsUtil;
17. /**
18. * 任务重试服务
19. *
20. *  第一次成功则不再重试；
21. *  第一次失败，10分钟后重试第二次；
22. *  第二次失败，20分钟后重试第三次；
23. *  第三次失败，40分钟后重试第四次；
24. *  第四次失败，60分钟后重试第五次；
25. * @author lh
26. *
27. */
28. //@Configuration
29. @EnableRetry
30. @Service
31. public class TaskRetryService {
34. private static final Logger LOGGER = LoggerFactory.getLogger(TaskRetryService.class);
36. //返回结果
37. private static final String RES_SUCCESS = “success”;
38. //时间单位：10min
39. private static final long TIME_UNIT = 1000 * 60 * 10;
40. //重试次数
41. private static final int MAX_ATTEMPTS = 5;
43. @Retryable(value = {RetryException.class, RuntimeException.class},
44. maxAttempts = MAX_ATTEMPTS,
45. backoff = @Backoff(delay = TIME_UNIT, maxDelay=TIME_UNIT * 6, multiplier= 2 ))
46. public void notice(RetMessage msg){
47. HashMap<String, String> paramMap = new HashMap<String, String>();
48. paramMap.put(“reqData”, msg.getReqData());
49. String httpResult = null;
50. try {
51. httpResult = HttpsUtil.getInstance().doPostRetString(msg.getUrl(), null, paramMap);
52. LOGGER.info(“第{}次异步回调,返回结果{},返回参数：{},响应结果：{}”, msg.getTimes(), httpResult,
53. paramMap.get(“reqData”), RES_SUCCESS.equals(httpResult));
54. if (!RES_SUCCESS.equals(httpResult)) {
55. msg.setTimes(msg.getTimes() + 1);
56. msg.setSuccess(false);
57. throw new RetryException(“retry failed”);
58. }else{
59. msg.setSuccess(true);
60. }
61. } catch (URISyntaxException | IOException e) {
62. }
63. }
65. }