12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273 |
- <?php
- declare(strict_types=1);
- namespace App\Process;
- use App\Master\Framework\Library\Mqtt\Subscribe;
- use App\Utils\LogUtil;
- use Hyperf\Process\AbstractProcess;
- use Hyperf\Process\Annotation\Process;
- class MqttProcess extends AbstractProcess
- {
-
- const LOG_MODULE = 'MqttProcess';
- const LOG_FUNCTION = 'handle';
-
- public int $nums = 1;
-
- public string $name = 'mqtt_process';
-
- public bool $redirectStdinStdout = false;
-
- public int $pipeType = 2;
-
- public bool $enableCoroutine = true;
-
- public function handle(): void
- {
-
- LogUtil::getInstance("Mqtt/");
- $topic = [
- '/test/subscribe' => 0
- ];
- $subscribe = new Subscribe();
- $subscribe->endlessLoop($topic, function ($cline,$message, array $topic) {
-
- LogUtil::getInstance("Mqtt/");
-
- LogUtil::info('订阅主题', self::LOG_MODULE, self::LOG_FUNCTION, $message);
-
- LogUtil::close();
- });
- }
- public function isEnable($server): bool
- {
-
- return false;
- }
- }
|