thinkPHP6接入workman-Toy模板网

这篇具有很好参考价值的文章主要介绍了thinkPHP6接入workman。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

上篇介绍了workman实现websocket功能（链接：https://blog.csdn.net/weixin_38155824/article/details/128952037）
后传：解决workman部署到Linux环境无法启动和连接的问题（https://blog.csdn.net/weixin_38155824/article/details/129004050）
这篇就介绍如何在thinkPHP6项目中接入workman。

利用TP6的自定义命令开启websocket服务

查看TP6手册：命令行=>自定义命令

第一步，执行以下命令，就会会生成一个app\command\Chat命令行指令类.

php think make:command Chat startChat

第二步，配置config/console.php文件

<?php
return [
    'commands' => [
        'chat' => 'app\command\Chat',
    ]
];

第三步，测试-命令帮助-命令行下运行

php think

输出
thinkPHP6接入workman,websocket,thinkPHP,PHP,php,websocket,开发语言
执行

php think chat

自定义命令搞定后，就可以引入workman了

在项目根目录下通过comoser安装workman：

composer require workerman/workerman

然后将上一篇的workman开启wetsocket服务的代码复制到新创建的自定义命令类Chat.php中

（划重点：要引入vendor目录下的autoload.php，路径要写对）
（划重点：要引入vendor目录下的autoload.php，路径要写对）
（划重点：要引入vendor目录下的autoload.php，路径要写对）

<?php
declare (strict_types = 1);

namespace app\command;

use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require __DIR__ . '/../../vendor/autoload.php';


class Chat extends Command
{

    protected function configure()
    {
        // 指令配置
        $this->setName('startChat')
            ->setDescription('the startChat command');
    }

    protected function execute(Input $input, Output $output)
    {
        // 指令输出
        $output->writeln('startChat');
        //启动workman-websocket服务
        // 注意：这里与上个例子不同，使用的是websocket协议
        $ws_worker = new Worker("websocket://0.0.0.0:2000");

        // 启动4个进程对外提供服务
        $ws_worker->count = 4;

        // 当收到客户端发来的数据后返回hello $data给客户端
        $ws_worker->onMessage = function(TcpConnection $connection, $data)
        {
            //在控制台打印客户端发送过来的消息
            var_dump($data);
            var_export($data);

            // 向客户端发送hello $data
            $connection->send('hello ' . $data);
        };

        // 运行worker
        Worker::runAll();

    }
}