phpを使用してWebsocketを開発し、リアルタイム商品レコメンド機能を実装する

Websocket は、ブラウザとサーバー間のリアルタイム通信を実現できる全二重通信プロトコルです。電子商取引 Web サイトでは、Websocket を使用してリアルタイムの製品推奨機能を実装し、ユーザーが必要な製品をより適切に見つけられるようにすることができます。

この記事では、PHP を使用してリアルタイム製品レコメンド機能を実装する Websocket を開発する方法と、具体的なコード例を紹介します。

1. 要件

開発を開始する前に、次の要件を満たす必要があります:

1. PHP バージョン: 5.3 以降
2. オペレーティング システム: Linux、Windows、Mac など
3. 拡張子: swoole 拡張機能 (https://www.swoole.com/) 4.3.0 以降

2. swoole をインストールしますextension

まず、swoole 拡張機能をインストールする必要があります。 swoole は、Websocket 開発用の基本クラスとイベント駆動型モデルを提供し、Websocket の開発を大幅に簡素化します。

Linux 環境では、次のコマンドを使用して swoole 拡張機能をインストールできます。

pecl install swoole

Windows 環境では、swoole 公式 Web サイト (https://windows. php.net/downloads/pecl/ releases/swoole/) 対応するバージョンの swoole 拡張機能をダウンロードし、それを php 拡張機能ディレクトリに抽出し、次の行を php.ini ファイルに追加します。

extension=swoole.so

3 . Websocket の開発

次に、Websocket の開発を開始します。まず、Websocket 接続を処理するための websocket.php ファイルを作成します。

<?php
// 创建Websocket服务器

$server = new swoole_websocket_server("0.0.0.0", 9501);

// 监听WebSocket连接打开事件

$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "WebSocket连接建立成功！
";
});

// 监听WebSocket消息事件

$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "WebSocket收到消息：{$frame->data}
";

    // 处理推荐商品逻辑
    // ...

    // 返回推荐商品列表
    $server->push($frame->fd, json_encode([
        ['name' => '商品1', 'price' => 10],
        ['name' => '商品2', 'price' => 20],
        ['name' => '商品3', 'price' => 30],
    ]));
});

// 监听WebSocket连接关闭事件

$server->on('close', function ($server, $fd) {
    echo "WebSocket连接关闭！
";
});

// 启动Websocket服务器

$server->start();

上記のコードは、Websocket サーバーを作成し、クライアントからの接続要求を監視し、接続の確立の成功、メッセージの受信、接続の終了などのイベントが発生したときに、対応するコールバック関数をトリガーします。

受信したメッセージ イベントで、製品の推奨ロジックを記述し、推奨結果をクライアントに返すことができます。

4. クライアントは Websocket を使用します

クライアントでは、JavaScript を使用して Websocket 接続を作成し、推奨製品を取得するためのメッセージを送信する必要があります。

// 创建Websocket连接
var ws = new WebSocket("ws://127.0.0.1:9501");

// 监听Websocket连接打开事件
ws.onopen = function() {
    console.log("Websocket连接建立成功！");

    // 发送消息
    ws.send("Hello, Server!");
};

// 监听Websocket消息事件
ws.onmessage = function(event) {
    var data = JSON.parse(event.data);
    console.log("推荐商品列表：", data);
};

// 监听Websocket连接关闭事件
ws.onclose = function() {
    console.log("Websocket连接关闭！");
};

上記のコードでは、WebSocket 接続を作成し、接続開始イベント、メッセージ イベント、および接続終了イベントをリッスンし、接続が正常に確立された後にメッセージを送信して推奨製品を取得します。

5. まとめ

この記事では、リアルタイム商品レコメンド機能を実現するための Websocket を PHP を使って開発する方法と、具体的なコード実装について紹介します。

Websocket を通じて、リアルタイムの通信とデータ交換を実現し、電子商取引 Web サイトのユーザーにより良いサービスを提供できます。同時に、Websocket はオンライン ゲームやビデオ会議などの他の分野でも使用できます。

以上がphpを使用してWebsocketを開発し、リアルタイム商品レコメンド機能を実装するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。