ホームページ >バックエンド開発 >PHPチュートリアル >PHP と MQTT を使用して、電子商取引 Web サイトにリアルタイムの在庫更新を追加する方法
PHP と MQTT を使用して電子商取引 Web サイトにリアルタイムの在庫更新機能を追加する方法
電子商取引 Web サイトでは、在庫更新は非常に重要なタスクです。より良いユーザーエクスペリエンスを提供するためには、在庫情報をタイムリーに更新し、過剰販売や不正確な製品情報を回避することが重要です。この記事では、PHPとMQTTを使ってECサイトのリアルタイム在庫更新機能を実装する方法を紹介します。
まず、いくつかの基本的な概念を理解しましょう。
MQTT は、モノのインターネットやその他の低帯域幅、高遅延、または不安定な環境でメッセージを送信するために使用される軽量のメッセージング プロトコルです。パブリッシュ/サブスクライブ モデルを使用し、ブローカーを通じてメッセージを配信します。 PHP は、Web アプリケーションの開発に使用される一般的なサーバーサイド スクリプト言語です。
次に、次の手順に従って、リアルタイム インベントリ更新機能を実装します。
ステップ 1: MQTT ブローカー (ブローカー) をインストールします。
最初に、必要なものが必要です。 Mosquitto などの MQTT ブローカーをコンピューターにインストールします。 Mosquitto の公式 Web サイトの指示に従ってインストールを完了できます。
ステップ 2: MQTT ブローカーを構成する
インストールが完了したら、MQTT ブローカーを構成する必要があります。 mosquitto.conf ファイルを編集して、次のパラメータを設定できます:
listener 1883
allow_anonymous true
ステップ 3: データベース テーブルを作成します
次に、製品の在庫情報を保存するデータベース テーブルを作成します。次の SQL ステートメントを使用して、「inventory」という名前のテーブルを作成できます:
CREATE TABLE inventory
(
id
int(11) NOT NULL AUTO_INCREMENT ,
product_id
int(11) NOT NULL,
quantity
int(11) NOT NULL,
主キー (id
)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4;
ステップ 4: PHP コードを作成する
これで、インベントリ情報を更新し、MQTT ブローカー情報に公開するための PHP コードを作成できます。 。まず、MQTT PHP ライブラリを使用する必要があります。このライブラリをインストールするには、composer を使用できます。次のコマンドを実行します。
composer require php-mqtt/client
次に、「inventory.php」というファイルを作成し、次のように入力します。コード:
7a881159d15931ae02a2d405dbbd0543close();
?>
上記ではコードでは、最初に MQTT クライアント インスタンスを作成しました。次に、connect メソッドを呼び出して MQTT ブローカーに接続します。次に、subscribe メソッドを呼び出して「インベントリ/更新」トピックにサブスクライブし、メッセージを処理するコールバック関数を提供します。コールバック関数では、メッセージ内のデータを解析し、データベース内の対応する製品の在庫情報を更新します。最後に、close メソッドを呼び出して MQTT クライアントを閉じます。
ステップ 5: メッセージを送信します。在庫更新メッセージ
これで、在庫更新メッセージを送信するコードを作成できます。注文確認ページや注文の支払いが成功した後のロジックなど、適切な場所に次のコードを追加できます。
c0e8d62d00a4e18a8988db7386285685connect ();$data = [
'product_id' => 1, 'quantity' => 10];//インベントリ更新メッセージを公開
$mqtt- >publish('inventory/update', json_encode($data));
?> ;
以上がPHP と MQTT を使用して、電子商取引 Web サイトにリアルタイムの在庫更新を追加する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。