#### 问题描述
```
$mqtt = new mqtt('mqtt://test.mosquitto.org:1883')
$this->startWorker1(); // 开启1号workerman, 主要处理http类
$this->startWorker2(); // 开启2号workerman, 主要处理物联网类(tcp,mqtt)
Worker::runAll(); // 统一启动所有的worker
public function startWorker1()
{
$worker = new Worker();
$worker->count = 4;
$worker->onWorkerStart = function ($worker) {
try {
switch ($worker->id) {
case 0: // 捷顺的任务
$jieShun = app()->make(\App\Services\JieShunService::class);
//$jieShun->test();
break;
case 1:
break;
default:
break;
}
} catch (\Exception $e) {
// Log::error("An error occurred in Worker_" . $worker->id . ": " . $e->getMessage(), [ // 记录错误日志
// 'worker_id' => $worker->id,
// 'exception' => $e,
// ]);
echo "An error occurred in Worker_" . $worker->id . ": " . $e->getMessage();
}
};
}
```
#### 为此你搜索到了哪些方案及不适用的原因
想请问下这样写行不行