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

## 吐槽

官方这文档 不忍直视

Web3 Info

The ownership of the data in this article is secured by blockchain encryption technology and smart contracts, and is solely owned by the creator.

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