Implementierungsmethode zur Kombination von Swoole mit dem MQTT-Protokoll

Mit der Entwicklung des Internets der Dinge erfordern immer mehr Anwendungen Datenübertragung und Kommunikation in Echtzeit. Das Message Queuing Transport Protocol (MQTT) ist ein leichtes Protokoll, das für kleine Geräte und Umgebungen mit geringer Bandbreite geeignet ist und häufig für die Datenübertragung in IoT-Geräten verwendet wird. Als leistungsstarkes, asynchrones, ereignisgesteuertes Netzwerkkommunikations-Framework bietet Swoole eine effiziente Implementierung des TCP/UDP/UnixSocket-Protokolls und kann in Verbindung mit dem MQTT-Protokoll verwendet werden, um eine effizientere Systemkommunikation bereitzustellen.

In diesem Artikel wird erläutert, wie Swoole- und MQTT-Protokolle zur Kommunikation verwendet werden, und eine praktikable Lösung bereitgestellt.

Zuerst müssen wir die Grundkenntnisse des MQTT-Protokolls verstehen. Es handelt sich um ein Protokoll, das auf einem Publish/Subscribe-Modell basiert und eine bidirektionale Kommunikation zwischen Geräten ermöglicht. Im MQTT-Protokoll gibt es zwei Hauptrollen: Herausgeber und Abonnenten. Herausgeber veröffentlichen Nachrichten zu Themen, und Abonnenten können interessante Themen abonnieren und von Herausgebern veröffentlichte Nachrichten in Echtzeit erhalten. Im MQTT-Protokoll wird ein Thema als String als Kennung für Publish/Subscribe definiert.

Als nächstes implementieren wir das Publish/Subscribe-Modell des MQTT-Protokolls mithilfe des Swoole-Frameworks.

Bevor wir Swoole zur Implementierung des MQTT-Protokolls verwenden, müssen wir die MQTT-Bibliothek installieren. Swoole kann die PHP-MQTT-Bibliothek für die MQTT-Kommunikation verwenden, und wir können Composer verwenden, um sie zu installieren:

composer require bluerhinos/phpmqtt dev-master

Nach erfolgreicher Installation können wir Swoole für die Kommunikation mit dem MQTT-Protokoll verwenden.

Zuerst müssen wir einen TCP-Server basierend auf dem Swoole-Framework erstellen. Auf diesem TCP-Server verwenden wir das MQTT-Protokoll zur Datenübertragung. Im Swoole-Framework können wir über den folgenden Code einen TCP-Server erstellen:

$server = new SwooleServer('0.0.0.0', 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);

Als nächstes müssen wir den Service-Hook registrieren, wenn der Server startet, damit Client-Anfragen verarbeitet werden können. In diesem Beispiel verwenden wir die Methoden onConnect, onReceive und onClose:

$server->on('connect', function ($serv, $fd) {
    echo "Client: Connect.
";
});

$server->on('receive', function ($serv, $fd, $from_id, $data) {
    echo "Receive Data: $data
";

    // 处理MQTT消息
});

$server->on('close', function ($serv, $fd) {
    echo "Client: Close.
";
});

Beim Empfang einer Client-Anfrage analysieren wir die MQTT-Nachricht. Da der Schwerpunkt dieses Artikels auf der Verwendung von Swoole zur Implementierung des MQTT-Protokolls liegt, konzentrieren wir uns nur auf die Analyse von MQTT-Nachrichten. MQTT-Nachrichten können einfach mit der PHP-MQTT-Bibliothek analysiert werden. Wir können sie in eine Methode kapseln:

function handleMqttMessage($client_id, $topic, $message)
{
    echo "Mqtt Message Received: 
";
    echo "Client ID: $client_id
";
    echo "Topic: $topic
";
    echo "Message: $message
";
}

Die verbleibende Arbeit besteht darin, die analysierten Daten der MQTT-Nachricht an den Client zu senden, der sie empfangen möchte. Im MQTT-Protokoll können wir im Publish/Subscribe-Modus kommunizieren, um Nachrichten zu bestimmten Themen zu veröffentlichen. Ein Kunde kann ein interessantes Thema abonnieren und dann zu diesem Thema veröffentlichte Nachrichten erhalten. Im Swoole-Framework können wir swoole_server->task() verwenden, um Nachrichten an bestimmte Clients zu senden.

Der folgende Code dient dazu, die Nachricht nach Erhalt der MQTT-Nachricht an alle Clients zu senden, die das entsprechende Thema abonniert haben:

$server->on('receive', function ($serv, $fd, $from_id, $data) {
    $mqtt = new BluerhinosphpMQTT('localhost', 1883, 'Swoole_Server');
    $mqtt->debug = false;
    if (!$mqtt->connect()) {
        exit(1);
    }
    $topics['topic_name'] = array('qos' => 0, 'function' => 'handleMqttMessage');
    $mqtt->subscribe($topics, 0);
    while ($mqtt->proc()) {
    };
    $mqtt->close();
    echo "Receive Data: $data
";

    $data = json_decode($data, true);
    $message = $data['message'];

    $client_ids = $serv->getClientList();
    foreach ($client_ids as $client_id) {
        $serv->task("$client_id:$message");
    }

});

Jedes Mal, wenn eine Client-Nachricht empfangen wird, rufen wir die Rückrufmethode handleMqttMessage(() auf und senden dann die Nachricht an den angegebenen Client.

Schließlich müssen wir die Nachricht im Task-Ereignis an den Client senden:

$server->on('task', function ($serv, $task_id, $from_id, $data) {
    $client_id = strstr($data, ':', true);
    $message = substr(strstr($data, ':'), 1);
    $serv->send($client_id, $message);
});

Der obige Code sendet die Nachricht an den Client und gibt nach erfolgreichem Senden eine entsprechende ACK-Nachricht zurück.

Zusammenfassung
In diesem Artikel haben wir gelernt, wie man das MQTT-Protokoll mit Swoole implementiert. Auf diese Weise können wir eine effiziente Echtzeitkommunikation erreichen und Kundenanfragen mithilfe eines asynchronen, ereignisgesteuerten Ansatzes besser bearbeiten. Das Swoole-Framework bietet eine effiziente Implementierung des TCP/UDP/UnixSocket-Protokolls, was sowohl für große Unternehmen als auch für kleine Projekte viele Vorteile bietet. Wir können davon ausgehen, dass in Zukunft mehr Anwendungen die Protokolle Swoole und MQTT für die Datenübertragung und Kommunikation nutzen werden.

Das obige ist der detaillierte Inhalt vonImplementierungsmethode zur Kombination von Swoole mit dem MQTT-Protokoll. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!