美文网首页
Laravel 5.4 结合 Workerman

Laravel 5.4 结合 Workerman

作者: 雨夜飞逃 | 来源:发表于2018-01-20 15:34 被阅读628次

一、安装 workerman

在项目根目录执行

composerrequireworkerman/workerman

二、创建自定义 artisan 命令来启动 workerman 服务

由于 laravel 不能直接在根目录下执行php命令,所以需要创建artisan命令用于后面 workerman 服务的开启。

1,生成 WorkermanCommand 文件

php artisan make:commandWorkermanCommand

执行以上命令行会在 app/Console/Commands/ 目录下生成 WorkermanCommand.php 文件。

argument('action');        $argv[1] = $argv[2];        $argv[2] =isset($argv[3]) ?"-{$argv[3]}":'';switch($arg) {case'start':$this->start();break;case'stop':break;case'restart':break;case'reload':break;case'status':break;case'connections':break;        }    }privatefunctionstart(){// 创建一个Worker监听20002端口,不使用任何应用层协议$this->server =newWorker("tcp://0.0.0.0:20002");// 启动4个进程对外提供服务$this->server->count =4;        $handler = \App::make('handlers\WorkermanHandler');// 连接时回调$this->server->onConnect = [$handler,'onConnect'];// 收到客户端信息时回调$this->server->onMessage = [$handler,'onMessage'];// 进程启动后的回调$this->server->onWorkerStart = [$handler,'onWorkerStart'];// 断开时触发的回调$this->server->onClose = [$handler,'onClose'];// 运行workerWorker::runAll();    }}

我只实现了start命令,其他命令童鞋们自行实现吧。

这里使用了 PHP 类方法的回调。(PHP几种回调写法

这里我们创建了一个自定义命令wk [action],通过此命令即可开启 workerman 服务。

在这个自定义命令还引用了其他的类文件,如:

$handler = \App::make('handlers\WorkermanHandler');

所以,需要创建一个WorkermanHandler.php的文件来处理对应的操作。

2,创建 WorkermanHandler.php

创建文件app/handlers/WorkermanHandler.php

getRemoteIp() ."\n";    }// 处理客户端消息publicfunctiononMessage($connection, $data){// 向客户端发送hello $data$connection->send('Hello, your send message is: '. $data);    }// 处理客户端断开publicfunctiononClose($connection){echo"connection closed from ip {$connection->getRemoteIp()}\n";    }publicfunctiononWorkerStart($worker){        Timer::add(1,function()use($worker){            $time_now = time();foreach($worker->connectionsas$connection) {// 有可能该connection还没收到过消息,则lastMessageTime设置为当前时间if(empty($connection->lastMessageTime)) {                    $connection->lastMessageTime = $time_now;continue;                }// 上次通讯时间间隔大于心跳间隔,则认为客户端已经下线,关闭连接if($time_now - $connection->lastMessageTime > HEARTBEAT_TIME) {echo"Client ip {$connection->getRemoteIp()} timeout!!!\n";                    $connection->close();                }            }        });    }}

3,修改composer.json文件,让app/Protocols文件夹下的类文件自动加载。

"autoload": {"classmap": [        ..."app/Protocols"],    ...},

至此。workman的命令定义已经完成。

使用:

php artisan wk start

如果看到以下内容,说明 workerman 服务启动正常:

Workerman[artisan] startinDEBUG mode----------------------- WORKERMAN -----------------------------Workerman version:3.5.4PHP version:7.1.4------------------------ WORKERS -------------------------------user          worker        listen                  processes statusroot          none          tcp://0.0.0.0:20002  1        [OK] ----------------------------------------------------------------Press Ctrl+C to quit. Start success.

帮助文档:

心跳包

如何与其它框架整合

利用WorkerMan给客户端推送数据

作者:Stone0070

链接:https://www.jianshu.com/p/00623acb3dad

來源:简书

著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

相关文章

网友评论

      本文标题:Laravel 5.4 结合 Workerman

      本文链接:https://www.haomeiwen.com/subject/ssrwixtx.html