Laravel은 MQTT를 모니터링하기 위해 Workerman 명령줄과 어떻게 협력합니까?

Laravel+Workerman은 MQTT를 어떻게 모니터링하나요? 다음 기사에서는 Laravel이 Workerman 명령줄과 협력하여 MQTT를 모니터링하는 방법을 소개합니다. 도움이 되기를 바랍니다.

회사는 사물 인터넷에 종사하고 있으며 서버는 MQTT 프로토콜을 통해 PHP를 통해 사물 인터넷 장치와 통신하는 경우가 많습니다. 처음 접했을 때 PHP 프레임워크가 Laravel을 사용하는 경우가 있었습니다. , 비교할 수 있는 정보가 없다는 것을 발견하여 한동안 더듬어 보았습니다. 은 여러 프로젝트에서 사용되었으며 향후 참조할 수 있고 유사한 요구 사항을 가진 친구가 참조할 수 있도록 관련 단계가 여기에 게시되었습니다.

처음에 작성

우리 모두 알고 있듯이 PHP는 웹용으로 특별히 설계된 언어입니다. 대부분의 경우 백엔드에서는 다른 백엔드 언어와도 협력합니다. ​​​​"프런트 엔드"를 수행하려면 기본 디자인으로 인해 웹에서의 적합성이 제한되므로 서버를 사용하여 MQTT를 모니터링하려면 두 가지 주요 라이브러리가 협력해야 합니다. 여기서 언급한 워커맨(workerman)과 스울(swoole)은 현재(2019.08) 서버를 사용하여 MQTT를 모니터링한 결과 차이점은 다음과 같습니다.

workerman:

• 설치가 간편하고 다음과 같이 설치할 수 있습니다. 한 줄의 작곡가 명령 [관련 권장 사항: "workerman Tutorial"]
• MQTT 라이브러리 많은 사람들이 사용하고 있으며 업데이트 날짜가 더 최근입니다
• MQTT TLS/SSL 암호화 지원
• 자세한 문서

---

swoole:

• Workerman보다 설치가 더 복잡합니다. 각 운영 환경을 별도로 설치해야 하며 컴파일 환경이 필요할 수 있습니다.
• MQTT를 사용하는 사람이 적고 오랫동안 업데이트되었습니다.
• 문서도 적고, 찾을 수 있는 정보도 적습니다.
• TLS/SSL 암호화를 지원하지 않습니다. 암호화가 필요한 경우 환경입니다. 별로 친절하지 않을 수도 있습니다

요약하자면, 저는 마침내 Workererman을 선택했습니다. 이 글에서는 구성 및 사용을 위해 Workererman을 MQTT 라이브러리로 사용합니다.

Laravel이 이미 설치되어 있으면 생략해도 됩니다.

Composer는 현대 PHP 개발에 반드시 필요합니다. 기본적으로 대규모 프레임워크에서는 Composer 사용을 권장하므로 여기서는 Composer를 사용하여 Laravel을 설치합니다. :

Composer create-project --prefer-dist laravel/laravel Workerman-mqtt '5.5.*'

Laravel 지정 버전은 5.5.x입니다. 이는 현재(2019.08) LTS 버전입니다. 엔터프라이즈 프로젝트의 안정성과 보안을 확인하거나 LTS를 선택하세요. 프로젝트 이름은 workerman-mqtt이며 ​​특별히 MQTT를 테스트하는 데 사용됩니다.

작곡가가 너무 느린 경우 알리바바 클라우드 등 국내 작곡가 소스를 사용하여 설치 속도를 높이는 것을 고려해 볼 수 있습니다.

worker-mqtt 설치

위에서 언급했듯이 작곡가를 사용하여 작업자-mqtt를 설치하는 것은 매우 간단합니다.

➜  cd workerman-mqtt
➜  composer require workerman/mqtt
Using version ^1.0 for workerman/mqtt
./composer.json has been updated
Loading composer repositories with package information
Updating dependencies (including require-dev)
Package operations: 2 installs, 0 updates, 0 removals
  - Installing workerman/workerman (v3.5.20): Loading from cache
  - Installing workerman/mqtt (v1.0): Loading from cache
workerman/workerman suggests installing ext-event (For better performance. )
Package phpunit/phpunit-mock-objects is abandoned, you should avoid using it. No replacement was suggested.
Writing lock file
Generating optimized autoload files
Carbon 1 is deprecated, see how to migrate to Carbon 2.
https://carbon.nesbot.com/docs/#api-carbon-2
    You can run './vendor/bin/upgrade-carbon' to get help in updating carbon and other frameworks and libraries that depend on it.
> Illuminate\Foundation\ComposerScripts::postAutoloadDump
> @php artisan package:discover
Discovered Package: fideloper/proxy
Discovered Package: laravel/tinker
Discovered Package: nesbot/carbon
Package manifest generated successfully.

새로운 artisan 명령

Laravel은 Workererman과 함께 사용되므로 한 줄만 있으면 됩니다. MQTT를 모니터링하려면 artisan이 당연히 최선의 선택입니다. Laravel 구성 요소를 사용할 수 있으며 artisan 명령을 사용하여 청취 프로세스를 관리할 수도 있습니다. 관련 명령 파일을 생성합니다:

➜  php artisan make:command mqtt
Console command created successfully.

그런 다음 생성된 workerman-mqtt/app/Console/Commands/mqtt.php 파일을 편집하고 파일을 다음 내용으로 변경합니다.

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Workerman\Worker;

