PHP と MQTT を使用してリアルタイム メッセージ プッシュ システムを構築する

PHP と MQTT を使用したリアルタイム メッセージ プッシュ システムの構築

はじめに

インターネットの発展に伴い、リアルタイム コミュニケーションの重要性がますます高まっています。インスタント チャット、通知リマインダー、リアルタイム データ更新などの多くのシナリオにおいて、リアルタイム メッセージ プッシュは不可欠な機能になっています。この記事では、PHP と MQTT を使用して簡単なリアルタイム メッセージ プッシュ システムを構築する方法をコード例とともに紹介します。

MQTT プロトコルの概要

MQTT (Message Queuing Telemetry Transport) は、パブリッシュ/サブスクライブ モデルに基づく軽量の通信プロトコルで、モノのインターネット、リアルタイム監視などの分野に適しています。 。 MQTT プロトコルは、通信に TCP/IP プロトコルを使用し、遅延が少なく、帯域幅の使用量が少なく、実装が簡単であるという特徴があります。

PHP MQTT クライアント

PHP では、Mosquitto 拡張機能を使用して MQTT 通信を実装できます。まず、Mosquitto 拡張機能をインストールする必要があります。 Linux システムでは、次のコマンドを使用してインストールできます。

sudo apt-get install php-mosquitto

以下は、単純な PHP MQTT クライアントのサンプル コードです。

<?php

$mqtt = new MosquittoClient();

// 连接到MQTT服务器
$mqtt->connect('localhost', 1883);

// 订阅主题
$mqtt->subscribe('topic');

// 接收消息的回调函数
$mqtt->onMessage(function ($message) {
    echo '收到消息：' . $message->payload . PHP_EOL;
});

// 循环接收消息
while (true) {
    $mqtt->loop();
}

// 断开连接
$mqtt->disconnect();

リアルタイム メッセージ プッシュ システムの構築

それでは、簡単なリアルタイム メッセージ プッシュ システムを構築してみましょう。このシステムは、メッセージ パブリッシャー、メッセージ サブスクライバー、メッセージ プッシュ サービスの 3 つの部分で構成されます。

メッセージ パブリッシャー

メッセージ パブリッシャーは、MQTT サーバーにメッセージを送信するために使用されます。以下は、単純なメッセージ パブリッシャーのサンプル コードです。

<?php

$mqtt = new MosquittoClient();

// 连接到MQTT服务器
$mqtt->connect('localhost', 1883);

// 发布消息
$mqtt->publish('topic', 'Hello, World!');

// 断开连接
$mqtt->disconnect();

メッセージ サブスクライバー

メッセージ サブスクライバーは、MQTT サーバーでメッセージを受信するために使用されます。以下は、単純なメッセージ サブスクライバのサンプル コードです。

<?php

$mqtt = new MosquittoClient();

// 连接到MQTT服务器
$mqtt->connect('localhost', 1883);

// 订阅主题
$mqtt->subscribe('topic');

// 接收消息的回调函数
$mqtt->onMessage(function ($message) {
    echo '收到消息：' . $message->payload . PHP_EOL;
});

// 循环接收消息
while (true) {
    $mqtt->loop();
}

// 断开连接
$mqtt->disconnect();

メッセージ プッシュ サービス

メッセージ プッシュ サービスは、サブスクライバによってサブスクライブされたメッセージをクライアントにプッシュする役割を果たします。以下は、単純なメッセージ プッシュ サービスのサンプル コードです。

<?php

$mqtt = new MosquittoClient();

// 连接到MQTT服务器
$mqtt->connect('localhost', 1883);

// 订阅主题
$mqtt->subscribe('topic');

// 接收消息的回调函数
$mqtt->onMessage(function ($message) {
    // 推送消息给客户端
    pushMessageToClient($message->payload);
});

// 循环接收消息
while (true) {
    $mqtt->loop();
}

// 断开连接
$mqtt->disconnect();

// 推送消息给客户端
function pushMessageToClient($message) {
    // 实现消息推送逻辑
}

概要

この記事では、PHP と MQTT を使用して、単純なリアルタイム メッセージ プッシュ システムを構築する方法を紹介します。 MQTT プロトコルを使用することで、低遅延、低帯域幅のリアルタイム通信を実現できます。この記事がお役に立てば幸いです!

以上がPHP と MQTT を使用してリアルタイム メッセージ プッシュ システムを構築するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。