使用workerman加速任意项目

先顶为敬

学习了！

赞！已经响应号召送上星星。^_^

🐂🍺

老大，不行哇，我拿着 laravel 项目测试运行，静态资源没成功加载到，laravel 的 缓存使用了 phpredis，提示找不到 Redis。

占位

威武霸气

厉害！已 start

赞

https://github.com/TechEmpower/FrameworkBenchmarks/pull/7626/files#diff-e853be1cf6b848987afe860157bc6ed090ffe163e868fb96e7c515c787963e89

还是没看懂这么简单的一部分 怎么就ok了，目前看上去好像就是 初始化了request

原理是吧workerman当fpm使用，吧session，cookies等使用封装函数代替了，是个不错的想法，但是不能全部直接移植使用，还需要更改一些东西

厉害

可以啊，希望webman的生态越来越好

我有点不相信不改代码，特别是引入其他库【抠鼻子】

牛

看起来是对 laravel tp6 这类封装较好的框架有效，如果拿来运行 dz dedecms 还是不行的

迟来的赞

已star，因为这个帖子才注册的账号，来晚了~

php -c cli-php.ini server.php start 正常
php -c cli-php.ini server.php start -d 就报错

[root@localhost laravel9]# php -c cli-php.ini  server.php  start -d
Adapterman v0.4 OK

Workerman[server.php] start in DAEMON mode
-------------------------------------------- WORKERMAN --------------------------------------------
Workerman version:3.5.33          PHP version:8.1.13           Event-Loop:\Workerman\Events\Select
--------------------------------------------- WORKERS ---------------------------------------------
proto   user            worker          listen                 processes    status           
tcp     root            AdapterMan      http://0.0.0.0:7070    8             [OK]            
---------------------------------------------------------------------------------------------------
Input "php server.php stop" to stop. Start success.

PHP Fatal error:  Uncaught TypeError: fclose(): Argument #1 ($stream) must be of type resource, null given in /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php:1245
Stack trace:
#0 /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php(1245): fclose()
#1 /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php(548): Workerman\Worker::resetStd()
#2 /mnt/hgfs/www/laravel9/server.php(24): Workerman\Worker::runAll()
#3 {main}
  thrown in /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php on line 1245

Fatal error: Uncaught TypeError: fclose(): Argument #1 ($stream) must be of type resource, null given in /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php:1245
Stack trace:
#0 /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php(1245): fclose()
#1 /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php(548): Workerman\Worker::resetStd()
#2 /mnt/hgfs/www/laravel9/server.php(24): Workerman\Worker::runAll()
#3 {main}
  thrown in /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php on line 1245
PHP Fatal error:  Uncaught TypeError: fclose(): Argument #1 ($stream) must be of type resource, null given in /mnt/hgfs/www/laravel9/vendor/workerman/workerman/Worker.php:1245

我的修改 不知道影响不影响

public static function resetStd()
    {
        if (!static::$daemonize || static::$_OS !== \OS_TYPE_LINUX) {
            return;
        }
        global $STDOUT, $STDERR;
        $handle = \fopen(static::$stdoutFile, "a");
        if ($handle) {
            unset($handle);
            \set_error_handler(function(){});
            $STDOUT && \fclose($STDOUT); //新增判断
            $STDERR && \fclose($STDERR); //新增判断
            \STDOUT &&  \fclose(\STDOUT); //新增判断
            \STDERR &&   \fclose(\STDERR); //新增判断
            $STDOUT = \fopen(static::$stdoutFile, "a");
            $STDERR = \fopen(static::$stdoutFile, "a");
            // change output stream
            static::$_outputStream = null;
            static::outputStream($STDOUT);
            \restore_error_handler();
            return;
        }

        throw new Exception('Can not open stdoutFile ' . static::$stdoutFile);
    }

webman和adaptman相当于是两种解决方案了吧，一种是当作fpm，一种是直接在fpm里写服务。性能应该还是webman好吧

这个怎么用啊，现有的项目直接composer require joanhey/adapterman？

牛逼，关注

如果可以完美兼容，感觉webman就不香了

@walkor 这个功能应该官方来搞

laravel9 还测试到两个问题 一个静态文件加载失败
第二个上传图片失败

