Swoole如何处理上传的文件-Swoole-PHP中文网

Swoole如何处理上传的文件

穿越時空

发布： 2025-09-30 12:30:02

原创

831人浏览过

Swoole处理文件上传需手动解析multipart/form-data数据。1. 启动HTTP服务器并监听POST请求；2. 通过$request->rawcontent()获取原始数据，结合$request->files获取文件元信息；3. 解析boundary分离文件内容，提取二进制流并保存至指定路径；4. 推荐使用Symfony等组件简化解析，提升安全性与开发效率。核心在于绕过PHP-FPM机制，自主处理上传流程。

swoole如何处理上传的文件

Swoole 处理上传文件的方式与传统 PHP + Nginx 模式略有不同，尤其是在使用 Swoole 的 HTTP 服务器时。由于 Swoole 是常驻内存的，不能直接依赖 PHP-FPM 的自动文件上传处理机制（如 $_FILES），需要手动解析 HTTP 请求中的 multipart/form-data 数据。以下是 Swoole 中处理文件上传的关键步骤和方法。

1. 启用 HTTP 服务器并监听请求

在 Swoole 中，你需要启动一个 HTTP 服务器，并通过 onRequest 回调接收上传请求。

示例代码：

$http = new Swoole\Http\Server("0.0.0.0", 9501);

$http->on('request', function ($request, $response) {
    if ($request->server['request_method'] == 'POST') {
        // 处理上传逻辑
        handleFileUpload($request, $response);
    } else {
        $response->header('Content-Type', 'text/html');
        $response->end('<form method="POST" enctype="multipart/form-data">
            <input type="file" name="upload_file" />
            <button type="submit">上传</button>
        </form>');
    }
});

$http->start();

登录后复制

2. 手动解析 multipart/form-data 数据

Swoole 不会自动生成 $_FILES 变量，必须从 $request-youjiankuohaophpcnrawcontent() 或 $request->getData() 中读取原始数据，并按 multipart 格式解析。

可以通过以下方式获取原始上传内容：

$request->rawcontent()：获取完整的 POST 原始数据
$request->getData()：获取已解析的表单字段（Swoole 4.4+ 支持）
$request->files：包含上传文件的元信息（如名称、大小、类型），但不包含内容

注意：$request->files 提供的是文件描述信息，实际内容仍在 body 中。

3. 将文件内容写入临时文件或指定路径

解析出文件二进制数据后，可将其保存到临时目录或目标路径。

示例：提取并保存文件

function handleFileUpload($request, $response) {
    $fileName = $request->files['upload_file']['name'] ?? '';
    $tmpName  = $request->files['upload_file']['tmp_name'] ?? ''; // 注意：Swoole 中 tmp_name 并不真实存在
    $fileData = $request->rawcontent(); // 需要从中提取文件部分

    if (!$fileName) {
        $response->end('未检测到上传文件');
        return;
    }

    // 解析 multipart 数据（简化版，建议使用专用库）
    $boundary = $request->header['content-type'];
    preg_match('/boundary=(.*)/', $boundary, $matches);
    if (!isset($matches[1])) {
        $response->end('无效的 boundary');
        return;
    }

    $parts = preg_split('/--' . preg_quote($matches[1]) . '/', $fileData);
    foreach ($parts as $part) {
        if (strpos($part, 'filename="' . $fileName . '"') !== false) {
            // 提取文件内容（跳过 header 部分）
            $lines = explode("\r\n", $part);
            $body = false;
            $fileContent = '';
            foreach ($lines as $line) {
                if ($body) {
                    $fileContent .= $line . "\r\n";
                }
                if ($line === '') {
                    $body = true;
                }
            }
            // 去除末尾的换行
            $fileContent = rtrim($fileContent, "\r\n");

            // 写入文件
            $savePath = '/tmp/' . basename($fileName);
            file_put_contents($savePath, $fileContent);
            $response->end("文件已保存至: {$savePath}");
            return;
        }
    }

    $response->end('未能提取文件内容');
}

登录后复制