😊 Thinkphp下 Gateway-woker实现热重载

Security Classification: 【C-1】 | Publish Time:2024-02-20 | Category:Coding | Edit

Expiry Notice: The article was published three months ago. Please independently assess the validity of the technical methods and code mentioned within. :)

AI Summary: 该文章介绍了一个PHP类`Push`，它利用GatewayWorker框架实现了文件监控和推送功能。在`onWorkerStart`事件中，启动了一个定时器，每秒检查指定目录（`/app/app/index/controller`）下的PHP文件是否有更新。如果发现文件的修改时间晚于上次记录的时间，便打印出更新信息并向主进程发送SIGUSR1信号以实现重新加载。还定义了`onConnect`和`onMessage`方法，用于处理客户端连接和消息发送。 --- (From Model:gpt-4o-mini-2024-07-18)

## 原理
onWorkerStart事件时添加一个计时器，绑定文件监控的代码函数即可。
## 代码
```php
<?php
namespace app\index\controller;
use app\index\service\BaseService;
use \GatewayWorker\Lib\Gateway;
use Workerman\Lib\Timer;
use RecursiveDirectoryIterator;
use RecursiveIteratorIterator;

class Push extends Base
{
	
	//首页
    public static function onConnect($client_id)
    {
        Gateway::sendToClient($client_id, json_encode(array(
            'type'      => 'init',
            'client_id' => $client_id
        )));

}

// GatewayWorker建议不做任何业务逻辑，onMessage留空即可
    public static function onMessage($client_id, $message)
    {
        // $data= json_decode($message,true);
        // $op = $data['op'];
        // $data = $data['data'];

Gateway::sendToClient($client_id, json_encode(array(
                'data222'      => $message,
                'client_id' => $client_id
            )));

}

public static function onWorkerStart($businessWorker)
    {
        $last_mtime = time();
        $_dir = "/app/app/index/controller";
        Timer::add(1, function () use (&$_dir,&$last_mtime) {
            $dir_iterator = new RecursiveDirectoryIterator($_dir);
            $iterator = new RecursiveIteratorIterator($dir_iterator);
            foreach ($iterator as $file)
            {
                // only check php files
                if(pathinfo($file, PATHINFO_EXTENSION) != 'php')
                {
                    continue;
                }
                // check mtime
                if($last_mtime < $file->getMTime())
                {
                    echo $file." update and reload\n";
                    // send SIGUSR1 signal to master process for reload
                    posix_kill(posix_getppid(), SIGUSR1);
                    $last_mtime = $file->getMTime();
                    break;
                }
            }
        });
    }
}

```

## 效果
![](https://img.meituan.net/imgupload/0b89a60d131638799279133eb18e6c3f259910.png)

## 吐槽

官方这文档 不忍直视

Comment List

5440e72a 2024/01/29

感谢！！找了很久

depy From DepyDocs TenantAdmin

不客气呢

Comment

© Copyright: This article is an original work and the copyright belongs to the Depy's docs unless marked as Reproduced

Please contact the blogger for authorization to reprint

『📕Category 』

😊 Thinkphp下 Gateway-woker实现热重载

© Copyright: This article is an original work and the copyright belongs to the Depy's docs unless marked as ReproducedPlease contact the blogger for authorization to reprint

© Copyright: This article is an original work and the copyright belongs to the Depy's docs unless marked as Reproduced

Please contact the blogger for authorization to reprint