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();

最佳答案

评论() 相关

收藏

赞

hollowcg

ThinkPHP 是一个免费开源的,快速、简单的面向对象的 轻量级PHP开发框架 ,创立于2006年初,遵循Apache2开源协议发布,是为了敏捷WEB应用开发和简化企业应用开发而诞生的。ThinkPHP从诞生以来一直秉承简洁实用的设计原则,在保持出色的性能和至简的代码的同时,也注重易用性。并且拥有众多的原创功能和特性,在社区团队的积极参与下,在易用性、扩展性和性能方面不断优化和改进,已经成长为国内最领先和最具影响力的WEB应用开发框架,众多的典型案例确保可以稳定用于商业以及门户级的开发。