【核心干货】Swoole 实现异步发送邮件/短信面试题-Swoole-PHP中文网

不能直接在swoole http回调里用mail()或file_get_contents()，因为它们是同步阻塞调用，会卡住整个协程，导致后续请求排队；应改用swoole\coroutine\http\client等协程安全api。

【核心干货】swoole 实现异步发送邮件/短信面试题

为什么不能直接在 Swoole HTTP 回调里用 `mail()` 或 `file_get_contents()` 发短信？

因为这些是同步阻塞调用，会卡住整个协程，让后续请求排队等待。Swoole 的协程调度器无法在 mail() 内部挂起，它会一直等到 SMTP 连接建立、认证、发信完成才返回——哪怕网络抖动导致耗时 3 秒，这 3 秒内该协程就“假死”了，其他请求全被堵住。

常见错误现象：Coroutine::sleep(0) 无效、Co::exec() 被阻塞、HTTP 响应延迟突增且不可预测。

PHP 内置 mail() 本质是 fork + sendmail，不支持协程化，Swoole 不会自动 Hook
file_get_contents("https://api.sms.com/...") 默认走同步 cURL，即使启用了 Swoole\Runtime::enableCoroutine()，也需确保底层是协程版 cURL（即 curl_setopt($ch, CURLOPT_RETURNTRANSFER, true) 配合 Swoole\Coroutine\Http\Client）
直接 exec("curl -s ...") 会 fork 子进程，协程无法接管其 I/O，照样阻塞

用 `Swoole\Coroutine\Http\Client` 发 HTTP 类短信/邮件 API 最稳妥

这是官方推荐、真正协程友好的方式。所有 DNS 解析、TCP 握手、TLS 握手、HTTP 请求/响应都由 Swoole 协程调度器接管，遇到网络等待自动让出 CPU，不阻塞其他协程。

实操建议：

Swoole 6.1.1

Swoole 6.1.1 是一个专为 PHP 设计的高性能事件驱动并发网络引擎。作为稳定版，它修复了编译时对 zlib 依赖的缺失及 curl 模块的内存安全风险。该版本支持协程、多线程与多进程架构，内置 TCP/HTTP/WebSocket 服务器，能够显著提升 PHP 在微服务、实时通信等场景下的执行效率与并发能力。

下载

创建客户端时显式设置超时：$client = new \Swoole\Coroutine\Http\Client('api.sms.net', 443, true); $client->set(['timeout' => 5.0]);
POST JSON 数据记得设 header：$client->setHeaders(['Content-Type' => 'application/json']); $client->post('/send', json_encode($data));
别忘了检查返回：if ($client->statusCode === 200) { /* 成功 */ } else { /* 记日志，不要静默失败 */ }
如果 API 支持长连接，可复用 $client 实例（但注意：它不是线程安全的，每个协程必须新建或从连接池取）

发邮件更推荐走独立协程任务 + 连接池，而不是实时 HTTP

SMTP 协议本身比 HTTP 更复杂（多轮交互、AUTH、STARTTLS），纯协程实现成本高；而多数企业级邮件服务（如 SendGrid、Mailgun、腾讯云 SES）都提供 REST API，但它们对并发限流更严格，且发信成功率依赖队列重试逻辑。

所以生产环境更合理的做法是：HTTP 请求只做“入队”，真正发信交给后台协程消费者。

主协程收到请求后，把收件人、模板 ID、参数写入 Redis List 或 Kafka，立即返回 {"code":0,"msg":"已入队"}
另起一个 Swoole\Server 或 tick 定时器驱动的协程 Worker，持续 LPOP 消费，用 Swoole\Coroutine\Http\Client 调用邮件 API
失败时记录失败原因、自动加入重试队列（如延时 60 秒再推回 List），避免单封信失败拖垮整条链路
注意 Redis 连接也要协程化：$redis = new \Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379);

面试官真正在意的不是“会不会发”，而是协程边界意识

他们想确认你是否理解：Swoole 的“异步”不是靠多线程或多进程，而是靠协程让出控制权；任何未被 Swoole Hook 的阻塞调用（包括 sleep()、fread()、stream_socket_client()）都会破坏这个模型。

最容易被忽略的一点：Swoole\Runtime::enableCoroutine() 默认只 Hook 一部分函数，mail() 和部分 stream 操作不在其中，必须手动确认或换方案。很多候选人写了 enableCoroutine() 就以为万事大吉，结果压测时 RT 爆表还查不出原因。