問題描述 業(yè)務需要定時去PLC獲取數(shù)據(jù),為此我在一個進程內(nèi),定義了多個定時器 foreach ($devicePlcs as $devicePlc) { // 如果不存在,則表示新增,需創(chuàng)建timer數(shù)組 if (!isset($this->timers[$devicePlc->id])) { $timer_id = Tim...
問題描述 以下的代碼,我寫在onworkerstart里面,每隔10秒中向redis的隊列寫數(shù)據(jù),但是為啥while(true)的部分沒有執(zhí)行呢?如果去掉while(true),那只能執(zhí)行1次,不能執(zhí)行多次? protected function loop() { Timer::add(10, function () { $data['DEVICE_ID'] =...
問題描述 大概意思就是想要個集群,現(xiàn)在不知道那個connection對象能否共享給其他worekerman用? 為此你搜索到了哪些方案及不適用的原因 找不到...
問題描述 我想問的問題是,假設每次發(fā)的包都包含有fromUserId,content,toUserId這些字段, $userIdToConnection[$fromUserId] = $connection; 那這句話后,他每次的$connection都是一樣的嗎? $worker->onMessage = function ($connection, $data) { global $userId...
問題描述 $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { switch ($worker->id) { case 0: ...
問題描述 $this->mqttClient->onMessage = function($topic, $content) {} 這個函數(shù),,一直loop,直到使用他的進程退出,才會退出? 請問這樣理解是否是正確的?...
問題描述 wokerman中能否獨立調(diào)用類似php artisan queue work的命令? 因為我有個laravel程序,本身要通過laravel的隊列放進去,取出來的時候再通過mqtt發(fā)送出去?...
我是用workerman的mqtt和laravel發(fā)送的,請問publish的內(nèi)容是不是2進制的? protected function sendBinary($device, $start, $registerNum, $byteNum) { $str = $device->address . $device->deviceModel->read_code . $star...
問題描述 public function startWorker2() { $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { // 為每個子進程創(chuàng)建獨立的...
問題描述 $mqtt = new mqtt('mqtt://test.mosquitto.org:1883') $this->startWorker1(); // 開啟1號workerman, 主要處理http類 $this->startWorker2(); // 開啟2號workerman, 主要處理物聯(lián)網(wǎng)類(tcp,mqtt) Worker::runAll(); // 統(tǒng)一啟動所有的worke...
問題描述 $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { switch ($worker->id) { case 0: ...