Perisian tengah rangka kerja Yii: menggunakan MQTT dan WebSocket untuk melaksanakan fungsi pemesejan segera

Yii framework middleware: Menggunakan MQTT dan WebSocket untuk melaksanakan fungsi pemesejan segera

Pengenalan:
Dalam pembangunan aplikasi Internet moden, fungsi pemesejan segera telah menjadi bahagian penting dalam banyak aplikasi. Dalam rangka kerja Yii, kita boleh menggunakan MQTT dan WebSocket dengan mudah, dua alatan berkuasa, untuk melaksanakan fungsi pemesejan segera. Artikel ini akan memperkenalkan cara menggunakan perisian tengah MQTT dan WebSocket dalam rangka kerja Yii, dan menyediakan sampel kod untuk rujukan pembaca.

1. Apakah itu MQTT dan WebSocket

1. MQTT
   MQTT, yang bermaksud Message Queuing Telemetry Transport, ialah protokol penghantaran mesej ringan yang digunakan secara meluas dalam Internet of Things dan medan pemesejan segera. MQTT mengguna pakai model terbitan/langganan, menyokong penerbitan mesej satu-ke-banyak, dan mempunyai ciri-ciri lebar jalur yang rendah dan penggunaan tenaga yang rendah.
2. WebSocket
   WebSocket ialah protokol yang digunakan untuk mencapai komunikasi dua hala, dan sering digunakan untuk melaksanakan fungsi pemesejan segera dalam pembangunan Web. Berbanding dengan protokol HTTP tradisional, WebSocket menyediakan kependaman yang lebih rendah dan prestasi masa nyata yang lebih tinggi.

2. Sokongan MQTT dan WebSocket dalam rangka kerja Yii

1. Sokongan MQTT
   Rangka kerja Yii menyediakan sokongan untuk MQTT melalui pakej sambungan yii2-mqtt. Anda boleh menggunakan MQTT dengan mudah dalam rangka kerja Yii dengan hanya menambah kebergantungan pada pakej sambungan dalam fail composer.json projek dan melaksanakan arahan pemasangan yang sepadan. yii2-mqtt扩展包提供了对MQTT的支持。只需在项目的composer.json文件中添加对该扩展包的依赖，并执行相应的安装命令，就可以在Yii框架中轻松地使用MQTT。
2. WebSocket支持
   Yii框架从2.0版本开始原生支持WebSocket。只需在配置文件中配置相应的WebSocket路由规则，并编写对应的控制器处理程序，就可以在Yii框架中使用WebSocket。

三、在Yii框架中实现即时通信功能的步骤

1. 安装依赖
   在项目的composer.json文件中添加对yii2-mqtt扩展包的依赖：

{
    "require": {
        "clevertech/yii2-mqtt": "1.0.0"
    }
}

然后执行composer install

Sokongan WebSocket

Rangka kerja Yii secara asli menyokong WebSocket bermula dari versi 2.0. Hanya konfigurasikan peraturan penghalaan WebSocket yang sepadan dalam fail konfigurasi dan tulis pengendali pengawal yang sepadan untuk menggunakan WebSocket dalam rangka kerja Yii.
2. 
   
3 Langkah untuk melaksanakan fungsi pemesejan segera dalam rangka kerja Yii

3. Pasang dependencies
   Tambah pakej sambungan yii2-mqtt dalam Ketergantungan fail composer.json projek:

'mqtt' => [
    'class' => 'clevertechyii2mqttMqtt',
    'hostname' => 'mqtt.example.com',
    'port' => 1883,
    'username' => 'your_username',
    'password' => 'your_password',
    'clientId' => 'your_client_id',
],

Kemudian laksanakan perintah composer install untuk memasang.
4. 
   
Konfigurasikan sambungan MQTT

Dalam fail konfigurasi rangka kerja Yii, konfigurasikan maklumat sambungan pelayan MQTT:

use clevertechyii2mqttMqtt;

class MyController extends yiiwebController
{
    public function actionSubscribe()
    {
        $mqtt = Yii::$app->mqtt;
        $mqtt->subscribe('topic/foo', function ($topic, $message) {
            echo "Received message on topic [$topic]: $message";
        });
    }

    public function actionPublish()
    {
        $mqtt = Yii::$app->mqtt;
        $mqtt->publish('topic/foo', 'Hello, MQTT!');
    }
}

🎜Laksanakan langganan dan penerbitan MQTT🎜Di mana MQTT perlu digunakan, kita boleh melakukannya melalui MQTT kelas yang disediakan oleh rangka kerja Yii Langganan dan operasi penerbitan. Berikut ialah contoh mudah: 🎜🎜

'urlManager' => [
    'rules' => [
        [
            'class' => 'yiiwebSocketUrlRule',
            'route' => 'my-websocket-controller/action',
            'pattern' => 'ws://localhost:8080',
        ],
    ],
],

🎜🎜Konfigurasikan penghalaan dan pengawal WebSocket🎜Dalam fail konfigurasi rangka kerja Yii, konfigurasikan peraturan penghalaan WebSocket dan tulis pengendali pengawal yang sepadan. Berikut ialah contoh mudah: 🎜🎜

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class MyWebSocketController implements MessageComponentInterface
{
    public function onOpen(ConnectionInterface $conn)
    {
        // WebSocket连接建立时的操作
    }

    public function onClose(ConnectionInterface $conn)
    {
        // WebSocket连接关闭时的操作
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        // 接收到WebSocket消息时的操作
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // WebSocket出错时的操作
    }
}

rrreee🎜 5. Ringkasan🎜Melalui langkah di atas, kita boleh melaksanakan fungsi pemesejan segera dengan mudah menggunakan MQTT dan WebSocket dalam rangka kerja Yii. Menggunakan pakej sambungan berkuasa rangka kerja Yii dan sokongan asli, kami boleh membangunkan aplikasi yang cekap dan stabil dengan cepat. Sudah tentu, artikel ini hanyalah pengenalan ringkas kepada ciri ini, dan pembaca boleh mempelajari lebih lanjut penggunaan terperinci bagi perisian tengah ini dan ciri yang lebih maju. 🎜

Atas ialah kandungan terperinci Perisian tengah rangka kerja Yii: menggunakan MQTT dan WebSocket untuk melaksanakan fungsi pemesejan segera. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!