当前位置：首页 > 文章列表 > 文章 > php教程 > PHP PSR-7 请求体怎样重复读取

PHP PSR-7 请求体怎样重复读取

来源：17golang原创 2026-10-14 12:45:21 0浏览收藏

我第一次在 PSR-7 中遇到“请求体第二次读取为空”，是在同一个请求里先做签名校验、再交给 JSON 解析器的时候。问题通常不在 JSON，而在于请求体是一个带游标的 StreamInterface：前一个消费者把游标读到了末尾，后一个消费者自然只能拿到剩余的空内容。

结论很简单：先取出 $request->getBody()，判断 isSeekable()；可回退就用 rewind() 或 seek(0)，不可回退就把第一次读到的字节放进新的 PSR-7 流，再通过 withBody() 交给下游。不要把每个流都当成可以无限次回到开头的字符串。

规范地址：https://www.php-fig.org/psr/psr-7/

PSR-7 的请求体为什么会读空

PSR-7 的消息对象和流对象是两层概念。getBody() 返回的是 StreamInterface，流有可读、可写、可回退等能力，并且维护当前指针位置。getContents() 读取的是“当前位置到末尾”的剩余内容，不是每次都重新读取整个请求体。

ServerRequestInterface、getBody、StreamInterface 与游标位置的 PSR-7 请求体结构说明图 — 图1：请求体与流游标的结构说明图，不是运行截图或运行证据。

因此下面两次调用的结果不同：第一次把指针推进到末尾，第二次没有剩余字节。这里的“不可重复”说的是当前流位置，不是 PSR-7 请求对象本身不可用；请求对象可以通过 withBody() 返回一个替换了流的新实例。

先分清 getContents、__toString 和 rewind

getContents() 适合读取当前剩余部分，调用后游标继续向前。rewind() 要求流可寻址，并把位置退回开头；seek(0) 表达的是同一个意图。PSR-7 还定义了 __toString()，规范要求实现尝试从开头读取完整内容，但它可能把大请求体全部放进内存，而且非可回退流不应被当成安全的缓存方案。

isReadable()) {
        throw new \RuntimeException('请求体不可读');
    }

    // 不可回退的流无法恢复已经被前一个消费者读走的字节。
    if (!$body->isSeekable()) {
        return $body->getContents();
    }

    $body->rewind();
    return $body->getContents();
}

这个函数的边界要说清楚：如果流不可回退，它只能读取“从当前游标开始的剩余部分”。想让日志、签名和业务解析都拿到完整内容，缓存动作必须发生在第一个消费者读取之前。

可回退流和不可回退流怎么选

把 isSeekable() 当成能力判断，而不是把某个具体实现的经验当成 PSR-7 保证。内存流、临时文件流通常可以寻址；网络管道、回调流或某些适配器可能只能顺序读取。

PSR-7 isSeekable、rewind、seek、php temp 与 withBody 的重复读取策略关系说明图 — 图2：重复读取策略的关系说明图，不是运行截图或运行证据。

可回退时，最小做法是把一次读取夹在两次游标定位之间：

getBody();
if (!$body->isSeekable()) {
    throw new \RuntimeException('当前请求体不能重复读取');
}

$body->rewind();
$raw = $body->getContents();

// 签名校验或日志读取结束后，把游标恢复到开头。
$body->rewind();
$requestForHandler = $request;
$payload = json_decode($raw, true, 512, JSON_THROW_ON_ERROR);

不可回退时，不要调用一个注定失败的 rewind()。在第一个读取点把原始字节复制到 php://temp 或库提供的内存/临时文件流，再把这个新流放回消息对象。

getBody();
    if (!$body->isReadable()) {
        throw new \RuntimeException('请求体不可读');
    }

    // 该函数应放在第一个消费者之前；不可回退时只能保存尚未读取的内容。
    $raw = $body->getContents();
    $replacement = Utils::streamFor($raw);

    // withBody() 返回新消息，后续中间件必须继续使用这个返回值。
    return [$request->withBody($replacement), $raw];
}

这里的 Utils::streamFor() 是 Guzzle PSR-7 的工厂示例；如果项目使用 Nyholm、Laminas 或其他实现，应换成对应的 StreamFactory。关键不是工厂名称，而是把缓存后的字节重新包装成真正的 StreamInterface。