php接收websocket 上传文件

要实现通过 WebSocket 接收上传的文件，需要按以下步骤操作：

1. 通过 WebSocket 建立连接。

2. 客户端将文件内容分块发送给服务端。

3. 服务端接收到文件块后，将其写入临时文件。

4. 客户端发送文件结束标志（如 EOF）。

5. 服务端接收到文件结束标志后，将临时文件保存到指定路径。

以下是 PHP 代码示例：

建立 WebSocket 连接：

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

$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "client {$request->fd} connected\n";
});

$server->on('message', function (swoole_websocket_server $server, $frame) {
    $data = json_decode($frame->data);
    if ($data->type === 'file') {
        $file = fopen('tmp.txt', 'a+');
        fwrite($file, $data->content);
        fclose($file);
    }
});

$server->on('close', function ($ser, $fd) {
    echo "client {$fd} closed\n";
});

$server->start();

客户端发送文件：

function sendFile(file, url) {
    var ws = new WebSocket(url);
    ws.onopen = function () {
        var chunkSize = 1024 * 1024; // 每次发送 1MB
        var reader = new FileReader();
        var offset = 0;
        reader.onload = function (e) {
            if (ws.readyState === WebSocket.OPEN) {
                ws.send(JSON.stringify({
                    type: 'file',
                    content: e.target.result
                }));
                offset += e.target.result.byteLength;
                if (offset < file.size) {
                    sendChunk(offset);
                } else {
                    ws.send(JSON.stringify({
                        type: 'eof'
                    }));
                }
            }
        };
        function sendChunk(offset) {
            var slice = file.slice(offset, offset + chunkSize);
            reader.readAsArrayBuffer(slice);
        }
        sendChunk(0);
    };
}

服务端接收文件：

$server->on('message', function (swoole_websocket_server $server, $frame) {
    $data = json_decode($frame->data);
    if ($data->type === 'file') {
        $file = fopen('tmp.txt', 'a+');
        fwrite($file, $data->content);
        fclose($file);
    } elseif ($data->type === 'eof') {
        $tempFile = fopen('tmp.txt', 'r');
        $realFile = fopen('real.txt', 'w');
        stream_copy_to_stream($tempFile, $realFile);
        fclose($tempFile);
        fclose($realFile);
    }
});

以上代码只是示例，实际使用时需要根据具体需求进行修改和完善。