go 的 net/rpc 和 grpc 客户端默认不重试,需显式配置:grpc 须满足 grpc.withdefaultserviceconfig(json 字符串)、proto 中 method 标注 retryable: true、且仅对临时错误码如 unavailable 重试;net/rpc 需用 goroutine + channel + context 封装避免阻塞。

Go 的 net/rpc 和 gRPC 客户端默认都不带重试——不是“没写好”,而是设计上就要求你显式决定哪些错误可重试、重试几次、等多久。盲目加 for 循环只会让超时堆积、连接耗尽、重复扣款。
gRPC 客户端重试必须用 JSON 配置且仅对特定方法生效
gRPC Go 默认完全关闭重试,哪怕服务端返回 UNAVAILABLE 也不会重发。启用它要同时满足三个条件:
-
grpc.Dial时传入grpc.WithDefaultServiceConfig,且参数是 JSON 字符串(不是 Go struct) - proto 文件里对应 method 必须声明
retryable: true(否则 runtime 直接跳过重试逻辑) -
RetryableStatusCodes只能填临时性错误码,比如["UNAVAILABLE","DEADLINE_EXCEEDED","RESOURCE_EXHAUSTED"];加INVALID_ARGUMENT会导致业务错误也被重试
常见失效写法:grpc.WithServiceConfig —— 它只影响后续新建的 client,对当前 dial 无效;或者把配置当 struct 直接传,JSON 解析失败后静默忽略。
net/rpc 重试必须用 goroutine + channel + context 封装
net/rpc.Client.Call 是同步阻塞调用,不接收 context.Context,硬套 for + time.Sleep 会卡死 goroutine、耗尽连接池、放大超时时间。
安全做法是每次调用起一个 goroutine,结果写进带缓冲的 chan error,外层用 select 等待 ctx.Done() 或结果返回:
done := make(chan error, 1)
go func() {
err := client.Call(serviceMethod, args, reply)
done <p>建连阶段也得设超时:<code>net.DialTimeout("tcp", addr, 2*time.Second)</code>,否则卡在 TCP 握手就彻底失控。</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill6264" title="Golang Samber Hot"><img
src="https://img.php.cn/upload/skill/000/000/081/179085436125259.jpg" alt="Golang Samber Hot" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/xiazai/skill6264" title="Golang Samber Hot" class="overflowclass">Golang Samber Hot</a>
<p class="overflowclass">在 Golang 中使用 samber/hot 进行内存缓存,支持 LRU、LFU、TinyLFU、W‑TinyLFU、S3FIFO、ARC、TwoQueue、SIEVE、FIFO 等淘汰算法,提供 TTL、缓存加载器及分片功能。</p>
</div>
<a rel="nofollow" href="/xiazai/skill6264" title="Golang Samber Hot" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div><h3>自研重试逻辑优先用 backoff.Retry 而非手写 for</h3><p>自己写重试容易漏掉关键点:退避策略、jitter 抖动、上下文取消、错误分类。社区库 <code>github.com/cenkalti/backoff/v4</code> 能自动处理这些:</p>
- 传入的函数必须接收并传递
ctx到底层调用,否则 cancel 无效 -
backoff.Retry内部已实现指数退避 + jitter,不用自己算1 - 错误判断要独立封装,比如
IsTransient(err),只对net.OpError、context.DeadlineExceeded、status.Code() == codes.Unavailable这类临时错误重试
别把重试次数硬编码在循环里——不同错误类型该重试几次,得按场景分级,比如连接失败重试 3 次,认证失败直接返回。
重试和幂等性必须一起设计,缺一不可
重试本身不解决重复提交问题。如果 RPC 方法是非幂等的(比如支付接口),重试一次就可能扣两次款。
服务端必须配合实现幂等控制,常见方式:
- 客户端生成唯一
request_id,服务端入库前查重 - 状态机校验:订单当前是“待支付”才允许执行“支付”,已是“已支付”则直接返回原结果
- 数据库唯一约束:比如在订单表加
(user_id, order_no)联合唯一索引
最容易被忽略的是:重试过程中,连接可能已断开但请求实际到达服务端——此时服务端响应丢失,客户端重试,结果就是“请求发了两次,只收到一次响应”。这种场景下,光靠客户端重试逻辑无法规避,必须靠服务端幂等兜底。
golang免费学习笔记(深入):立即使用
在学习笔记中,你将探索golang的核心概念和高级技巧!










