使用php开发Websocket，实现实时商品推荐功能

pecl install swoole

extension=swoole.so

<?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连接
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连接关闭！");
};