-
Notifications
You must be signed in to change notification settings - Fork 421
Expand file tree
/
Copy pathRetryable.html
More file actions
113 lines (86 loc) · 8.25 KB
/
Retryable.html
File metadata and controls
113 lines (86 loc) · 8.25 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"><html xmlns="http://www.w3.org/1999/xhtml"><head><meta http-equiv="Content-Type" content="text/html; charset=UTF-8" /><title>第 63 章 Spring boot with Retryable</title><link rel="stylesheet" type="text/css" href="../docbook.css" /><meta name="generator" content="DocBook XSL Stylesheets Vsnapshot" /><link rel="home" href="../index.html" title="Netkiller Java 手札（版）" /><link rel="up" href="index.html" title="部分 IV. Spring Boot" /><link rel="prev" href="record/spring.boot.record.html" title="62.5. Record 作为 Controller" /><link rel="next" href="ch63s02.html" title="63.2. spring-retry" /></head><body><a xmlns="" href="//www.netkiller.cn/">Home</a> | <a xmlns="" href="//netkiller.github.io/">简体中文</a> | <a xmlns="" href="http://netkiller.sourceforge.net/">繁体中文</a> | <a xmlns="" href="/journal/index.html">杂文</a>
| <a xmlns="" href="https://github.com/netkiller">Github</a> | <a xmlns="" href="https://zhuanlan.zhihu.com/netkiller">知乎专栏</a> | <a xmlns="" href="https://www.facebook.com/bg7nyt">Facebook</a> | <a xmlns="" href="http://cn.linkedin.com/in/netkiller/">Linkedin</a> | <a xmlns="" href="https://www.youtube.com/user/bg7nyt/videos">Youtube</a> | <a xmlns="" href="//www.netkiller.cn/home/donations.html">打赏(Donations)</a> | <a xmlns="" href="//www.netkiller.cn/home/about.html">About</a><div class="navheader"><table width="100%" summary="Navigation header"><tr><th colspan="3" align="center">第 63 章 Spring boot with Retryable</th></tr><tr><td width="20%" align="left"><a accesskey="p" href="record/spring.boot.record.html">上一页</a> </td><th width="60%" align="center">部分 IV. Spring Boot</th><td width="20%" align="right"> <a accesskey="n" href="ch63s02.html">下一页</a></td></tr></table><hr /></div><table xmlns=""><tr><td><iframe src="//ghbtns.com/github-btn.html?user=netkiller&repo=netkiller.github.io&type=watch&count=true&size=large" height="30" width="170" frameborder="0" scrolling="0" style="width:170px; height: 30px;" allowTransparency="true"></iframe></td><td><iframe src="//ghbtns.com/github-btn.html?user=netkiller&repo=netkiller.github.io&type=fork&count=true&size=large" height="30" width="170" frameborder="0" scrolling="0" style="width:170px; height: 30px;" allowTransparency="true"></iframe></td><td><iframe src="//ghbtns.com/github-btn.html?user=netkiller&type=follow&count=true&size=large" height="30" width="240" frameborder="0" scrolling="0" style="width:240px; height: 30px;" allowTransparency="true"></iframe></td><td></td><td><a href="https://zhuanlan.zhihu.com/netkiller"><img src="/images/logo/zhihu-card-default.svg" height="25" /></a></td><td valign="middle"><a href="https://zhuanlan.zhihu.com/netkiller">知乎专栏</a></td><td></td><td></td><td></td><td></td></tr></table><div class="chapter"><div class="titlepage"><div><div><h2 class="title"><a id="Retryable"></a>第 63 章 Spring boot with Retryable</h2></div></div></div><div class="toc"><p><strong>目录</strong></p><dl class="toc"><dt><span class="section"><a href="Retryable.html#spring.EnableResilientMethods">63.1. @EnableResilientMethods</a></span></dt><dd><dl><dt><span class="section"><a href="Retryable.html#spring.ConcurrencyLimit">63.1.1. @ConcurrencyLimit 限流</a></span></dt><dt><span class="section"><a href="Retryable.html#spring.Retryable">63.1.2. @Retryable 重试</a></span></dt></dl></dd><dt><span class="section"><a href="ch63s02.html">63.2. spring-retry</a></span></dt><dd><dl><dt><span class="section"><a href="ch63s02.html#id1200">63.2.1. spring-retry 依赖</a></span></dt><dt><span class="section"><a href="ch63s02.html#id1201">63.2.2. @EnableRetry 启用重试</a></span></dt><dt><span class="section"><a href="ch63s02.html#id1202">63.2.3. </a></span></dt><dt><span class="section"><a href="ch63s02.html#id1203">63.2.4. 高级用法</a></span></dt></dl></dd></dl></div>
<p>Springboot 实现重试有两个方案，一个是 Springboot 4.0 自带的 Retryable 是 Resilient 实现。另一个方案是 spring-retry 需要额外引入依赖。</p>
<div class="section"><div class="titlepage"><div><div><h3 class="title"><a id="spring.EnableResilientMethods"></a>63.1. @EnableResilientMethods</h3></div></div></div>
<p>启用配置，在配置类上添加@EnableResilientMethods注解</p>
<pre class="programlisting">
</pre>
<div class="section"><div class="titlepage"><div><div><h4 class="title"><a id="spring.ConcurrencyLimit"></a>63.1.1. @ConcurrencyLimit 限流</h4></div></div></div>
<p>在需要限制并发的方法上添加@ConcurrencyLimit注解</p>
<pre class="programlisting">
@Configuration
@EnableResilientMethods
public class ResilientMethodsConfig {
// 配置类
}
@Component
public class NotificationService {
@ConcurrencyLimit(10)
public void sendNotification() {
this.jmsClient.destination("notifications").send(...);
}
@ConcurrencyLimit(1)
public void processCriticalTask() {
// 关键任务处理
}
}
</pre>
</div>
<div class="section"><div class="titlepage"><div><div><h4 class="title"><a id="spring.Retryable"></a>63.1.2. @Retryable 重试</h4></div></div></div>
<pre class="programlisting">
@Retryable
public void sendNotification() {
this.jmsClient.destination("notifications").send(...);
}
</pre>
<p>可通过@Retryable注解中的includes、excludes和implicit值属性，限制触发重试的异常类型。
</p>
<pre class="programlisting">
@Retryable( includes = MessageDeliveryException.class, maxAttempts = 5, delay = 100, jitter = 10, multiplier = 2, maxDelay = 1000)
public void sendNotification() {
this.jmsClient.destination("notifications").send(...);
}
</pre>
<p>RetryTemplate</p>
<pre class="programlisting">
var retryPolicy = RetryPolicy.builder()
.includes(MessageDeliveryException.class)
.maxAttempts(5)
.delay(Duration.ofMillis(100))
.build();
var retryTemplate = new RetryTemplate(retryPolicy);
retryTemplate.execute(() -> jmsClient.destination("notifications").send(...));
</pre>
</div>
</div>
</div><script xmlns="" type="text/javascript" id="clustrmaps" src="//cdn.clustrmaps.com/map_v2.js?u=r5HG&d=9mi5r_kkDC8uxG8HuY3p4-2qgeeVypAK9vMD-2P6BYM"></script><div class="navfooter"><hr /><table width="100%" summary="Navigation footer"><tr><td width="40%" align="left"><a accesskey="p" href="record/spring.boot.record.html">上一页</a> </td><td width="20%" align="center"><a accesskey="u" href="index.html">上一级</a></td><td width="40%" align="right"> <a accesskey="n" href="ch63s02.html">下一页</a></td></tr><tr><td width="40%" align="left" valign="top">62.5. Record 作为 Controller </td><td width="20%" align="center"><a accesskey="h" href="../index.html">起始页</a></td><td width="40%" align="right" valign="top"> 63.2. spring-retry</td></tr></table></div><script xmlns="">
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
})(window,document,'script','//www.google-analytics.com/analytics.js','ga');
ga('create', 'UA-11694057-1', 'auto');
ga('send', 'pageview');
</script><script xmlns="" async="async">
var _hmt = _hmt || [];
(function() {
var hm = document.createElement("script");
hm.src = "https://hm.baidu.com/hm.js?93967759a51cda79e49bf4e34d0b0f2c";
var s = document.getElementsByTagName("script")[0];
s.parentNode.insertBefore(hm, s);
})();
</script><script xmlns="" async="async">
(function(){
var bp = document.createElement('script');
var curProtocol = window.location.protocol.split(':')[0];
if (curProtocol === 'https') {
bp.src = 'https://zz.bdstatic.com/linksubmit/push.js';
}
else {
bp.src = 'http://push.zhanzhang.baidu.com/push.js';
}
var s = document.getElementsByTagName("script")[0];
s.parentNode.insertBefore(bp, s);
})();
</script></body></html>