TP6 workerman 执行 php think worker 出错

浏览:1651 发布日期:2020/03/05 分类:ThinkPHP6专区 关键字: TP6 workerman
composer安装完成官方文档教学的workerman,在启动的时候出现了下面的错误,两个启动命令都尝试了,没用。PHP Parse error:  syntax error, unexpected '=' in /www/wwwroot/huiyun.liudiaoxiaochengxu.changtuchacha.com/vendor/topthink/framework/src/think/Container.php on line 306然后直接下载了workerman的官方包,现在已经启动成功了,在根目录新建了一个worker.php的文件
两个疑问:
1. 为什么会出现上面的错误呢
2. 怎么在根目录的worker.php使用TPLog/Db等方法,PS:我引用了之后使用没有反应,下面是我的worker.php的代码<?php

use think\App;
use Workerman\Worker;
require_once __DIR__ .'/public/workerman/Autoloader.php';

$context = [
    'ssl'=>[
        // 请使用绝对路径
        'local_cert'                 => '/www/server/panel/vhost/ssl/huiyun.liudiaoxiaochengxu.changtuchacha.com/fullchain.pem', // 也可以是crt文件
        'local_pk'                   => '/www/server/panel/vhost/ssl/huiyun.liudiaoxiaochengxu.changtuchacha.com/privkey.pem',
        'verify_peer'                => false,
        // 'allow_self_signed' => true, //如果是自签名证书需要开启此选项
    ],
];

$worker = new Worker('websocket://0.0.0.0:19463', $context);
$worker->count = 1;
$worker->transport = 'ssl';
$worker->uidConnections = array();
$worker->onMessage = function($connection, $data)
{
    global $worker;
    $data = json_decode($data,true);
    \think\facade\Log::record("日志测试",'notice');
//    验证有没有user_id,如果没有,就发送一条数据
    if (!isset($data['user_id']) || empty($data['user_id']) || $data['user_id'] == 'undefined'){
        $connection->send(json(['code'=>1,'msg'=>'no user_id']));
    }
    // 判断当前客户端是否已经验证,即是否设置了uid
    if(!isset($connection->uid))
    {
        // 没验证的话把第一个包当做uid(这里为了方便演示,没做真正的验证)
        $connection->uid = $data['user_id'];
        /* 保存uid到connection的映射,这样可以方便的通过uid查找connection,
         * 实现针对特定uid推送数据
         */
        $worker->uidConnections[$connection->uid] = $connection;
        return $connection->send('login success, your uid is ' . $connection->uid);
    }
    // 其它逻辑,针对某个uid发送 或者 全局广播
    // 假设消息格式为 uid:message 时是对 uid 发送 message
    // uid 为 all 时是全局广播
    $recv_uid = $data['user_id'];
    $message = $data['msg'];
    // 全局广播
    if($recv_uid == 'all')
    {
        broadcast($message);
    }
    // 给特定uid发送
    else
    {
        sendMessageByUid($recv_uid, $message);
    }

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

};

// 向所有验证的用户推送数据
function broadcast($message)
{
    global $worker;
    foreach($worker->uidConnections as $connection)
    {
        $connection->send($message);
    }
}

// 针对uid推送数据
function sendMessageByUid($uid, $message)
{
    global $worker;
    if(isset($worker->uidConnections[$uid]))
    {
        $connection = $worker->uidConnections[$uid];
        $connection->send($message);
    }
}

Worker::runAll();
最佳答案
评论( 相关
后面还有条评论,点击查看>>