mqtt的onMessage函数,是不是要等使用它的进程退出才退出?

问题描述 $this->mqttClient->onMessage = function($topic, $content) {} 这个函数,,一直loop,直到使用他的进程退出,才会退出? 请问这样理解是否是正确的?...

bobshipwood 发表与 3天前 62 浏览 1 回答
workerman中的mqtt类,能否独立出来在其他laravel中运行的php-cli程序中运行?

问题描述 wokerman中能否独立调用类似php artisan queue work的命令? 因为我有个laravel程序,本身要通过laravel的队列放进去,取出来的时候再通过mqtt发送出去?...

bobshipwood 发表与 8天前 140 浏览 3 回答
有没有办法知道当前进程中运行了多少个定时器?

问题描述 我有个进程,里面运行了很多定时器,那有啥办法把所有的定时器任务都给列出来呢?...

bobshipwood 发表与 8天前 182 浏览 1 回答
为啥程序发送出去的mqtt消息没有相应,我手动用工具模拟发出的又有相应?

我是用workerman的mqtt和laravel发送的,请问publish的内容是不是2进制的? protected function sendBinary($device, $start, $registerNum, $byteNum) { $str = $device->address . $device->deviceModel->read_code . $star...

bobshipwood 发表与 9天前 47 浏览 0 回答
总觉得这样写不正确?

问题描述 public function startWorker2() { $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { // 为每个子进程创建独立的...

bobshipwood 发表与 9天前 72 浏览 0 回答
workemran/mqtt,这个异步消息组件,能否跨越进程去使用?

问题描述 $mqtt = new mqtt('mqtt://test.mosquitto.org:1883') $this->startWorker1(); // 开启1号workerman, 主要处理http类 $this->startWorker2(); // 开启2号workerman, 主要处理物联网类(tcp,mqtt) Worker::runAll(); // 统一启动所有的worke...

bobshipwood 发表与 18天前 178 浏览 1 回答
总感觉是错误的,请大神知道workerman中的timer类的使用

问题描述 $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { switch ($worker->id) { case 0: ...

bobshipwood 发表与 19天前 194 浏览 1 回答

bobshipwood

-20
积分
0
获赞数
0
粉丝数
19天前 加入
×
🔝