問(wèn)題描述

public function startWorker2()
    {
        $worker = new Worker();
        $worker->count = 4;
        $worker->onWorkerStart = function ($worker) {
            try {
                // 為每個(gè)子進(jìn)程創(chuàng)建獨(dú)立的 MQTT 客戶端實(shí)例
                $mqttClient = new \Workerman\Mqtt\Client(env('MQTT_URL'), ['client_id' => "sy-mqtt-client-".mt_rand(), 'username' => env('MQTT_USERNAME'), 'password' => env('MQTT_PASSWORD')]);
                $mqttClient->connect();
                switch ($worker->id) {
                    case 0:
                        app()->make(\App\Services\DeviceModelService::class,  ['mqttClient' => $mqttClient]); // 執(zhí)行485設(shè)備定時(shí)采集數(shù)據(jù)
                        break;
                    case 1:
                        app()->make(\App\Services\ModelReceiveService::class,  ['mqttClient' => $mqttClient]); // 執(zhí)行485設(shè)備收集數(shù)據(jù)
                        break;
                    default:
                        break;
                }
            } catch (\Exception $e) {
//                Log::error("An error occurred in Worker_" . $worker->id . ": " . $e->getMessage(), [ // 記錄錯(cuò)誤日志
//                    'worker_id' => $worker->id,
//                    'exception' => $e,
//                ]);
                echo "An error occurred in Worker_" . $worker->id . ": " . $e->getMessage();
                echo $e->getFile() . $e->getLine();
            }
        };
    }

為此你搜索到了哪些方案及不適用的原因

問(wèn)題出現(xiàn)在這里， app()->make(\App\Services\DeviceModelService::class, ['mqttClient' => $mqttClient]); 怎么能確保里面的mqtt一定是這個(gè)進(jìn)程所對(duì)應(yīng)的mqtt呢？