Workerman version:3.5.34          PHP version:8.1.3
------------------------ WORKERS -------------------------------
worker               listen                              processes status
AdapterMan           http://0.0.0.0:8080                 8         [ok]
Error: Call to a member function getClientOriginalName() on string in E:\www\laravel9\vendor\laravel\telescope\src\Watchers\RequestWatcher.php:164
Stack trace:
#0 [internal function]: Laravel\Telescope\Watchers\RequestWatcher->Laravel\Telescope\Watchers\{closure}('files', 'name')
#1 E:\www\laravel9\vendor\laravel\telescope\src\Watchers\RequestWatcher.php(167): array_walk_recursive(Array, Object(Closure))
#2 E:\www\laravel9\vendor\laravel\telescope\src\Watchers\RequestWatcher.php(54): Laravel\Telescope\Watchers\RequestWatcher->input(Object(Illuminate\Http\Request))
#3 E:\www\laravel9\vendor\laravel\framework\src\Illuminate\Events\Dispatcher.php(421): Laravel\Telescope\Watchers\RequestWatcher->recordRequest(Object(Illuminate\Foundation\Http\Events\RequestHandled))
#4 E:\www\laravel9\vendor\laravel\framework\src\Illuminate\Events\Dispatcher.php(249): Illuminate\Events\Dispatcher->Illuminate\Events\{closure}('Illuminate\\Foun...', Array)
#5 E:\www\laravel9\vendor\laravel\framework\src\Illuminate\Foundation\Http\Kernel.php(142): Illuminate\Events\Dispatcher->dispatch('Illuminate\\Foun...')
#6 E:\www\laravel9\public\start.php(61): Illuminate\Foundation\Http\Kernel->handle(Object(Illuminate\Http\Request))
#7 E:\www\laravel9\server.php(21): run()
#8 E:\www\laravel9\vendor\workerman\workerman\Connection\TcpConnection.php(656): {closure}(Object(Workerman\Connection\TcpConnection), Array)
#9 E:\www\laravel9\vendor\workerman\workerman\Events\Select.php(292): Workerman\Connection\TcpConnection->baseRead(Resource id #142)
#10 E:\www\laravel9\vendor\workerman\workerman\Worker.php(2410): Workerman\Events\Select->loop()
#11 E:\www\laravel9\vendor\workerman\workerman\Worker.php(1406): Workerman\Worker->run()
#12 E:\www\laravel9\vendor\workerman\workerman\Worker.php(1349): Workerman\Worker::forkWorkersForWindows()
#13 E:\www\laravel9\vendor\workerman\workerman\Worker.php(547): Workerman\Worker::forkWorkers()
#14 E:\www\laravel9\server.php(24): Workerman\Worker::runAll()
#15 {main}
Worker process terminated

没看懂咋用

有没有大佬分析下这个实现原理是啥呢？

我在使用redis-queue，用的是workerman 4.*，希望早日升级到workerman 4.0，让我试试。

对于laravel 应在请求时初使化一些laravel的单例，不初使化有可能会出现单例污染情况如：auth如果不重置，会导致登陆后，
返回的是第一个登陆的用户信息，
在run中加入：$kernel->getApplication()->forgetInstance('auth')；如下，当然还有其它组件，用啥加啥

$kernel->getApplication()->forgetInstance('auth')；
$response = $kernel->handle(
            $request = Illuminate\Http\Request::capture()
        );

具体有多少单例是通过 判断变量返结果的，得大家使用中发现或者参考：swoole与laravel的整合了完善！
目前用于生产应核有点难，除非用的组件少，

thinkphp6能用了么

顶顶更健康

laravel 使用得自己加一条动态路由实现，静态路由会有一个问题：控制器中的 ，__construct 方法只会执行首次，路由也是按单例模式只初使化一次，要吗得按webman方法改变一下路由为每次初使化，当然不使用__construct魔术方法就好了

HttpForPHP 我这个项目也是一样的 为什么就没有人关注下
使用workerman实现http服务，把现有其他框架的代码简单改为常驻内存http服务，未实现session支持，最适合用于接口服务，已有在yii项目中运行，参见自带的yii示例。
原理就是对PHP的$_SERVER $_COOKIE $_FILES $_REQUEST $_POST $_GET全局变量重置数据
$_SESSION太麻烦就没有处理 毕竟只针对接口应用的服务 所以就没有必要

主页：https://github.com/ncwsky/HttpForPHP

文件上传是不是需要单独处理啊，其他的都没有问题，就是上传文件这个地方不管用

