PHP用Guzzle怎样设重试调用服务_PHPGuzzle设重试调用法【稳健】

4次阅读

最直接方式是使用 GuzzlehttpMiddleware::retry() 创建重试中间件并注入 HandlerStack;需自定义 $decider 判定网络异常和5xx/429响应才重试,$delay 实现指数退避,且必须通过 HandlerStack 传入 Client 而非直接赋值 handler。

PHP用Guzzle怎样设重试调用服务_PHPGuzzle设重试调用法【稳健】

GuzzleHttpClient 配置重试中间件最直接的方式

php 里 Guzzle 本身不内置重试逻辑,必须靠 RetryMiddleware + HandlerStack 手动组装。官方推荐做法是用 GuzzleHttpMiddleware::retry(),它返回一个可插入的中间件函数。

关键点:不能只改 timeoutconnect_timeout,那只是单次请求超时控制,和“失败后重试”是两回事。

  • retry 中间件需绑定到 HandlerStack,再传给 Client 构造函数
  • 重试判定逻辑由回调函数 $decider 控制,不是所有 HTTP 状态码都该重试(比如 400、401、403 通常不该重试)
  • 指数退避由 $delay 回调决定,Guzzle 不自动帮你算 2^n * 100ms 这类值,得自己写

$decider 怎么写才不乱重试

默认的 retry 决策函数对网络错误(如连接拒绝、超时)返回 true,但对 5xx 响应默认不重试——这点常被忽略,导致服务端临时 502/503 时没重试就直接报错。

典型安全策略:重试网络异常 + 5xx 响应,跳过 4xx(除 429):

立即学习PHP免费学习笔记(深入)”;

$decider = function ($retries, $request, $response, $exception) {     // 有异常:连接失败、超时、dns 错误等     if ($exception instanceof Exception) {         return $retries < 3;     }     // 有响应但状态码是 5xx 或 429     if ($response && $response->getStatusCode() >= 500 || $response->getStatusCode() === 429) {         return $retries < 3;     }     return false; };
  • 别把 400401404 加进重试,它们代表客户端问题,重试无意义
  • 注意 $exception 可能为 NULL$response 可能为 null,判空前先检查
  • 重试次数建议设为 2~3 次,太多会放大下游压力

怎么让重试带延迟且不阻塞线程

Guzzle 是同步 HTTP 客户端,所谓“不阻塞”是指避免固定 sleep,而用指数退避降低重试冲击。Guzzle 的 $delay 参数接收一个回调,返回毫秒数:

$delay = function ($retries) {     return (int) pow(2, $retries) * 100; // 第1次100ms,第2次200ms,第3次400ms };
  • 不要用 sleep(1) 这种硬延迟,它会让整个 PHP 进程挂起,影响并发能力
  • 实际延迟是累加在每次重试前的,Guzzle 会自动调用 usleep(),你只需返回整数毫秒
  • 如果用了 curl handler(默认),延迟期间 CPU 是空闲的,不影响其他请求处理

guzzlehttp/guzzle 7.x 时要注意 HandlerStack 初始化方式

7.x 版本中 HandlerStack::create() 返回的默认已含重定向、cookie、http_errors 等中间件,你只需 prepend retry,别 replace 整个

$stack = HandlerStack::create(); $stack->push(Middleware::retry($decider, $delay)); 

$client = new Client([ 'handler' => $stack, 'timeout' => 5.0, ]);

  • 别写 new Client(['handler' => Middleware::retry(...)])),这会丢掉所有默认中间件,连重定向都失效
  • 如果你用了自定义 handler(比如 swoole 的协程 handler),retry 中间件仍可用,但 $delay 的 usleep 行为可能被绕过,需确认底层是否支持
  • 日志调试时可加 on_stats 选项观察重试次数:'on_stats' => function (TransferStats $stats) { var_dump($stats->getEffectiveUri(), $stats->getTransferTime(), $stats->hasResponse()); }

重试真正难的不是代码几行,而是判断哪些错误值得重试、延迟设多少才既稳又快、以及确认底层 handler 是否尊重你的 delay 策略——这些不测一测线上流量,光看文档容易漏掉。

text=ZqhQzanResources