class mqtt extends Command
{
    protected $signature = &#39;mqtt {action}&#39;;

    protected $description = &#39;PHP Server MQTT Client&#39;;

    protected $client_id = &#39;php-server&#39;;

    public function __construct()
    {
        parent::__construct();
    }

    public function handle()
    {
        global $argv;
        $arg = $this->argument('action');
        $argv [1] = $arg;

        $worker = new Worker();
        $worker->count = 1;
        $worker->onWorkerStart = function () {
            $mqtt = new \Workerman\Mqtt\Client("mqtt://" . env('MQTT_HOST') . ":" . env('MQTT_PORT'), array(
//                'ssl' => array(
//                    'local_cert' => base_path() . '/path/mqtt/client.crt',
//                    'local_pk' => base_path() . '/path/mqtt/client.key',
//                    'cafile' => base_path() . '/path/mqtt/ca.crt',
//                    'verify_peer' => false,
//                    'allow_self_signed' => true,
//                ),
//                $mqtt->transport = 'ssl';
                'username' => env('MQTT_USER'),
                'password' => env('MQTT_PASSWORD'),
                'debug' => env('MQTT_DEBUG'),
                'client_id' => $this->client_id . mt_rand(0, 999),
                'will' => [
                    'topic' => 'status/' . $this->client_id,
                    'content' => 0,
                    'qos' => 2,
                    'retain' => true,
                ]
            ));
            $mqtt->onConnect = function ($mqtt) {
                $mqtt->subscribe('/iot/#');
            };
            $mqtt->onMessage = function ($topic, $data, $mqtt) {
                                var_dump($topic);
                                var_dump($data);
                                //TODO 业务代码

                                //publish消息到topic
                                $mqtt->publish('test', 'hello workerman mqtt');
            };
            $mqtt->connect();
        };
        Worker::runAll();
    }
}

그런 다음 아래의 .env로 이동합니다. 프로젝트 루트 디렉토리 파일에 다음 항목을 추가합니다.

MQTT_HOST=mqtt-broker.test
MQTT_PORT=1883
MQTT_USER=username
MQTT_PASSWORD=password
MQTT_DEBUG=true

그 중 onConnect의 subscribe 뒤에 모니터링해야 할 주제가 있습니다. 새 메시지가 수신되면 onMessage의 topic 주제가 옵니다. 메시지와 데이터는 특정 메시지 정보입니다. 이 두 가지를 사용하여 onMessage에 비즈니스 로직을 작성할 수도 있습니다. 물론 데이터베이스, 로그 등과 같은 Laravel 프레임워크 자체의 일부 구성 요소를 도입하거나 협력할 수도 있습니다. Redis, 메시지 큐 MQ 등과 같은 다른 서비스와 함께 사용. 메시지 큐 캐싱 또는 사용 등

mqtt 명령 실행

은 다른 artisan 명령과 유사합니다. 명령줄에서 직접 실행하세요.

➜  php artisan mqtt start
Workerman[artisan] start in DEBUG mode
------------------------------------- WORKERMAN --------------------------------------
Workerman version:3.5.20          PHP version:7.1.30
-------------------------------------- WORKERS ---------------------------------------
proto   user            worker          listen          processes    status
tcp     zoco            none            none            1             [OK]
--------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
-> Try to connect to mqtt://mqtt-broker.test:1883
-- Tcp connection established
-> Send CONNECT package client_id:php-server-superuser-subscribe95 username:username password:password clean_session:1 protocol_name:MQTT protocol_level:4
<- Recv CONNACK package, MQTT connect success
-> Send SUBSCRIBE package, topic:/iot/# message_id:1
<- Recv SUBACK package, message_id:1

Workerman 자체에 필요한 시작 매개변수인 다음 start를 잊지 않도록 주의하세요.

워커맨 설정은 메모리에 상주하기 때문에 정상적인 상황에서는 지속적으로 모니터링을 하기 때문에 프로그램에 버그가 생겨 종료되더라도 워커맨은 자동으로 새로운 프로세스를 생성해 처리하게 됩니다.

프로덕션 환경에서 MQTT 데이터를 장기간 모니터링하고 처리해야 하는 경우 systemctl과 같은 명령을 사용하여 관리하는 것이 좋습니다.

단점

지금까지는 클라이언트로 서버에서 MQTT 메시지를 모니터링할 수 있었지만, 아직까지는 이 라이브러리를 단독으로 호출해 실제 업무를 처리하는 방법을 찾지 못했다. 논리. 지정된 주제에 메시지를 게시할 때.

또 다른 점은 이 라이브러리를 사용할 때 이 라이브러리를 사용하는 두 개의 artisan 명령을 동시에 실행할 수 없다는 것입니다.

➜  php artisan mqtt start
Workerman[artisan] start in DEBUG mode
Workerman[artisan] already running

이 문제에 대해 전체 인터넷을 검색했지만 해결책을 찾지 못했습니다. Timer 클래스를 통해 타이밍 기능을 추가하고 대체 방법으로 해결할 수 있지만 효율성이 필요한 경우에는 최적의 솔루션이 아닙니다. 다른 솔루션이 있는 경우 MQTT 관련 비즈니스를 처리하는 서버로 PHP를 선택하지 않는 것이 좋습니다. .

더 많은 프로그래밍 관련 지식을 보려면 프로그래밍 교육을 방문하세요! !

위 내용은 Laravel은 MQTT를 모니터링하기 위해 Workerman 명령줄과 어떻게 협력합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!