thinkphp6咋用的啊

我尝试了一下适配现有项目，现有项目使用的lumen，发现http post body 里面的值，在lumen 的$request对象里获取不到，是我使用姿势不对吗？

看了下，骚操作呀，应该是可以适配任意项目，本质就直接禁止掉部分系统函数，手动实现去适配

最大的障碍就是静态引用。
所以说零代码改动是不可能的。

这个需要php8 老项目版本一般比较低，会兼容吗？

不明所以，随便看看

thinkphp6 加速失败 各种报错...

安装报错 composer require joanhey/adapterman

Problem 1
    - Root composer.json requires joanhey/adapterman ^0.5.5 -> satisfiable by joanhey/adapterman[0.5.5].
    - joanhey/adapterman 0.5.5 requires workerman/workerman ^3.5 -> found workerman/workerman[v3.5.0, ..., v3.5.34] but it conflicts with your root composer.json require (^4.1).

是我用tp6，已经安装过workerman了，版本较高

牛逼的项目

Test environment:
Mac 13.3.1
Workerman version:4.1.5
PHP version:8.1.17
Event-Loop:\Workerman\Events\Select
Adapterman: 0.6.1
Laravel : 9.33.0
当我运行 php server.php start 时是可正常使用的，但是当我运行php server.php start -d 在访问接口的时候就报错了，错误在这个帖子里。
https://github.com/joanhey/AdapterMan/issues/36

我现在的疑问是 workerman的守护模式和非守护模式有什么不一样的地方？不知道有没有人遇到这样的问题

laravel 文件上传处理，更改原码中 http.php 500行，下面的switch部分为：

 switch ($header_key) {
                    case "content-disposition":
                        // Is file data.
                        if (\preg_match('/name="(.*?)"; filename="(.*?)"/', $header_value, $match)) {
                            $error = 0;
                            $tmp_file = '';
                            $file_name = $match[2];
                            $size = \strlen($boundary_value);
                            $tmp_upload_dir = \Workerman\Protocols\Http::uploadTmpDir();
                            if (!$tmp_upload_dir) {
                                $error = UPLOAD_ERR_NO_TMP_DIR;
                            } else if ($boundary_value === '' && $file_name === '') {
                                $error = UPLOAD_ERR_NO_FILE;
                            } else {
                                $tmp_file = \tempnam($tmp_upload_dir, 'workerman.upload.');
                                if ($tmp_file === false || false === \file_put_contents($tmp_file, $boundary_value)) {
                                    $error = UPLOAD_ERR_CANT_WRITE;
                                }
                            }
                            $upload_key = $match[1];
                            // Parse upload files.
                            $_FILES[$upload_key] = [
                                'name' => $file_name,
                                'tmp_name' => $tmp_file,
                                'size' => $size,
                                'error' => $error,
                                'type' => '',
                            ];
                            break;
                        } // Is post field.
                        else {
                            // Parse $_POST.
                            if (\preg_match('/name="(.*?)"$/', $header_value, $match)) {
                                //TODO search a fast solution
                                $post_encode_string .= urlencode($match[1]) . '=' . urlencode($boundary_value) . '&';
                            }
                        }
                        break;
                    case "content-type":
                        // add file_type
                        $_FILES[$upload_key]['type'] = \trim($header_value);
                        break;
                }

php7.X 能跑吗？装了一下提示PHP版本不兼容，看了一下貌似要 PHP8 以上

唯一的问题： 代码创建的 静态变量 怎么解决？如何一键清理所有静态变量？

需要老大修改一下workerman，来解决内存泄漏的问题
$http_worker->onMessage = static function ($connection, $request) {
$connection->send(run());
};
这里onMessage 需要改一下。增加一个控制的开关：实现每次收到消息后都用新进程处理，解决静态变量、内存泄漏的问题：
方法：
onWorkerStart执行一些需要提前加载的代码之后，worker进程提前fork出很多子进程备用，
然后每次 onMessage 接收到消息都用fork出的进程处理，用完就销毁，同时fork一个新的。

其中涉及到信号的处理，fork出的进程如何接收数据和主进程通讯等

看时间节点，已经使用两年半了，哈哈哈哈

明天试试在Thinkphp6或者8上面是什么效果

加速的话对服务器内存要求是多少呀，资源消耗会很大嘛