lanzu_api_2021-12-26/app/TaskWorker/MQTTClientTask.php

<?php
declare(strict_types=1);

namespace App\TaskWorker;

use App\Libs\MQTTClient;
use Hyperf\Task\Annotation\Task;

class MQTTClientTask
{
    protected $mqttClient = null;

    /**
     * @Task
     */
    public function getClient()
    {
        $this->mqttClient = new MQTTClient(env('MQTT_HOST'), env('MQTT_PORT'));
        $this->mqttClient->setAuthentication(env('MQTT_NAME'), env('MQTT_PASS'));

        if (env('MQTT_CERT')) {
            $this->mqttClient->setEncryption(env('MQTT_CERT'));
        }

        return $this->mqttClient;
    }
}