Swoole如何优雅地关闭服务器和所有连接

优雅关闭需监听SIGTERM/SIGINT信号,触发shutdown()停止接收新连接并等待现有任务完成,同时广播关闭通知、清理定时器与异步任务,超时后强制关闭长连接,确保资源有序释放。

Swoole如何优雅地关闭服务器和所有连接

在使用 swoole 构建的服务器应用中,优雅关闭(Graceful Shutdown)是指在不中断正在处理的请求、有序释放资源的前提下停止服务。这能避免客户端连接突然断开、数据丢失或写入不完整等问题。实现优雅关闭的关键在于正确处理信号、等待现有连接完成,并主动关闭所有活跃连接。

监听退出信号并触发关闭逻辑

Swoole 服务器运行在事件循环中,默认不会响应 Ctrl+C 或 kill 命令立即退出。要实现优雅关闭,需注册信号处理器,在收到终止信号时启动清理流程。

常用信号包括:

  • SIGTERM:标准终止信号,用于请求程序正常退出。
  • SIGINT:通常由 Ctrl+C 触发。

示例代码:

$server->on('WorkerStart', function ($server, $workerId) {     if ($workerId === 0) { // 只在主工作进程中监听         pcntl_signal(SIGTERM, function () use ($server) {             echo "收到 SIGTERM,开始优雅关闭...n";             $server->shutdown();         });         pcntl_signal(SIGINT, function () use ($server) {             echo "收到 SIGINT,开始优雅关闭...n";             $server->shutdown();         });     } });  // 在主进程或管理进程中也可监听 SwooleProcess::signal(SIGTERM, function () use ($server) {     $server->shutdown(); }); 

调用 shutdown() 并等待连接自然结束

$server->shutdown() 是 Swoole 提供的优雅关闭方法。它会:

  • 关闭服务器监听端口,不再接受新连接。
  • 保留已建立的连接和正在进行的任务,等待其自然完成。

注意:shutdown() 不会强制断开现有连接,适合配合连接超时机制使用。

若希望更彻底地控制关闭过程,可在 shutdown() 后手动遍历并关闭连接:

Swoole如何优雅地关闭服务器和所有连接

有道小P

有道小P,新一代AI全科学习助手,在学习中遇到任何问题都可以问我。

Swoole如何优雅地关闭服务器和所有连接64

查看详情 Swoole如何优雅地关闭服务器和所有连接

$server->shutdown();  // 可选:延迟一段时间,等待连接自动关闭 $timer = swoole_timer_after(5000, function () use ($server) {     foreach ($server->connections as $fd) {         if ($server->exists($fd)) {             $server->close($fd);         }     }     echo "所有连接已关闭。n"; }); 

处理长连接与心跳机制

对于 websocket 或 TCP 长连接服务,客户端可能长时间保持在线。此时仅靠 shutdown() 可能无法及时释放资源。

建议做法:

  • 在收到关闭信号后,向所有客户端发送“服务即将关闭”通知。
  • 设置合理的最大等待时间,超时后强制关闭。
  • 利用心跳检测空闲连接,提前清理无效会话。

示例:广播关闭通知

foreach ($server->connections as $fd) {     if ($server->isEstablished($fd)) {         $server->push($fd, json_encode(['type' => 'closing', 'msg' => '服务即将关闭']));     } } 

清理定时器与异步任务

如果服务中使用了定时器或异步任务,应在关闭前清除它们,防止残留执行。

// 清理所有定时器 swoole_timer_clear_all();  // 或记录 timer_id,按需清除 if (isset($this->heartbeatTimer)) {     swoole_timer_clear($this->heartbeatTimer); } 

基本上就这些。关键是通过信号监听触发 shutdown(),配合连接遍历、通知广播和资源清理,实现真正优雅的退出。不复杂但容易忽略细节。

    当前页面评论已关闭。

    text=ZqhQzanResources