呕心搜集总结的15个“swoole”常见问题(二)

之前已经说了前面八个问题,现在接着往下分享,没有看到之前的文章的可以点击这里哦~

九、Swoole如何正确的重启服务

在我们修改了 PHP 代码后经常需要重启服务让代码生效,一台繁忙的后端服务器随时都在处理请求,如果管理员通过 kill 进程方式来终止 / 重启服务器程序,可能导致刚好代码执行到一半终止,没法保证整个业务逻辑的完整性。

Swoole 提供了柔性终止 / 重启的机制,管理员只需要向 Server 发送特定的信号或者调用 reload 方法,工作进程就可以结束,并重新拉起。

但有几点要注意:

首先要注意新修改的代码必须要在 OnWorkerStart 事件中重新载入才会生效,比如某个类在 OnWorkerStart 之前就通过 composer 的 autoload 载入了就是不可以的。

其次 reload 还要配合这两个参数 max_wait_time 和 reload_async,设置了这两个参数之后就能实现异步安全重启

如果没有此特性,Worker 进程收到重启信号或达到 max_request 时,会立即停止服务,这时 Worker 进程内可能仍然有事件监听,这些异步任务将会被丢弃。设置上述参数后会先创建新的 Worker,旧的 Worker 在完成所有事件之后自行退出,即 reload_async。

如果旧的 Worker 一直不退出,底层还增加了一个定时器,在约定的时间 ( max_wait_time 秒) 内旧的 Worker 没有退出,底层会强行终止。

示例:

<?php

$serv = new Swoole\Server("0.0.0.0", 9501, SWOOLE_PROCESS);

$serv->set(array(

'worker_num' => 1,

'max_wait_time' => 60,

'reload_async' => true,

));

$serv->on('receive', function (Swoole\Server $serv, $fd, $reactor_id, $data) {

echo"[#" . $serv->worker_id . "]\tClient[$fd] receive data: $data\n";

Swoole\Timer::tick(5000, function () {

echo'tick';

});

});

$serv->start();

例如上面的代码 如果没有 reload_async 那么 onReceive 中创建的定时器将丢失,没有机会处理定时器中的回调函数。

进程退出事件

为了支持异步重启特性,底层新增了一个 onWorkerExit 事件,当旧的 Worker 即将退出时,会触发 onWorkerExit 事件,在此事件回调函数中,应用层可以尝试清理某些长连接 Socket,直到事件循环中没有 fd 或者达到了 max_wait_time 退出进程。

$serv->on('WorkerExit', function (Swoole\Server $serv, $worker_id) {

$redisState = $serv->redis->getState();

if ($redisState == Swoole\Redis::STATE_READY or $redisState == Swoole\Redis::STATE_SUBSCRIBE)

{

$serv->redis->close();

}

});

同时我们在 Swoole Plus 中增加了检测文件变化的功能,可以不用手动 reload 或者发送信号,文件变更自动重启 worker。

十、为什么不要send完后立即close就是不安全的

send 完后立即 close 就是不安全的,无论是服务器端还是客户端。

send 操作成功只是表示数据成功地写入到操作系统 socket 缓存区,不代表对端真的接收到了数据。究竟操作系统有没有发送成功,对方服务器是否收到,服务器端程序是否处理,都没办法确切保证。

close 后的逻辑请看下面的 linger 设置相关

这个逻辑和电话沟通是一个道理,A 告诉 B 一个事情,A 说完了就挂掉电话。那么 B 听到没有,A 是不知道的。如果 A 说完事情,B 说好,然后 B 挂掉电话,就绝对是安全的。

linger 设置

一个 socket 在 close 时,如果发现缓冲区仍然有数据,操作系统底层会根据 linger 设置决定如何处理

struct linger

{

int l_onoff;

int l_linger;

};

  • l_onoff = 0,close 时立刻返回,底层会将未发送完的数据发送完成后再释放资源,也就是优雅的退出。
  • l_onoff != 0,l_linger = 0,close 时会立刻返回,但不会发送未发送完成的数据,而是通过一个 RST 包强制的关闭 socket 描述符,也就是强制的退出。
  • l_onoff !=0,l_linger > 0, closes 时不会立刻返回,内核会延迟一段时间,这个时间就由 l_linger 的值来决定。如果超时时间到达之前,发送完未发送的数据 (包括 FIN 包) 并得到另一端的确认,close 会返回正确,socket 描述符优雅性退出。否则 close 会直接返回错误值,未发送数据丢失,socket 描述符被强制性退出。如果 socket 描述符被设置为非堵塞型,则 close 会直接返回值。

十一、连接已关闭问题

如以下提示

NOTICE    swFactoryProcess_finish (ERRNO 1004): send 165 byte failed, because connection[fd=123] is closed

NOTICE swFactoryProcess_finish (ERROR 1005): connection[fd=123] does not exists

服务端响应时,客户端已经切断了连接导致

常见于:

  • 浏览器疯狂刷新页面 (还没加载完就刷掉了)
  • ab 压测到一半取消
  • wrk 基于时间的压测 (时间到了未完成的请求会被取消)

以上几种情况均属于正常现象,可以忽略,所以该错误的级别是 NOTICE

