<?php
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
use Workerman\Lib\Timer;
use app\date\model\SystemNode;
require_once __DIR__ . '/vendor/autoload.php';
/**
* Worker 命令行類
*/
$worker = new Worker();
$worker->onWorkerStart = function($worker){
$conC_url="ws://xxx";
$con_url="ws://xxx";
//配置
$conC = new AsyncTcpConnection($conC_url);$conC->transport = 'ssl';
// // 建立連接
$conC->onConnect = function($connection) {
SystemNode::mk()->where('')->update();
};
// 遠(yuǎn)程websocket服務(wù)器發(fā)來消息時
$conC->onMessage = function($connection, $data){
print_r($data."\n");
};
// 連接上發(fā)生錯誤時,一般是連接遠(yuǎn)程websocket服務(wù)器失敗錯誤
$conC->onError = function($connection, $code, $msg){};
// 當(dāng)連接遠(yuǎn)程websocket服務(wù)器的連接斷開時// 如果連接斷開20秒后自動重連
$conC->onClose = function($connection){print_r(date('Y-m-d H:i:s',time())." 重連"); $connection->reconnect(5);};
$conC->connect();
};
Worker::runAll();
類似這樣,可以實現(xiàn)嗎?:
use app\date\model\SystemNode;
SystemNode::mk()->where($map)->update();
我引用了之后報錯:
Error: Call to a member function connect() on null in F:\okx\tp\vendor\topthink\think-orm\src\Model.php:357
Stack trace:
#0 F:\okx\tp\vendor\topthink\think-orm\src\Model.php(1045): think\Model->db()
#1 F:\okx\tp\vendor\zoujingli\think-library\src\Model.php(96): think\Model- >__call('where', Array)
#2 F:\okx\tp\Startws3.php(53): think\admin\Model->__call('where', Array)
#3 F:\okx\tp\vendor\workerman\workerman\Connection\AsyncTcpConnection.php(345): Startws3\{closure}(Object(Workerman\Connection\AsyncTcpConnection))
#4 F:\okx\tp\vendor\workerman\workerman\Events\Select.php(302): Workerman\Connection\AsyncTcpConnection->checkConnection(Resource id #27)
#5 F:\okx\tp\vendor\workerman\workerman\Worker.php(2410): Workerman\Events\Select->loop()
#6 F:\okx\tp\vendor\workerman\workerman\Worker.php(1406): Workerman\Worker->run()
#7 F:\okx\tp\vendor\workerman\workerman\Worker.php(1349): Workerman\Worker::forkWorkersForWindows()
#8 F:\okx\tp\vendor\workerman\workerman\Worker.php(546): Workerman\Worker::forkWorkers()
#9 F:\okx\tp\Startws3.php(180): Workerman\Worker::runAll()
#10 {main}
Worker process terminated