workerman中，如果發(fā)送的兩次modbus tcp連接需要一定的間隔時(shí)間，怎么辦？
問題描述 業(yè)務(wù)需要定時(shí)去PLC獲取數(shù)據(jù)，為此我在一個(gè)進(jìn)程內(nèi)，定義了多個(gè)定時(shí)器 foreach ($devicePlcs as $devicePlc) { // 如果不存在，則表示新增，需創(chuàng)建timer數(shù)組 if (!isset($this->timers[$devicePlc->id])) { $timer_id = Tim...
workerman中，while(true)和timer::add的沖突?
問題描述 以下的代碼，我寫在onworkerstart里面，每隔10秒中向redis的隊(duì)列寫數(shù)據(jù)，但是為啥while(true)的部分沒有執(zhí)行呢？如果去掉while（true），那只能執(zhí)行1次，不能執(zhí)行多次？ protected function loop() { Timer::add(10, function () { $data['DEVICE_ID'] =...
connection對(duì)象可以存放在redis中，共享給其他workerman用嗎？
問題描述 大概意思就是想要個(gè)集群，現(xiàn)在不知道那個(gè)connection對(duì)象能否共享給其他worekerman用？ 為此你搜索到了哪些方案及不適用的原因 找不到...
我想問下關(guān)于onmessage離的connection對(duì)象？我想開發(fā)個(gè)聊天室的項(xiàng)目
問題描述 我想問的問題是，假設(shè)每次發(fā)的包都包含有fromUserId，content，toUserId這些字段， $userIdToConnection[$fromUserId] = $connection; 那這句話后，他每次的$connection都是一樣的嗎？ $worker->onMessage = function ($connection, $data) { global $userId...
開啟workerman后，能否用不同的子worker，來(lái)監(jiān)聽不同的請(qǐng)求？
問題描述 $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { switch ($worker->id) { case 0: ...
mqtt的onMessage函數(shù)，是不是要等使用它的進(jìn)程退出才退出？
問題描述 $this->mqttClient->onMessage = function($topic, $content) {} 這個(gè)函數(shù)，，一直loop，直到使用他的進(jìn)程退出，才會(huì)退出？ 請(qǐng)問這樣理解是否是正確的？...
workerman中的mqtt類，能否獨(dú)立出來(lái)在其他laravel中運(yùn)行的php-cli程序中運(yùn)行？
問題描述 wokerman中能否獨(dú)立調(diào)用類似php artisan queue work的命令？ 因?yàn)槲矣袀€(gè)laravel程序，本身要通過laravel的隊(duì)列放進(jìn)去，取出來(lái)的時(shí)候再通過mqtt發(fā)送出去？...
有沒有辦法知道當(dāng)前進(jìn)程中運(yùn)行了多少個(gè)定時(shí)器？
問題描述 我有個(gè)進(jìn)程，里面運(yùn)行了很多定時(shí)器，那有啥辦法把所有的定時(shí)器任務(wù)都給列出來(lái)呢？...
為啥程序發(fā)送出去的mqtt消息沒有相應(yīng)，我手動(dòng)用工具模擬發(fā)出的又有相應(yīng)？
我是用workerman的mqtt和laravel發(fā)送的，請(qǐng)問publish的內(nèi)容是不是2進(jìn)制的？ 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 { // 為每個(gè)子進(jìn)程創(chuàng)建獨(dú)立的...
workemran/mqtt，這個(gè)異步消息組件，能否跨越進(jìn)程去使用？
問題描述 $mqtt = new mqtt('mqtt://test.mosquitto.org:1883') $this->startWorker1(); // 開啟1號(hào)workerman， 主要處理http類 $this->startWorker2(); // 開啟2號(hào)workerman， 主要處理物聯(lián)網(wǎng)類（tcp，mqtt） Worker::runAll(); // 統(tǒng)一啟動(dòng)所有的worke...
總感覺是錯(cuò)誤的，請(qǐng)大神知道workerman中的timer類的使用
問題描述 $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { switch ($worker->id) { case 0: ...
