first commit
This commit is contained in:
Enoch
commit
f0701d25b9
8
.gitignore
vendored
Normal file
8
.gitignore
vendored
Normal file
@ -0,0 +1,8 @@
|
|||||||
|
/runtime
|
||||||
|
/.idea
|
||||||
|
/.vscode
|
||||||
|
/vendor
|
||||||
|
*.log
|
||||||
|
.env
|
||||||
|
/tests/tmp
|
||||||
|
/tests/.phpunit.result.cache
|
||||||
21
LICENSE
Normal file
21
LICENSE
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
MIT License
|
||||||
|
|
||||||
|
Copyright (c) 2021 walkor<walkor@workerman.net> and contributors (see https://github.com/walkor/webman/contributors)
|
||||||
|
|
||||||
|
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
|
of this software and associated documentation files (the "Software"), to deal
|
||||||
|
in the Software without restriction, including without limitation the rights
|
||||||
|
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||||
|
copies of the Software, and to permit persons to whom the Software is
|
||||||
|
furnished to do so, subject to the following conditions:
|
||||||
|
|
||||||
|
The above copyright notice and this permission notice shall be included in all
|
||||||
|
copies or substantial portions of the Software.
|
||||||
|
|
||||||
|
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||||
|
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||||
|
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||||
|
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||||
|
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||||
|
SOFTWARE.
|
||||||
59
README.md
Normal file
59
README.md
Normal file
@ -0,0 +1,59 @@
|
|||||||
|
<div style="padding:18px;max-width: 1024px;margin:0 auto;background-color:#fff;color:#333">
|
||||||
|
<h1>webman</h1>
|
||||||
|
|
||||||
|
基于<a href="https://www.workerman.net" target="__blank">workerman</a>开发的超高性能PHP框架
|
||||||
|
|
||||||
|
|
||||||
|
<h1>学习</h1>
|
||||||
|
|
||||||
|
<ul>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/webman" target="__blank">主页 / Home page</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/doc/webman" target="__blank">文档 / Document</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/doc/webman/install.html" target="__blank">安装 / Install</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/questions" target="__blank">问答 / Questions</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/apps" target="__blank">市场 / Apps</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/sponsor" target="__blank">赞助 / Sponsors</a>
|
||||||
|
</li>
|
||||||
|
<li>
|
||||||
|
<a href="https://www.workerman.net/doc/webman/thanks.html" target="__blank">致谢 / Thanks</a>
|
||||||
|
</li>
|
||||||
|
</ul>
|
||||||
|
|
||||||
|
<div style="float:left;padding-bottom:30px;">
|
||||||
|
|
||||||
|
<h1>赞助商</h1>
|
||||||
|
|
||||||
|
<h4>特别赞助</h4>
|
||||||
|
<a href="https://www.crmeb.com/?form=workerman" target="__blank">
|
||||||
|
<img src="https://www.workerman.net/img/sponsors/6429/20230719111500.svg" width="200">
|
||||||
|
</a>
|
||||||
|
|
||||||
|
<h4>铂金赞助</h4>
|
||||||
|
<a href="https://www.fadetask.com/?from=workerman" target="__blank"><img src="https://www.workerman.net/img/sponsors/1/20230719084316.png" width="200"></a>
|
||||||
|
<a href="https://www.yilianyun.net/?from=workerman" target="__blank" style="margin-left:20px;"><img src="https://www.workerman.net/img/sponsors/6218/20230720114049.png" width="200"></a>
|
||||||
|
|
||||||
|
<h4>金牌赞助</h4>
|
||||||
|
|
||||||
|
|
||||||
|
</div>
|
||||||
|
|
||||||
|
|
||||||
|
<div style="clear: both">
|
||||||
|
<h1>LICENSE</h1>
|
||||||
|
The webman is open-sourced software licensed under the MIT.
|
||||||
|
</div>
|
||||||
|
|
||||||
|
</div>
|
||||||
|
|
||||||
|
|
||||||
28
app/controller/IndexController.php
Normal file
28
app/controller/IndexController.php
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace app\controller;
|
||||||
|
|
||||||
|
use support\Request;
|
||||||
|
|
||||||
|
class IndexController
|
||||||
|
{
|
||||||
|
public function index(Request $request)
|
||||||
|
{
|
||||||
|
static $readme;
|
||||||
|
if (!$readme) {
|
||||||
|
$readme = file_get_contents(base_path('README.md'));
|
||||||
|
}
|
||||||
|
return $readme;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function view(Request $request)
|
||||||
|
{
|
||||||
|
return view('index/view', ['name' => 'webman']);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function json(Request $request)
|
||||||
|
{
|
||||||
|
return json(['code' => 0, 'msg' => 'ok']);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
4
app/functions.php
Normal file
4
app/functions.php
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* Here is your custom functions.
|
||||||
|
*/
|
||||||
42
app/middleware/StaticFile.php
Normal file
42
app/middleware/StaticFile.php
Normal file
@ -0,0 +1,42 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace app\middleware;
|
||||||
|
|
||||||
|
use Webman\MiddlewareInterface;
|
||||||
|
use Webman\Http\Response;
|
||||||
|
use Webman\Http\Request;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Class StaticFile
|
||||||
|
* @package app\middleware
|
||||||
|
*/
|
||||||
|
class StaticFile implements MiddlewareInterface
|
||||||
|
{
|
||||||
|
public function process(Request $request, callable $next): Response
|
||||||
|
{
|
||||||
|
// Access to files beginning with. Is prohibited
|
||||||
|
if (strpos($request->path(), '/.') !== false) {
|
||||||
|
return response('<h1>403 forbidden</h1>', 403);
|
||||||
|
}
|
||||||
|
/** @var Response $response */
|
||||||
|
$response = $next($request);
|
||||||
|
// Add cross domain HTTP header
|
||||||
|
/*$response->withHeaders([
|
||||||
|
'Access-Control-Allow-Origin' => '*',
|
||||||
|
'Access-Control-Allow-Credentials' => 'true',
|
||||||
|
]);*/
|
||||||
|
return $response;
|
||||||
|
}
|
||||||
|
}
|
||||||
29
app/model/Test.php
Normal file
29
app/model/Test.php
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace app\model;
|
||||||
|
|
||||||
|
use support\Model;
|
||||||
|
|
||||||
|
class Test extends Model
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* The table associated with the model.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $table = 'test';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The primary key associated with the table.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $primaryKey = 'id';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Indicates if the model should be timestamped.
|
||||||
|
*
|
||||||
|
* @var bool
|
||||||
|
*/
|
||||||
|
public $timestamps = false;
|
||||||
|
}
|
||||||
14
app/view/index/view.html
Normal file
14
app/view/index/view.html
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
<!doctype html>
|
||||||
|
<html>
|
||||||
|
<head>
|
||||||
|
<meta charset="utf-8">
|
||||||
|
<meta http-equiv="X-UA-Compatible" content="IE=edge">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1">
|
||||||
|
<link rel="shortcut icon" href="/favicon.ico"/>
|
||||||
|
<title>webman</title>
|
||||||
|
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
hello <?=htmlspecialchars($name)?>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
71
composer.json
Normal file
71
composer.json
Normal file
@ -0,0 +1,71 @@
|
|||||||
|
{
|
||||||
|
"name": "workerman/webman",
|
||||||
|
"type": "project",
|
||||||
|
"keywords": [
|
||||||
|
"high performance",
|
||||||
|
"http service"
|
||||||
|
],
|
||||||
|
"homepage": "https://www.workerman.net",
|
||||||
|
"license": "MIT",
|
||||||
|
"description": "High performance HTTP Service Framework.",
|
||||||
|
"authors": [
|
||||||
|
{
|
||||||
|
"name": "walkor",
|
||||||
|
"email": "walkor@workerman.net",
|
||||||
|
"homepage": "https://www.workerman.net",
|
||||||
|
"role": "Developer"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"support": {
|
||||||
|
"email": "walkor@workerman.net",
|
||||||
|
"issues": "https://github.com/walkor/webman/issues",
|
||||||
|
"forum": "https://wenda.workerman.net/",
|
||||||
|
"wiki": "https://workerman.net/doc/webman",
|
||||||
|
"source": "https://github.com/walkor/webman"
|
||||||
|
},
|
||||||
|
"require": {
|
||||||
|
"php": ">=7.2",
|
||||||
|
"workerman/webman-framework": "^1.5.0",
|
||||||
|
"monolog/monolog": "^2.0",
|
||||||
|
"illuminate/database": "^9.52",
|
||||||
|
"illuminate/pagination": "^9.52",
|
||||||
|
"illuminate/events": "^9.52",
|
||||||
|
"symfony/var-dumper": "^6.0",
|
||||||
|
"jasongrimes/paginator": "~1.0",
|
||||||
|
"robmorgan/phinx": "^0.14.0",
|
||||||
|
"illuminate/redis": "^9.52",
|
||||||
|
"symfony/cache": "^6.0",
|
||||||
|
"workerman/validation": "^3.1",
|
||||||
|
"symfony/translation": "^6.0",
|
||||||
|
"webman/captcha": "^1.0",
|
||||||
|
"webman/event": "^1.0",
|
||||||
|
"vlucas/phpdotenv": "^5.6",
|
||||||
|
"workerman/crontab": "^1.0",
|
||||||
|
"yzh52521/easyhttp": "^1.1"
|
||||||
|
},
|
||||||
|
"suggest": {
|
||||||
|
"ext-event": "For better performance. "
|
||||||
|
},
|
||||||
|
"autoload": {
|
||||||
|
"psr-4": {
|
||||||
|
"": "./",
|
||||||
|
"app\\": "./app",
|
||||||
|
"App\\": "./app",
|
||||||
|
"app\\View\\Components\\": "./app/view/components"
|
||||||
|
},
|
||||||
|
"files": [
|
||||||
|
"./support/helpers.php"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"scripts": {
|
||||||
|
"post-package-install": [
|
||||||
|
"support\\Plugin::install"
|
||||||
|
],
|
||||||
|
"post-package-update": [
|
||||||
|
"support\\Plugin::install"
|
||||||
|
],
|
||||||
|
"pre-package-uninstall": [
|
||||||
|
"support\\Plugin::uninstall"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
4863
composer.lock
generated
Normal file
4863
composer.lock
generated
Normal file
File diff suppressed because it is too large
Load Diff
26
config/app.php
Normal file
26
config/app.php
Normal file
@ -0,0 +1,26 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
use support\Request;
|
||||||
|
|
||||||
|
return [
|
||||||
|
'debug' => true,
|
||||||
|
'error_reporting' => E_ALL,
|
||||||
|
'default_timezone' => 'Asia/Shanghai',
|
||||||
|
'request_class' => Request::class,
|
||||||
|
'public_path' => base_path() . DIRECTORY_SEPARATOR . 'public',
|
||||||
|
'runtime_path' => base_path(false) . DIRECTORY_SEPARATOR . 'runtime',
|
||||||
|
'controller_suffix' => 'Controller',
|
||||||
|
'controller_reuse' => false,
|
||||||
|
];
|
||||||
21
config/autoload.php
Normal file
21
config/autoload.php
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
'files' => [
|
||||||
|
base_path() . '/app/functions.php',
|
||||||
|
base_path() . '/support/Request.php',
|
||||||
|
base_path() . '/support/Response.php',
|
||||||
|
]
|
||||||
|
];
|
||||||
18
config/bootstrap.php
Normal file
18
config/bootstrap.php
Normal file
@ -0,0 +1,18 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
support\bootstrap\Session::class,
|
||||||
|
support\bootstrap\LaravelDb::class,
|
||||||
|
];
|
||||||
15
config/container.php
Normal file
15
config/container.php
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return new Webman\Container;
|
||||||
15
config/database.php
Normal file
15
config/database.php
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [];
|
||||||
15
config/dependence.php
Normal file
15
config/dependence.php
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [];
|
||||||
5
config/event.php
Normal file
5
config/event.php
Normal file
@ -0,0 +1,5 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
return [
|
||||||
|
|
||||||
|
];
|
||||||
17
config/exception.php
Normal file
17
config/exception.php
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
'' => support\exception\Handler::class,
|
||||||
|
];
|
||||||
32
config/log.php
Normal file
32
config/log.php
Normal file
@ -0,0 +1,32 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
'default' => [
|
||||||
|
'handlers' => [
|
||||||
|
[
|
||||||
|
'class' => Monolog\Handler\RotatingFileHandler::class,
|
||||||
|
'constructor' => [
|
||||||
|
runtime_path() . '/logs/webman.log',
|
||||||
|
7, //$maxFiles
|
||||||
|
Monolog\Logger::DEBUG,
|
||||||
|
],
|
||||||
|
'formatter' => [
|
||||||
|
'class' => Monolog\Formatter\LineFormatter::class,
|
||||||
|
'constructor' => [null, 'Y-m-d H:i:s', true],
|
||||||
|
],
|
||||||
|
]
|
||||||
|
],
|
||||||
|
],
|
||||||
|
];
|
||||||
15
config/middleware.php
Normal file
15
config/middleware.php
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [];
|
||||||
4
config/plugin/webman/event/app.php
Normal file
4
config/plugin/webman/event/app.php
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
<?php
|
||||||
|
return [
|
||||||
|
'enable' => true,
|
||||||
|
];
|
||||||
17
config/plugin/webman/event/bootstrap.php
Normal file
17
config/plugin/webman/event/bootstrap.php
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
Webman\Event\BootStrap::class,
|
||||||
|
];
|
||||||
7
config/plugin/webman/event/command.php
Normal file
7
config/plugin/webman/event/command.php
Normal file
@ -0,0 +1,7 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
use Webman\Event\EventListCommand;
|
||||||
|
|
||||||
|
return [
|
||||||
|
EventListCommand::class
|
||||||
|
];
|
||||||
42
config/process.php
Normal file
42
config/process.php
Normal file
@ -0,0 +1,42 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
global $argv;
|
||||||
|
|
||||||
|
return [
|
||||||
|
// File update detection and automatic reload
|
||||||
|
'monitor' => [
|
||||||
|
'handler' => process\Monitor::class,
|
||||||
|
'reloadable' => false,
|
||||||
|
'constructor' => [
|
||||||
|
// Monitor these directories
|
||||||
|
'monitorDir' => array_merge([
|
||||||
|
app_path(),
|
||||||
|
config_path(),
|
||||||
|
base_path() . '/process',
|
||||||
|
base_path() . '/support',
|
||||||
|
base_path() . '/resource',
|
||||||
|
base_path() . '/.env',
|
||||||
|
], glob(base_path() . '/plugin/*/app'), glob(base_path() . '/plugin/*/config'), glob(base_path() . '/plugin/*/api')),
|
||||||
|
// Files with these suffixes will be monitored
|
||||||
|
'monitorExtensions' => [
|
||||||
|
'php', 'html', 'htm', 'env'
|
||||||
|
],
|
||||||
|
'options' => [
|
||||||
|
'enable_file_monitor' => !in_array('-d', $argv) && DIRECTORY_SEPARATOR === '/',
|
||||||
|
'enable_memory_monitor' => DIRECTORY_SEPARATOR === '/',
|
||||||
|
]
|
||||||
|
]
|
||||||
|
]
|
||||||
|
];
|
||||||
22
config/redis.php
Normal file
22
config/redis.php
Normal file
@ -0,0 +1,22 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
'default' => [
|
||||||
|
'host' => '127.0.0.1',
|
||||||
|
'password' => null,
|
||||||
|
'port' => 6379,
|
||||||
|
'database' => 0,
|
||||||
|
],
|
||||||
|
];
|
||||||
21
config/route.php
Normal file
21
config/route.php
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
use Webman\Route;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
31
config/server.php
Normal file
31
config/server.php
Normal file
@ -0,0 +1,31 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
return [
|
||||||
|
'listen' => 'http://0.0.0.0:8787',
|
||||||
|
'transport' => 'tcp',
|
||||||
|
'context' => [],
|
||||||
|
'name' => 'webman',
|
||||||
|
'count' => cpu_count() * 4,
|
||||||
|
'user' => '',
|
||||||
|
'group' => '',
|
||||||
|
'reusePort' => false,
|
||||||
|
'event_loop' => '',
|
||||||
|
'stop_timeout' => 2,
|
||||||
|
'pid_file' => runtime_path() . '/webman.pid',
|
||||||
|
'status_file' => runtime_path() . '/webman.status',
|
||||||
|
'stdout_file' => runtime_path() . '/logs/stdout.log',
|
||||||
|
'log_file' => runtime_path() . '/logs/workerman.log',
|
||||||
|
'max_package_size' => 10 * 1024 * 1024
|
||||||
|
];
|
||||||
65
config/session.php
Normal file
65
config/session.php
Normal file
@ -0,0 +1,65 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
use Webman\Session\FileSessionHandler;
|
||||||
|
use Webman\Session\RedisSessionHandler;
|
||||||
|
use Webman\Session\RedisClusterSessionHandler;
|
||||||
|
|
||||||
|
return [
|
||||||
|
|
||||||
|
'type' => 'file', // or redis or redis_cluster
|
||||||
|
|
||||||
|
'handler' => FileSessionHandler::class,
|
||||||
|
|
||||||
|
'config' => [
|
||||||
|
'file' => [
|
||||||
|
'save_path' => runtime_path() . '/sessions',
|
||||||
|
],
|
||||||
|
'redis' => [
|
||||||
|
'host' => '127.0.0.1',
|
||||||
|
'port' => 6379,
|
||||||
|
'auth' => '',
|
||||||
|
'timeout' => 2,
|
||||||
|
'database' => '',
|
||||||
|
'prefix' => 'redis_session_',
|
||||||
|
],
|
||||||
|
'redis_cluster' => [
|
||||||
|
'host' => ['127.0.0.1:7000', '127.0.0.1:7001', '127.0.0.1:7001'],
|
||||||
|
'timeout' => 2,
|
||||||
|
'auth' => '',
|
||||||
|
'prefix' => 'redis_session_',
|
||||||
|
]
|
||||||
|
],
|
||||||
|
|
||||||
|
'session_name' => 'PHPSID',
|
||||||
|
|
||||||
|
'auto_update_timestamp' => false,
|
||||||
|
|
||||||
|
'lifetime' => 7*24*60*60,
|
||||||
|
|
||||||
|
'cookie_lifetime' => 365*24*60*60,
|
||||||
|
|
||||||
|
'cookie_path' => '/',
|
||||||
|
|
||||||
|
'domain' => '',
|
||||||
|
|
||||||
|
'http_only' => true,
|
||||||
|
|
||||||
|
'secure' => false,
|
||||||
|
|
||||||
|
'same_site' => '',
|
||||||
|
|
||||||
|
'gc_probability' => [1, 1000],
|
||||||
|
|
||||||
|
];
|
||||||
23
config/static.php
Normal file
23
config/static.php
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Static file settings
|
||||||
|
*/
|
||||||
|
return [
|
||||||
|
'enable' => true,
|
||||||
|
'middleware' => [ // Static file Middleware
|
||||||
|
//app\middleware\StaticFile::class,
|
||||||
|
],
|
||||||
|
];
|
||||||
25
config/translation.php
Normal file
25
config/translation.php
Normal file
@ -0,0 +1,25 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Multilingual configuration
|
||||||
|
*/
|
||||||
|
return [
|
||||||
|
// Default language
|
||||||
|
'locale' => 'zh_CN',
|
||||||
|
// Fallback language
|
||||||
|
'fallback_locale' => ['zh_CN', 'en'],
|
||||||
|
// Folder where language files are stored
|
||||||
|
'path' => base_path() . '/resource/translations',
|
||||||
|
];
|
||||||
22
config/view.php
Normal file
22
config/view.php
Normal file
@ -0,0 +1,22 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
use support\view\Raw;
|
||||||
|
use support\view\Twig;
|
||||||
|
use support\view\Blade;
|
||||||
|
use support\view\ThinkPHP;
|
||||||
|
|
||||||
|
return [
|
||||||
|
'handler' => Raw::class
|
||||||
|
];
|
||||||
243
process/Monitor.php
Normal file
243
process/Monitor.php
Normal file
@ -0,0 +1,243 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace process;
|
||||||
|
|
||||||
|
use FilesystemIterator;
|
||||||
|
use RecursiveDirectoryIterator;
|
||||||
|
use RecursiveIteratorIterator;
|
||||||
|
use SplFileInfo;
|
||||||
|
use Workerman\Timer;
|
||||||
|
use Workerman\Worker;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Class FileMonitor
|
||||||
|
* @package process
|
||||||
|
*/
|
||||||
|
class Monitor
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* @var array
|
||||||
|
*/
|
||||||
|
protected $paths = [];
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @var array
|
||||||
|
*/
|
||||||
|
protected $extensions = [];
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
public static $lockFile = __DIR__ . '/../runtime/monitor.lock';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Pause monitor
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public static function pause()
|
||||||
|
{
|
||||||
|
file_put_contents(static::$lockFile, time());
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Resume monitor
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public static function resume(): void
|
||||||
|
{
|
||||||
|
clearstatcache();
|
||||||
|
if (is_file(static::$lockFile)) {
|
||||||
|
unlink(static::$lockFile);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Whether monitor is paused
|
||||||
|
* @return bool
|
||||||
|
*/
|
||||||
|
public static function isPaused(): bool
|
||||||
|
{
|
||||||
|
clearstatcache();
|
||||||
|
return file_exists(static::$lockFile);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* FileMonitor constructor.
|
||||||
|
* @param $monitorDir
|
||||||
|
* @param $monitorExtensions
|
||||||
|
* @param array $options
|
||||||
|
*/
|
||||||
|
public function __construct($monitorDir, $monitorExtensions, array $options = [])
|
||||||
|
{
|
||||||
|
static::resume();
|
||||||
|
$this->paths = (array)$monitorDir;
|
||||||
|
$this->extensions = $monitorExtensions;
|
||||||
|
if (!Worker::getAllWorkers()) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
$disableFunctions = explode(',', ini_get('disable_functions'));
|
||||||
|
if (in_array('exec', $disableFunctions, true)) {
|
||||||
|
echo "\nMonitor file change turned off because exec() has been disabled by disable_functions setting in " . PHP_CONFIG_FILE_PATH . "/php.ini\n";
|
||||||
|
} else {
|
||||||
|
if ($options['enable_file_monitor'] ?? true) {
|
||||||
|
Timer::add(1, function () {
|
||||||
|
$this->checkAllFilesChange();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$memoryLimit = $this->getMemoryLimit($options['memory_limit'] ?? null);
|
||||||
|
if ($memoryLimit && ($options['enable_memory_monitor'] ?? true)) {
|
||||||
|
Timer::add(60, [$this, 'checkMemory'], [$memoryLimit]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param $monitorDir
|
||||||
|
* @return bool
|
||||||
|
*/
|
||||||
|
public function checkFilesChange($monitorDir): bool
|
||||||
|
{
|
||||||
|
static $lastMtime, $tooManyFilesCheck;
|
||||||
|
if (!$lastMtime) {
|
||||||
|
$lastMtime = time();
|
||||||
|
}
|
||||||
|
clearstatcache();
|
||||||
|
if (!is_dir($monitorDir)) {
|
||||||
|
if (!is_file($monitorDir)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
$iterator = [new SplFileInfo($monitorDir)];
|
||||||
|
} else {
|
||||||
|
// recursive traversal directory
|
||||||
|
$dirIterator = new RecursiveDirectoryIterator($monitorDir, FilesystemIterator::SKIP_DOTS | FilesystemIterator::FOLLOW_SYMLINKS);
|
||||||
|
$iterator = new RecursiveIteratorIterator($dirIterator);
|
||||||
|
}
|
||||||
|
$count = 0;
|
||||||
|
foreach ($iterator as $file) {
|
||||||
|
$count ++;
|
||||||
|
/** var SplFileInfo $file */
|
||||||
|
if (is_dir($file->getRealPath())) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
// check mtime
|
||||||
|
if (in_array($file->getExtension(), $this->extensions, true) && $lastMtime < $file->getMTime()) {
|
||||||
|
$var = 0;
|
||||||
|
exec('"'.PHP_BINARY . '" -l ' . $file, $out, $var);
|
||||||
|
$lastMtime = $file->getMTime();
|
||||||
|
if ($var) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
echo $file . " update and reload\n";
|
||||||
|
// send SIGUSR1 signal to master process for reload
|
||||||
|
if (DIRECTORY_SEPARATOR === '/') {
|
||||||
|
posix_kill(posix_getppid(), SIGUSR1);
|
||||||
|
} else {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (!$tooManyFilesCheck && $count > 1000) {
|
||||||
|
echo "Monitor: There are too many files ($count files) in $monitorDir which makes file monitoring very slow\n";
|
||||||
|
$tooManyFilesCheck = 1;
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return bool
|
||||||
|
*/
|
||||||
|
public function checkAllFilesChange(): bool
|
||||||
|
{
|
||||||
|
if (static::isPaused()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
foreach ($this->paths as $path) {
|
||||||
|
if ($this->checkFilesChange($path)) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param $memoryLimit
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function checkMemory($memoryLimit)
|
||||||
|
{
|
||||||
|
if (static::isPaused() || $memoryLimit <= 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
$ppid = posix_getppid();
|
||||||
|
$childrenFile = "/proc/$ppid/task/$ppid/children";
|
||||||
|
if (!is_file($childrenFile) || !($children = file_get_contents($childrenFile))) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
foreach (explode(' ', $children) as $pid) {
|
||||||
|
$pid = (int)$pid;
|
||||||
|
$statusFile = "/proc/$pid/status";
|
||||||
|
if (!is_file($statusFile) || !($status = file_get_contents($statusFile))) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
$mem = 0;
|
||||||
|
if (preg_match('/VmRSS\s*?:\s*?(\d+?)\s*?kB/', $status, $match)) {
|
||||||
|
$mem = $match[1];
|
||||||
|
}
|
||||||
|
$mem = (int)($mem / 1024);
|
||||||
|
if ($mem >= $memoryLimit) {
|
||||||
|
posix_kill($pid, SIGINT);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get memory limit
|
||||||
|
* @return float
|
||||||
|
*/
|
||||||
|
protected function getMemoryLimit($memoryLimit)
|
||||||
|
{
|
||||||
|
if ($memoryLimit === 0) {
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
$usePhpIni = false;
|
||||||
|
if (!$memoryLimit) {
|
||||||
|
$memoryLimit = ini_get('memory_limit');
|
||||||
|
$usePhpIni = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($memoryLimit == -1) {
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
$unit = strtolower($memoryLimit[strlen($memoryLimit) - 1]);
|
||||||
|
if ($unit === 'g') {
|
||||||
|
$memoryLimit = 1024 * (int)$memoryLimit;
|
||||||
|
} else if ($unit === 'm') {
|
||||||
|
$memoryLimit = (int)$memoryLimit;
|
||||||
|
} else if ($unit === 'k') {
|
||||||
|
$memoryLimit = ((int)$memoryLimit / 1024);
|
||||||
|
} else {
|
||||||
|
$memoryLimit = ((int)$memoryLimit / (1024 * 1024));
|
||||||
|
}
|
||||||
|
if ($memoryLimit < 30) {
|
||||||
|
$memoryLimit = 30;
|
||||||
|
}
|
||||||
|
if ($usePhpIni) {
|
||||||
|
$memoryLimit = (int)(0.8 * $memoryLimit);
|
||||||
|
}
|
||||||
|
return $memoryLimit;
|
||||||
|
}
|
||||||
|
}
|
||||||
12
public/404.html
Normal file
12
public/404.html
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
<html>
|
||||||
|
<head>
|
||||||
|
<title>404 Not Found - webman</title>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<center>
|
||||||
|
<h1>404 Not Found</h1>
|
||||||
|
</center>
|
||||||
|
<hr>
|
||||||
|
<center>webman</center>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
BIN
public/favicon.ico
Normal file
BIN
public/favicon.ico
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 4.2 KiB |
4
start.php
Executable file
4
start.php
Executable file
@ -0,0 +1,4 @@
|
|||||||
|
#!/usr/bin/env php
|
||||||
|
<?php
|
||||||
|
require_once __DIR__ . '/vendor/autoload.php';
|
||||||
|
support\App::run();
|
||||||
24
support/Request.php
Normal file
24
support/Request.php
Normal file
@ -0,0 +1,24 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace support;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Class Request
|
||||||
|
* @package support
|
||||||
|
*/
|
||||||
|
class Request extends \Webman\Http\Request
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
24
support/Response.php
Normal file
24
support/Response.php
Normal file
@ -0,0 +1,24 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
namespace support;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Class Response
|
||||||
|
* @package support
|
||||||
|
*/
|
||||||
|
class Response extends \Webman\Http\Response
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
133
support/bootstrap.php
Normal file
133
support/bootstrap.php
Normal file
@ -0,0 +1,133 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
use Dotenv\Dotenv;
|
||||||
|
use support\Log;
|
||||||
|
use Webman\Bootstrap;
|
||||||
|
use Webman\Config;
|
||||||
|
use Webman\Middleware;
|
||||||
|
use Webman\Route;
|
||||||
|
use Webman\Util;
|
||||||
|
|
||||||
|
$worker = $worker ?? null;
|
||||||
|
|
||||||
|
set_error_handler(function ($level, $message, $file = '', $line = 0) {
|
||||||
|
if (error_reporting() & $level) {
|
||||||
|
throw new ErrorException($message, 0, $level, $file, $line);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
if ($worker) {
|
||||||
|
register_shutdown_function(function ($startTime) {
|
||||||
|
if (time() - $startTime <= 0.1) {
|
||||||
|
sleep(1);
|
||||||
|
}
|
||||||
|
}, time());
|
||||||
|
}
|
||||||
|
|
||||||
|
if (class_exists('Dotenv\Dotenv') && file_exists(base_path(false) . '/.env')) {
|
||||||
|
if (method_exists('Dotenv\Dotenv', 'createUnsafeMutable')) {
|
||||||
|
Dotenv::createUnsafeMutable(base_path(false))->load();
|
||||||
|
} else {
|
||||||
|
Dotenv::createMutable(base_path(false))->load();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Config::clear();
|
||||||
|
support\App::loadAllConfig(['route']);
|
||||||
|
if ($timezone = config('app.default_timezone')) {
|
||||||
|
date_default_timezone_set($timezone);
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach (config('autoload.files', []) as $file) {
|
||||||
|
include_once $file;
|
||||||
|
}
|
||||||
|
foreach (config('plugin', []) as $firm => $projects) {
|
||||||
|
foreach ($projects as $name => $project) {
|
||||||
|
if (!is_array($project)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
foreach ($project['autoload']['files'] ?? [] as $file) {
|
||||||
|
include_once $file;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
foreach ($projects['autoload']['files'] ?? [] as $file) {
|
||||||
|
include_once $file;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Middleware::load(config('middleware', []));
|
||||||
|
foreach (config('plugin', []) as $firm => $projects) {
|
||||||
|
foreach ($projects as $name => $project) {
|
||||||
|
if (!is_array($project) || $name === 'static') {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
Middleware::load($project['middleware'] ?? []);
|
||||||
|
}
|
||||||
|
Middleware::load($projects['middleware'] ?? [], $firm);
|
||||||
|
if ($staticMiddlewares = config("plugin.$firm.static.middleware")) {
|
||||||
|
Middleware::load(['__static__' => $staticMiddlewares], $firm);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Middleware::load(['__static__' => config('static.middleware', [])]);
|
||||||
|
|
||||||
|
foreach (config('bootstrap', []) as $className) {
|
||||||
|
if (!class_exists($className)) {
|
||||||
|
$log = "Warning: Class $className setting in config/bootstrap.php not found\r\n";
|
||||||
|
echo $log;
|
||||||
|
Log::error($log);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
/** @var Bootstrap $className */
|
||||||
|
$className::start($worker);
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach (config('plugin', []) as $firm => $projects) {
|
||||||
|
foreach ($projects as $name => $project) {
|
||||||
|
if (!is_array($project)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
foreach ($project['bootstrap'] ?? [] as $className) {
|
||||||
|
if (!class_exists($className)) {
|
||||||
|
$log = "Warning: Class $className setting in config/plugin/$firm/$name/bootstrap.php not found\r\n";
|
||||||
|
echo $log;
|
||||||
|
Log::error($log);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
/** @var Bootstrap $className */
|
||||||
|
$className::start($worker);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
foreach ($projects['bootstrap'] ?? [] as $className) {
|
||||||
|
/** @var string $className */
|
||||||
|
if (!class_exists($className)) {
|
||||||
|
$log = "Warning: Class $className setting in plugin/$firm/config/bootstrap.php not found\r\n";
|
||||||
|
echo $log;
|
||||||
|
Log::error($log);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
/** @var Bootstrap $className */
|
||||||
|
$className::start($worker);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$directory = base_path() . '/plugin';
|
||||||
|
$paths = [config_path()];
|
||||||
|
foreach (Util::scanDir($directory) as $path) {
|
||||||
|
if (is_dir($path = "$path/config")) {
|
||||||
|
$paths[] = $path;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Route::load($paths);
|
||||||
|
|
||||||
528
support/helpers.php
Normal file
528
support/helpers.php
Normal file
@ -0,0 +1,528 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This file is part of webman.
|
||||||
|
*
|
||||||
|
* Licensed under The MIT License
|
||||||
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||||||
|
* Redistributions of files must retain the above copyright notice.
|
||||||
|
*
|
||||||
|
* @author walkor<walkor@workerman.net>
|
||||||
|
* @copyright walkor<walkor@workerman.net>
|
||||||
|
* @link http://www.workerman.net/
|
||||||
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||||||
|
*/
|
||||||
|
|
||||||
|
use support\Container;
|
||||||
|
use support\Request;
|
||||||
|
use support\Response;
|
||||||
|
use support\Translation;
|
||||||
|
use support\view\Blade;
|
||||||
|
use support\view\Raw;
|
||||||
|
use support\view\ThinkPHP;
|
||||||
|
use support\view\Twig;
|
||||||
|
use Twig\Error\LoaderError;
|
||||||
|
use Twig\Error\RuntimeError;
|
||||||
|
use Twig\Error\SyntaxError;
|
||||||
|
use Webman\App;
|
||||||
|
use Webman\Config;
|
||||||
|
use Webman\Route;
|
||||||
|
use Workerman\Protocols\Http\Session;
|
||||||
|
use Workerman\Worker;
|
||||||
|
|
||||||
|
// Project base path
|
||||||
|
define('BASE_PATH', dirname(__DIR__));
|
||||||
|
|
||||||
|
/**
|
||||||
|
* return the program execute directory
|
||||||
|
* @param string $path
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function run_path(string $path = ''): string
|
||||||
|
{
|
||||||
|
static $runPath = '';
|
||||||
|
if (!$runPath) {
|
||||||
|
$runPath = is_phar() ? dirname(Phar::running(false)) : BASE_PATH;
|
||||||
|
}
|
||||||
|
return path_combine($runPath, $path);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* if the param $path equal false,will return this program current execute directory
|
||||||
|
* @param string|false $path
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function base_path($path = ''): string
|
||||||
|
{
|
||||||
|
if (false === $path) {
|
||||||
|
return run_path();
|
||||||
|
}
|
||||||
|
return path_combine(BASE_PATH, $path);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* App path
|
||||||
|
* @param string $path
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function app_path(string $path = ''): string
|
||||||
|
{
|
||||||
|
return path_combine(BASE_PATH . DIRECTORY_SEPARATOR . 'app', $path);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Public path
|
||||||
|
* @param string $path
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function public_path(string $path = ''): string
|
||||||
|
{
|
||||||
|
static $publicPath = '';
|
||||||
|
if (!$publicPath) {
|
||||||
|
$publicPath = \config('app.public_path') ?: run_path('public');
|
||||||
|
}
|
||||||
|
return path_combine($publicPath, $path);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Config path
|
||||||
|
* @param string $path
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function config_path(string $path = ''): string
|
||||||
|
{
|
||||||
|
return path_combine(BASE_PATH . DIRECTORY_SEPARATOR . 'config', $path);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Runtime path
|
||||||
|
* @param string $path
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function runtime_path(string $path = ''): string
|
||||||
|
{
|
||||||
|
static $runtimePath = '';
|
||||||
|
if (!$runtimePath) {
|
||||||
|
$runtimePath = \config('app.runtime_path') ?: run_path('runtime');
|
||||||
|
}
|
||||||
|
return path_combine($runtimePath, $path);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Generate paths based on given information
|
||||||
|
* @param string $front
|
||||||
|
* @param string $back
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function path_combine(string $front, string $back): string
|
||||||
|
{
|
||||||
|
return $front . ($back ? (DIRECTORY_SEPARATOR . ltrim($back, DIRECTORY_SEPARATOR)) : $back);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Response
|
||||||
|
* @param int $status
|
||||||
|
* @param array $headers
|
||||||
|
* @param string $body
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function response(string $body = '', int $status = 200, array $headers = []): Response
|
||||||
|
{
|
||||||
|
return new Response($status, $headers, $body);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Json response
|
||||||
|
* @param $data
|
||||||
|
* @param int $options
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function json($data, int $options = JSON_UNESCAPED_UNICODE): Response
|
||||||
|
{
|
||||||
|
return new Response(200, ['Content-Type' => 'application/json'], json_encode($data, $options));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Xml response
|
||||||
|
* @param $xml
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function xml($xml): Response
|
||||||
|
{
|
||||||
|
if ($xml instanceof SimpleXMLElement) {
|
||||||
|
$xml = $xml->asXML();
|
||||||
|
}
|
||||||
|
return new Response(200, ['Content-Type' => 'text/xml'], $xml);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Jsonp response
|
||||||
|
* @param $data
|
||||||
|
* @param string $callbackName
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function jsonp($data, string $callbackName = 'callback'): Response
|
||||||
|
{
|
||||||
|
if (!is_scalar($data) && null !== $data) {
|
||||||
|
$data = json_encode($data);
|
||||||
|
}
|
||||||
|
return new Response(200, [], "$callbackName($data)");
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Redirect response
|
||||||
|
* @param string $location
|
||||||
|
* @param int $status
|
||||||
|
* @param array $headers
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function redirect(string $location, int $status = 302, array $headers = []): Response
|
||||||
|
{
|
||||||
|
$response = new Response($status, ['Location' => $location]);
|
||||||
|
if (!empty($headers)) {
|
||||||
|
$response->withHeaders($headers);
|
||||||
|
}
|
||||||
|
return $response;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* View response
|
||||||
|
* @param string $template
|
||||||
|
* @param array $vars
|
||||||
|
* @param string|null $app
|
||||||
|
* @param string|null $plugin
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function view(string $template, array $vars = [], string $app = null, string $plugin = null): Response
|
||||||
|
{
|
||||||
|
$request = \request();
|
||||||
|
$plugin = $plugin === null ? ($request->plugin ?? '') : $plugin;
|
||||||
|
$handler = \config($plugin ? "plugin.$plugin.view.handler" : 'view.handler');
|
||||||
|
return new Response(200, [], $handler::render($template, $vars, $app, $plugin));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Raw view response
|
||||||
|
* @param string $template
|
||||||
|
* @param array $vars
|
||||||
|
* @param string|null $app
|
||||||
|
* @return Response
|
||||||
|
* @throws Throwable
|
||||||
|
*/
|
||||||
|
function raw_view(string $template, array $vars = [], string $app = null): Response
|
||||||
|
{
|
||||||
|
return new Response(200, [], Raw::render($template, $vars, $app));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Blade view response
|
||||||
|
* @param string $template
|
||||||
|
* @param array $vars
|
||||||
|
* @param string|null $app
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function blade_view(string $template, array $vars = [], string $app = null): Response
|
||||||
|
{
|
||||||
|
return new Response(200, [], Blade::render($template, $vars, $app));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Think view response
|
||||||
|
* @param string $template
|
||||||
|
* @param array $vars
|
||||||
|
* @param string|null $app
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function think_view(string $template, array $vars = [], string $app = null): Response
|
||||||
|
{
|
||||||
|
return new Response(200, [], ThinkPHP::render($template, $vars, $app));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Twig view response
|
||||||
|
* @param string $template
|
||||||
|
* @param array $vars
|
||||||
|
* @param string|null $app
|
||||||
|
* @return Response
|
||||||
|
* @throws LoaderError
|
||||||
|
* @throws RuntimeError
|
||||||
|
* @throws SyntaxError
|
||||||
|
*/
|
||||||
|
function twig_view(string $template, array $vars = [], string $app = null): Response
|
||||||
|
{
|
||||||
|
return new Response(200, [], Twig::render($template, $vars, $app));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get request
|
||||||
|
* @return \Webman\Http\Request|Request|null
|
||||||
|
*/
|
||||||
|
function request()
|
||||||
|
{
|
||||||
|
return App::request();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get config
|
||||||
|
* @param string|null $key
|
||||||
|
* @param $default
|
||||||
|
* @return array|mixed|null
|
||||||
|
*/
|
||||||
|
function config(string $key = null, $default = null)
|
||||||
|
{
|
||||||
|
return Config::get($key, $default);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Create url
|
||||||
|
* @param string $name
|
||||||
|
* @param ...$parameters
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function route(string $name, ...$parameters): string
|
||||||
|
{
|
||||||
|
$route = Route::getByName($name);
|
||||||
|
if (!$route) {
|
||||||
|
return '';
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!$parameters) {
|
||||||
|
return $route->url();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (is_array(current($parameters))) {
|
||||||
|
$parameters = current($parameters);
|
||||||
|
}
|
||||||
|
|
||||||
|
return $route->url($parameters);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Session
|
||||||
|
* @param mixed $key
|
||||||
|
* @param mixed $default
|
||||||
|
* @return mixed|bool|Session
|
||||||
|
*/
|
||||||
|
function session($key = null, $default = null)
|
||||||
|
{
|
||||||
|
$session = \request()->session();
|
||||||
|
if (null === $key) {
|
||||||
|
return $session;
|
||||||
|
}
|
||||||
|
if (is_array($key)) {
|
||||||
|
$session->put($key);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
if (strpos($key, '.')) {
|
||||||
|
$keyArray = explode('.', $key);
|
||||||
|
$value = $session->all();
|
||||||
|
foreach ($keyArray as $index) {
|
||||||
|
if (!isset($value[$index])) {
|
||||||
|
return $default;
|
||||||
|
}
|
||||||
|
$value = $value[$index];
|
||||||
|
}
|
||||||
|
return $value;
|
||||||
|
}
|
||||||
|
return $session->get($key, $default);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Translation
|
||||||
|
* @param string $id
|
||||||
|
* @param array $parameters
|
||||||
|
* @param string|null $domain
|
||||||
|
* @param string|null $locale
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function trans(string $id, array $parameters = [], string $domain = null, string $locale = null): string
|
||||||
|
{
|
||||||
|
$res = Translation::trans($id, $parameters, $domain, $locale);
|
||||||
|
return $res === '' ? $id : $res;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Locale
|
||||||
|
* @param string|null $locale
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function locale(string $locale = null): string
|
||||||
|
{
|
||||||
|
if (!$locale) {
|
||||||
|
return Translation::getLocale();
|
||||||
|
}
|
||||||
|
Translation::setLocale($locale);
|
||||||
|
return $locale;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 404 not found
|
||||||
|
* @return Response
|
||||||
|
*/
|
||||||
|
function not_found(): Response
|
||||||
|
{
|
||||||
|
return new Response(404, [], file_get_contents(public_path() . '/404.html'));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Copy dir
|
||||||
|
* @param string $source
|
||||||
|
* @param string $dest
|
||||||
|
* @param bool $overwrite
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
function copy_dir(string $source, string $dest, bool $overwrite = false)
|
||||||
|
{
|
||||||
|
if (is_dir($source)) {
|
||||||
|
if (!is_dir($dest)) {
|
||||||
|
mkdir($dest);
|
||||||
|
}
|
||||||
|
$files = scandir($source);
|
||||||
|
foreach ($files as $file) {
|
||||||
|
if ($file !== "." && $file !== "..") {
|
||||||
|
copy_dir("$source/$file", "$dest/$file", $overwrite);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else if (file_exists($source) && ($overwrite || !file_exists($dest))) {
|
||||||
|
copy($source, $dest);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Remove dir
|
||||||
|
* @param string $dir
|
||||||
|
* @return bool
|
||||||
|
*/
|
||||||
|
function remove_dir(string $dir): bool
|
||||||
|
{
|
||||||
|
if (is_link($dir) || is_file($dir)) {
|
||||||
|
return unlink($dir);
|
||||||
|
}
|
||||||
|
$files = array_diff(scandir($dir), array('.', '..'));
|
||||||
|
foreach ($files as $file) {
|
||||||
|
(is_dir("$dir/$file") && !is_link($dir)) ? remove_dir("$dir/$file") : unlink("$dir/$file");
|
||||||
|
}
|
||||||
|
return rmdir($dir);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Bind worker
|
||||||
|
* @param $worker
|
||||||
|
* @param $class
|
||||||
|
*/
|
||||||
|
function worker_bind($worker, $class)
|
||||||
|
{
|
||||||
|
$callbackMap = [
|
||||||
|
'onConnect',
|
||||||
|
'onMessage',
|
||||||
|
'onClose',
|
||||||
|
'onError',
|
||||||
|
'onBufferFull',
|
||||||
|
'onBufferDrain',
|
||||||
|
'onWorkerStop',
|
||||||
|
'onWebSocketConnect',
|
||||||
|
'onWorkerReload'
|
||||||
|
];
|
||||||
|
foreach ($callbackMap as $name) {
|
||||||
|
if (method_exists($class, $name)) {
|
||||||
|
$worker->$name = [$class, $name];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (method_exists($class, 'onWorkerStart')) {
|
||||||
|
call_user_func([$class, 'onWorkerStart'], $worker);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Start worker
|
||||||
|
* @param $processName
|
||||||
|
* @param $config
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
function worker_start($processName, $config)
|
||||||
|
{
|
||||||
|
$worker = new Worker($config['listen'] ?? null, $config['context'] ?? []);
|
||||||
|
$propertyMap = [
|
||||||
|
'count',
|
||||||
|
'user',
|
||||||
|
'group',
|
||||||
|
'reloadable',
|
||||||
|
'reusePort',
|
||||||
|
'transport',
|
||||||
|
'protocol',
|
||||||
|
];
|
||||||
|
$worker->name = $processName;
|
||||||
|
foreach ($propertyMap as $property) {
|
||||||
|
if (isset($config[$property])) {
|
||||||
|
$worker->$property = $config[$property];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$worker->onWorkerStart = function ($worker) use ($config) {
|
||||||
|
require_once base_path('/support/bootstrap.php');
|
||||||
|
if (isset($config['handler'])) {
|
||||||
|
if (!class_exists($config['handler'])) {
|
||||||
|
echo "process error: class {$config['handler']} not exists\r\n";
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$instance = Container::make($config['handler'], $config['constructor'] ?? []);
|
||||||
|
worker_bind($worker, $instance);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get realpath
|
||||||
|
* @param string $filePath
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
function get_realpath(string $filePath): string
|
||||||
|
{
|
||||||
|
if (strpos($filePath, 'phar://') === 0) {
|
||||||
|
return $filePath;
|
||||||
|
} else {
|
||||||
|
return realpath($filePath);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Is phar
|
||||||
|
* @return bool
|
||||||
|
*/
|
||||||
|
function is_phar(): bool
|
||||||
|
{
|
||||||
|
return class_exists(Phar::class, false) && Phar::running();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get cpu count
|
||||||
|
* @return int
|
||||||
|
*/
|
||||||
|
function cpu_count(): int
|
||||||
|
{
|
||||||
|
// Windows does not support the number of processes setting.
|
||||||
|
if (DIRECTORY_SEPARATOR === '\\') {
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
$count = 4;
|
||||||
|
if (is_callable('shell_exec')) {
|
||||||
|
if (strtolower(PHP_OS) === 'darwin') {
|
||||||
|
$count = (int)shell_exec('sysctl -n machdep.cpu.core_count');
|
||||||
|
} else {
|
||||||
|
$count = (int)shell_exec('nproc');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return $count > 0 ? $count : 4;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get request parameters, if no parameter name is passed, an array of all values is returned, default values is supported
|
||||||
|
* @param string|null $param param's name
|
||||||
|
* @param mixed|null $default default value
|
||||||
|
* @return mixed|null
|
||||||
|
*/
|
||||||
|
function input(string $param = null, $default = null)
|
||||||
|
{
|
||||||
|
return is_null($param) ? request()->all() : request()->input($param, $default);
|
||||||
|
}
|
||||||
3
windows.bat
Normal file
3
windows.bat
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
CHCP 65001
|
||||||
|
php windows.php
|
||||||
|
pause
|
||||||
118
windows.php
Normal file
118
windows.php
Normal file
@ -0,0 +1,118 @@
|
|||||||
|
<?php
|
||||||
|
/**
|
||||||
|
* Start file for windows
|
||||||
|
*/
|
||||||
|
require_once __DIR__ . '/vendor/autoload.php';
|
||||||
|
|
||||||
|
use Dotenv\Dotenv;
|
||||||
|
use process\Monitor;
|
||||||
|
use support\App;
|
||||||
|
use Workerman\Worker;
|
||||||
|
|
||||||
|
ini_set('display_errors', 'on');
|
||||||
|
error_reporting(E_ALL);
|
||||||
|
|
||||||
|
if (class_exists('Dotenv\Dotenv') && file_exists(base_path() . '/.env')) {
|
||||||
|
if (method_exists('Dotenv\Dotenv', 'createUnsafeImmutable')) {
|
||||||
|
Dotenv::createUnsafeImmutable(base_path())->load();
|
||||||
|
} else {
|
||||||
|
Dotenv::createMutable(base_path())->load();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
App::loadAllConfig(['route']);
|
||||||
|
|
||||||
|
$errorReporting = config('app.error_reporting');
|
||||||
|
if (isset($errorReporting)) {
|
||||||
|
error_reporting($errorReporting);
|
||||||
|
}
|
||||||
|
|
||||||
|
$runtimeProcessPath = runtime_path() . DIRECTORY_SEPARATOR . '/windows';
|
||||||
|
if (!is_dir($runtimeProcessPath)) {
|
||||||
|
mkdir($runtimeProcessPath);
|
||||||
|
}
|
||||||
|
$processFiles = [
|
||||||
|
__DIR__ . DIRECTORY_SEPARATOR . 'start.php'
|
||||||
|
];
|
||||||
|
foreach (config('process', []) as $processName => $config) {
|
||||||
|
$processFiles[] = write_process_file($runtimeProcessPath, $processName, '');
|
||||||
|
}
|
||||||
|
|
||||||
|
foreach (config('plugin', []) as $firm => $projects) {
|
||||||
|
foreach ($projects as $name => $project) {
|
||||||
|
if (!is_array($project)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
foreach ($project['process'] ?? [] as $processName => $config) {
|
||||||
|
$processFiles[] = write_process_file($runtimeProcessPath, $processName, "$firm.$name");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
foreach ($projects['process'] ?? [] as $processName => $config) {
|
||||||
|
$processFiles[] = write_process_file($runtimeProcessPath, $processName, $firm);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function write_process_file($runtimeProcessPath, $processName, $firm): string
|
||||||
|
{
|
||||||
|
$processParam = $firm ? "plugin.$firm.$processName" : $processName;
|
||||||
|
$configParam = $firm ? "config('plugin.$firm.process')['$processName']" : "config('process')['$processName']";
|
||||||
|
$fileContent = <<<EOF
|
||||||
|
<?php
|
||||||
|
require_once __DIR__ . '/../../vendor/autoload.php';
|
||||||
|
|
||||||
|
use Workerman\Worker;
|
||||||
|
use Workerman\Connection\TcpConnection;
|
||||||
|
use Webman\Config;
|
||||||
|
use support\App;
|
||||||
|
|
||||||
|
ini_set('display_errors', 'on');
|
||||||
|
error_reporting(E_ALL);
|
||||||
|
|
||||||
|
if (is_callable('opcache_reset')) {
|
||||||
|
opcache_reset();
|
||||||
|
}
|
||||||
|
|
||||||
|
App::loadAllConfig(['route']);
|
||||||
|
|
||||||
|
worker_start('$processParam', $configParam);
|
||||||
|
|
||||||
|
if (DIRECTORY_SEPARATOR != "/") {
|
||||||
|
Worker::\$logFile = config('server')['log_file'] ?? Worker::\$logFile;
|
||||||
|
TcpConnection::\$defaultMaxPackageSize = config('server')['max_package_size'] ?? 10*1024*1024;
|
||||||
|
}
|
||||||
|
|
||||||
|
Worker::runAll();
|
||||||
|
|
||||||
|
EOF;
|
||||||
|
$processFile = $runtimeProcessPath . DIRECTORY_SEPARATOR . "start_$processParam.php";
|
||||||
|
file_put_contents($processFile, $fileContent);
|
||||||
|
return $processFile;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($monitorConfig = config('process.monitor.constructor')) {
|
||||||
|
$monitor = new Monitor(...array_values($monitorConfig));
|
||||||
|
}
|
||||||
|
|
||||||
|
function popen_processes($processFiles)
|
||||||
|
{
|
||||||
|
$cmd = '"' . PHP_BINARY . '" ' . implode(' ', $processFiles);
|
||||||
|
$descriptorspec = [STDIN, STDOUT, STDOUT];
|
||||||
|
$resource = proc_open($cmd, $descriptorspec, $pipes, null, null, ['bypass_shell' => true]);
|
||||||
|
if (!$resource) {
|
||||||
|
exit("Can not execute $cmd\r\n");
|
||||||
|
}
|
||||||
|
return $resource;
|
||||||
|
}
|
||||||
|
|
||||||
|
$resource = popen_processes($processFiles);
|
||||||
|
echo "\r\n";
|
||||||
|
while (1) {
|
||||||
|
sleep(1);
|
||||||
|
if (!empty($monitor) && $monitor->checkAllFilesChange()) {
|
||||||
|
$status = proc_get_status($resource);
|
||||||
|
$pid = $status['pid'];
|
||||||
|
shell_exec("taskkill /F /T /PID $pid");
|
||||||
|
proc_close($resource);
|
||||||
|
$resource = popen_processes($processFiles);
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue
Block a user