守护进程、信号和平滑重启

守护进程

守护进程(daemon)就是一种长期生存的进程,它不受终端的控制,可以在后台运行。其实我们之前也有了解,比如说nginx,fpm等一般都是作为守护进程在后台提供服务。

Swoole实现守护进程

参考参数: daemonize

$serv->set([
    'worker_num' => 1,//设置进程
    'daemonize' => true, // 启用守护进程
    'log_file' => __DIR__ . 'server.log'
]);

启用守护进程后,server内所有的标准输出都会被丢弃,这样的话我们也就无法跟踪进程在运行过程中是否异常之类的错误信息了。一般会配合log_file我们可以指定日志路径,这样swoole在运行时就会把所有的标准输出统统记载到该文件内。

平滑重启

当将服务端设置守护进程之后,程序常驻内存, 当修改了代码.通过ctrl+c或者kill杀掉进程终止然后重新运行,当然可以使修改后的代码生效.

但是如果是上线的项目,一台繁忙的后端服务器随时都在处理请求,如果管理员通过kill进程方式来终止/重启服务器程序,可能导致刚好代码执行到一半终止。

这种情况下会产生数据的不一致。如交易系统中,支付逻辑的下一段是发货,假设在支付逻辑之后进程被终止了。会导致用户支付了货币,但并没有发货,后果非常严重。

如何解决?

这个时候我们需要考虑如何平滑重启server的问题了。所谓的平滑重启,也叫“热重启”,就是在不影响用户的情况下重启服务,更新内存中已经加载的php程序代码,从而达到对业务逻辑的更新。

swoole为我们提供了平滑重启机制,我们只需要向swoole_server的主进程发送特定的信号,即可完成对server的重启。

那什么是信号呢?

信号的名字都以“SIG”开头,比如我们最熟悉的Ctrl+C就是一个名字叫“SIGINT”的信号,意味着“终端中断”。

在swoole中,我们可以向主进程发送各种不同的信号,主进程根据接收到的信号类型做出不同的处理。比如下面这几个

  • 1、kill -SIGTERM master_pid终止Swoole程序,一种优雅的终止信号,会待进程执行完当前程序之后中断,而不是直接干掉进程

  • 2、kill -USR1 master_pid重启所有的Worker进程

  • 3、kill -USR2 master_pid 重启所有的Task Worker进程

当USR1信号被发送给Master进程后,Master进程会将同样的信号通过Manager进程转发Worker进程,收到此信号的Worker进程会在处理完正在执行的逻辑之后,释放进程内存,关闭自己,然后由Manager进程重启一个新的Worker进程。新的Worker进程会占用新的内存空间。

kill -9这里面的-n是指信号, Linux信号表 (网上有大把文章).其中比较常见的是

9(SIGKILL):立即结束程序的运行.本信号不能被阻塞、处理和忽略

2(SIGINT):程序终止(interrupt)信号,譬如Ctrl+C时发出

15(SIGTERM):可以被阻塞和处理。通常用来要求程序自己正常退出

参考资料:https://wiki.swoole.com/wiki/page/138.html

注意事项:

1、更新仅仅只是针对worker进程,也就是写在master进程跟manger进程当中更新代码并不生效,也就是说只有在onWorkerStart回调之后加载的文件,重启才有意义。在Worker进程启动之前就已经加载到内存中的文件,如果想让它重新生效,只能关闭server再重启。

2、直接写在worker代码当中的逻辑是不会生效的,就算发送了信号也不会,需要通过include方式引入相关的业务逻辑代码才会生效

实际操作

1、首先,我们需要在程序中注册自动加载函数,通过这些自动加载函数实现逻辑文件的更新。

//主进程
$serv->on('start', function ($serv) {
       //swoole_set_process_name("server:master");
       //echo "主进程启动". PHP_EOL;
});

//全局共享

//管理进程
$serv->on('managerStart', function ($serv) {
      //swoole_set_process_name("server:manage");
      echo "管理进程启动". PHP_EOL;
});

//工作进程
$serv->on('WorkerStart', function ($serv,$worker_id) {

     var_dump($serv->master_pid);
     file_put_contents("/tmp/master_pid", $serv->master_pid);

    //为什么需要每一个worker进程都加载一次?每个进程相互独立互不影响
     include_once __DIR__.'/auto.php';

    //swoole_set_process_name("server:Worker");
    //echo "工作进程启动". PHP_EOL;
});

auto.php

<?php
//自动加载
spl_autoload_register(function($class){
     include_once  __DIR__."/{$class}.php";

});

2、其次,我们需要保存服务的Master进程的进程号在目录下创建一个server.pid文件来保存,并在需要重新加载新文件的时候,向Master进程发送USR1信号。当Worker进程重启后,之前加载过的文件就从内存中移除,下一次请求时就会重新加载新的文件。

注意:

1、OnWorkerStart回调加载的代码都在各自进程中,OnWorkerStart之前加载的代码属于共享内存。

2、可以将公用的,不易变的php文件放置到onWorkerStart之前。这样虽然不能重载入代码,但所有worker是共享的,不需要额外的内存来保存这些数据。onWorkerStart之后的代码每个worker都需要在内存中保存一份.

Last updated