Kaedah pelaksanaan menggabungkan Swoole dengan protokol MQTT

Dengan perkembangan Internet Perkara, semakin banyak aplikasi memerlukan penghantaran data dan komunikasi dalam masa nyata. Protokol Pengangkutan Beratur Mesej (MQTT) ialah protokol ringan yang sesuai untuk peranti kecil dan persekitaran lebar jalur rendah, dan sering digunakan untuk penghantaran data dalam peranti IoT. Sebagai rangka kerja komunikasi rangkaian berprestasi tinggi, tak segerak, dipacu peristiwa, Swoole menyediakan pelaksanaan protokol TCP/UDP/UnixSocket yang cekap dan boleh digunakan bersama dengan protokol MQTT untuk menyediakan komunikasi sistem yang lebih cekap.

Artikel ini akan memperkenalkan cara menggunakan protokol Swoole dan MQTT untuk berkomunikasi, dan menyediakan penyelesaian yang boleh dilaksanakan.

Pertama, kita perlu memahami pengetahuan asas protokol MQTT. Ia adalah protokol berdasarkan model terbitkan/langganan yang membolehkan komunikasi dua hala antara peranti. Terdapat dua peranan utama dalam protokol MQTT: penerbit dan pelanggan. Penerbit menerbitkan mesej kepada topik, dan pelanggan boleh melanggan topik yang diminati dan menerima mesej yang diterbitkan oleh penerbit dalam masa nyata. Dalam protokol MQTT, topik ditakrifkan sebagai rentetan sebagai pengecam untuk diterbitkan/langgan.

Seterusnya, kami akan melaksanakan model terbitan/langganan protokol MQTT menggunakan rangka kerja Swoole.

Sebelum menggunakan Swoole untuk melaksanakan protokol MQTT, kita perlu memasang perpustakaan MQTT. Swoole boleh menggunakan perpustakaan php-mqtt untuk komunikasi MQTT, dan kita boleh menggunakan komposer untuk memasangnya:

composer require bluerhinos/phpmqtt dev-master

Selepas pemasangan berjaya, kita boleh mula menggunakan Swoole untuk berkomunikasi dengan protokol MQTT.

Pertama, kita perlu mencipta pelayan TCP berdasarkan rangka kerja Swoole. Pada pelayan TCP ini, kami akan menggunakan protokol MQTT untuk penghantaran data. Dalam rangka kerja Swoole, kita boleh mencipta pelayan TCP melalui kod berikut:

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

Seterusnya, kita perlu mendaftarkan cangkuk perkhidmatan apabila pelayan bermula supaya permintaan pelanggan boleh diproses. Dalam contoh ini, kami akan menggunakan kaedah onConnect, onReceive dan 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.
";
});

Apabila menerima permintaan pelanggan, kami akan menghuraikan mesej MQTT. Memandangkan fokus artikel ini ialah cara menggunakan Swoole untuk melaksanakan protokol MQTT, kami hanya menumpukan pada cara menghuraikan mesej MQTT. Mesej MQTT boleh dihuraikan dengan mudah menggunakan perpustakaan php-mqtt Kami boleh merangkumnya ke dalam kaedah:

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

Kerja yang selebihnya ialah menghantar data yang dihuraikan mesej MQTT kepada pelanggan yang ingin menerimanya. Dalam protokol MQTT, kita boleh berkomunikasi menggunakan mod terbitkan/langganan untuk menerbitkan mesej kepada topik tertentu. Pelanggan boleh melanggan topik yang diminati dan kemudian menerima mesej yang diterbitkan mengenai topik tersebut. Dalam rangka kerja Swoole, kita boleh menggunakan swoole_server->task() untuk menghantar mesej kepada pelanggan tertentu.

Kod berikut adalah untuk menghantar mesej kepada semua pelanggan yang melanggan topik yang sepadan selepas menerima mesej MQTT:

$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");
    }

});

Setiap kali mesej pelanggan diterima, kami akan memanggil kaedah panggil balik handleMqttMessage(( ), dan kemudian menghantar mesej kepada pelanggan yang ditentukan.

Akhir sekali, kami perlu menghantar mesej kepada pelanggan dalam acara Tugas:

$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);
});

Kod di atas akan menghantar mesej kepada pelanggan dan mengembalikan mesej ACK yang sepadan selepas berjaya menghantar.

Ringkasan
Dalam artikel ini, kami mempelajari cara melaksanakan protokol MQTT menggunakan Swoole. Dengan cara ini, kami boleh mencapai komunikasi masa nyata yang cekap dan mengendalikan permintaan pelanggan dengan lebih baik menggunakan pendekatan tak segerak, dipacu peristiwa. Rangka kerja Swoole menyediakan pelaksanaan protokol TCP/UDP/UnixSocket yang cekap, yang mempunyai banyak kelebihan untuk kedua-dua perusahaan besar dan projek kecil. Pada masa hadapan, kami boleh menjangkakan lebih banyak aplikasi untuk menggunakan protokol Swoole dan MQTT untuk pemindahan data dan komunikasi.

Atas ialah kandungan terperinci Kaedah pelaksanaan menggabungkan Swoole dengan protokol MQTT. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!