在自定義進程使用swoole協(xié)程
二進制打包 啟動報錯亂碼
/app/config/process.php
<?php
return [
'task' => [
'handler' => app\process\Task::class,
'reloadable' => false,
'eventLoop' => Workerman\Events\Swoole::class,
],
]
/app/process/Task.php
<?php
namespace app\process;
class Task
{
public function onWorkerStart()
{
// 每1分鐘執(zhí)行一次
new Crontab('0 */1 * * * *', function () {
$parallel = new Parallel();
for ($i=1; $i<5; $i++) {
$parallel->add(function () use ($i) {
// Do something
return $i;
});
}
$results = $parallel->wait();
}
}
}
v????|?Q??*?t??%?F0??LFb????4?8?LxR?uNHz??????o$?`~??I??*?f?)??r???2????~?<`?L)?H0H3?)(!?"???A??D9A
??9[?h??#??H3?UD
????r2??T?`
?U??p/L???d?X?1I?.?B???l?L1?I??nM2???0?bl??:N?[??MS?????B O A??[?1????
9???'@H????A??g?F?>=??D(?r??I??L)?d*?I1?'9H1(???H??H??!?|@??A??X?|I??4???b?'??Mc?'?N??3W??????n??"??@;??]?T?YG
?h3?r6?2?4?????PK??TA?? ~?????[? ?<??
?L????T
oy?-n5+????,n????0???`?Э^????i??B???R(??Z????A????
?[zp??0??????#??
L??u?????? D?X?
??K?[???[?Q?tZ?@nY?k??3-??????g"???oe?????&??| ????o%+Sw@????si??$?1? G3M7?? ?`q_L ?!s?h?//e?{`?@b?lu?=???W??Bp??.???|6?*Ay@p?l ?O?D???UP?I??`a?s3mp?$
?^CWorkerman[queue.bin] received signal SIGINT
Workerman[queue.bin] stopping
ParseError: syntax error, unexpected character 0x05 in phar:///data/queue/queue.bin/app/process/Task.php:20
Stack trace:
#0 phar:///data/queue/queue.bin/vendor/composer/ClassLoader.php(432): Composer\Autoload\ClassLoader::Composer\Autoload\{closure}('phar:///data/qu...')
#1 [internal function]: Composer\Autoload\ClassLoader->loadClass('app\\process\\Tas...')
#2 phar:///data/queue/queue.bin/vendor/workerman/webman-framework/src/support/helpers.php(552): class_exists('app\\process\\Tas...')
#3 phar:///data/queue/queue.bin/vendor/workerman/workerman/src/Worker.php(2566): {closure}(Object(Workerman\Worker))
#4 [internal function]: Workerman\Worker->Workerman\{closure}()
#5 {main}
Workerman[queue.bin] has been stopped