如由于其它情况无缘无故出现大量连接断开时,才需要注意

十二、学习Swoole需要掌握哪些基础知识

1、多进程/多线程

  • 了解 Linux 操作系统进程和线程的概念
  • 了解 Linux 进程 / 线程切换调度的基本知识
  • 了解进程间通信的基本知识,如管道、UnixSocket、消息队列、共享内存

2、SOCKET

  • 了解 SOCKET 的基本操作如 accept/connectsend/recvcloselistenbind

  • 了解 SOCKET 的接收缓存区、发送缓存区、阻塞 / 非阻塞、超时等概念

3、IO复用

  • 了解 select/poll/epoll

  • 了解基于 select/epoll 实现的事件循环,Reactor 模型
  • 了解可读事件、可写事件

4、TCP/IP网络协议

  • 了解 TCP/IP 协议
  • 了解 TCPUDP 传输协议

5、调试工具

  • 使用 gdb 调试 Linux 程序
  • 使用 strace 跟踪进程的系统调用
  • 使用 tcpdump 跟踪网络通信过程
  • 其他 Linux 系统工具,如 ps、lsof、top、vmstat、netstat、sar、ss 等

十三、是否可以共用1个Redis或MySQL连接

绝对不可以。必须每个进程单独创建 RedisMySQLPDO 连接,其他的存储客户端同样也是如此。原因是如果共用 1 个连接,那么返回的结果无法保证被哪个进程处理,持有连接的进程理论上都可以对这个连接进行读写,这样数据就发生错乱了。

所以在多个进程之间,一定不能共用连接

  • 在 Swoole\Server 中,应当在 onWorkerStart 中创建连接对象
  • 在 Swoole\Process 中,应当在 Swoole\Process->start 后,子进程的回调函数中创建连接对象
  • 此问题所述信息对使用 pcntl_fork 的程序同样有效

示例:

$server = new Swoole\Server("0.0.0.0", 9502);

//必须在onWorkerStart回调中创建redis/mysql连接

$server->on('workerstart', function($server, $id) {

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

$server->redis = $redis;

});

$server->on('receive', function (Swoole\Server $server, $fd, $from_id, $data) {

$value = $server->redis->get("key");

$server->send($fd, "Swoole: ".$value);

});

$server->start();

十四、Call to undefined function Co\Run()

本文档中的大部分示例都使用了 Co\run() 来创建一个协程容器,了解什么是协程容器

如果遇到如下错误:

PHP Fatal error:  Uncaught Error: Call to undefined function Co\Run()

PHP Fatal error: Uncaught Error: Call to undefined function go()

说明你的 Swoole 扩展版本小于 v4.4.0 或者手动关闭了协程短名称,提供三种解决方法

  • 如果是版本过低,则请升级扩展版本至 >= v4.4.0 或使用 go 关键字替换 Co\Run 来创建协程;
  • 如果是关闭了协程短名称,则请打开协程短名称;
  • 使用 Coroutine::create 方法替换 Co\Rungo 来创建协程;

十五、Resource temporarily unavailable[11]

客户端 swoole_client 在 recv 时报

swoole_client::recv(): recv() failed. Error: Resource temporarily unavailable [11] 

这个错误表示,服务器端在规定的时间内没有返回数据,接收超时了。

  • 可以通过 tcpdump 查看网络通信过程,检查服务器是否发送了数据
  • 服务器的 $serv->send 函数需要检测是否返回了 true
  • 外网通信时,耗时较多需要调大 swoole_client 的超时时间

进阶PHP月薪30k>>>架构师成长路线【视频、面试文档免费获取】​

我的官方群点击此处加入群聊【PHP高级学习交流群953224940】,一起学习,相互讨论。群内已经有管理将知识体系整理好(源码,学习视频等资料),欢迎免费领取。

这套精品PHP教程绝不是市场上的那些妖艳贱货可比,作为web开发的佼佼者PHP并不逊色其他语言,加上Swoole后更加是如虎添翼!进军通信 、物联网行业开发百度地图、百度订单中心、虎牙、战旗TV等!寒冬裁员期过后正是各大企业扩大招人的时期,现在市场初级程序员泛滥,进阶中高级程序员绝对是各大企业急需的人才,这套学习教程适合那些1-5年以内的PHP开发者正处于瓶颈期,想要突破自己进阶中高级、架构师!名额有限,先到先得!

部分资料截图:




还有限时精品福利:

★腾讯高级PHP工程师笔试题目

★亿级PV高并发场景订单的处理

★laravel开发天猫商城组件服务

★战旗TV视频直播的架构项目实战

扫描下面二维码领取

正在跳转(二维码自动跳转)

对PHP后端技术,对PHP架构技术感兴趣的朋友,我的的官方群953224940,一起学习,相互讨论。

群内已经有管理将知识体系整理好(源码,学习视频等资料),欢迎免费领取。

本课程深度对标腾讯T3-T4标准,贴身打造学习计划为web开发人员进阶中高级、架构师提升技术,为自己增值涨薪!加入BAT特训营还可以获得内推大厂名额以及GO语言学习权限!!!


以上是 呕心搜集总结的15个“swoole”常见问题(二) 的全部内容, 来源链接: utcz.com/a/36147.html

回到顶部