发表新帖

Swoole\Process\Pool多进程代码热更新问题

以包含文件的方式引入代码，当使用SIGUSR1、SIGUSR2、USR1、USR2进行重启的时候都不能实现代码更新，表现在计算以及写文件的内容。不知道为什么****

swoole.php

<?php
$workerNum = 10;
$pool = new Swoole\Process\Pool($workerNum);

$pool->on("WorkerStart", function ($pool, $workerId) {

require_once './data_process.php';

$run = new data_process($workerId);

$run->run();
});

$pool->on("WorkerStop", function ($pool, $workerId) {
    echo "Worker#{$workerId} is stopped\n";
});

$pool->start();

<?php

class data_process
{
    public $workId = 0;

public function __construct($workId = 0)
    {
        $this->workId  = $workId;
    }

public function run()
    {
        echo "Worker#{$this->workId} is started **888**\n";
        file_put_contents(dirname(__FILE__).'/a.txt', PHP_EOL.'bb', FILE_APPEND);
        $redis = new Redis();
        $redis->pconnect('127.0.0.1', 6379);
        $key = "key1";
        while (true) {
            $msg = $redis->brpop($key, 2);
            if ( $msg == null) continue;
            $msg[1] += 1;
            var_dump($msg);
        }

return;
    }
}

发布于6年前 · 6 次浏览 · 来自提问

bredeli

以包含文件的方式引入代码，当使用SIGUSR1、SIGUSR2、USR1、USR2进行重启的时候都不能实现代码更新，表现在计算以及写文件的内容。不知道为什么****

swoole.php

<?php
$workerNum = 10;
$pool = new Swoole\Process\Pool($workerNum);

$pool->on("WorkerStart", function ($pool, $workerId) {

require_once './data_process.php';

$run = new data_process($workerId);

$run->run();
});

$pool->on("WorkerStop", function ($pool, $workerId) {
    echo "Worker#{$workerId} is stopped\n";
});

$pool->start();

<?php

class data_process
{
    public $workId = 0;

public function __construct($workId = 0)
    {
        $this->workId  = $workId;
    }

return;
    }
}

登录后参与评论

2020-03-20

郭新华

2020-03-20

bredeli 回复郭新华

2020-03-19

Twosee

2020-03-19

bredeli 回复 Twosee

2020-12-04

路上回复 bredeli