为何无法接收FCGI_END_REQUEST记录？Rust代码调试求助

核心错误点分析 #

1. 字节序未正确转换 #

FastCGI协议所有多字节字段（版本、类型、请求ID、内容长度等）都采用大端字节序，如果解析时直接用主机字节序读取，会导致记录类型、长度等字段值完全错误，出现45、111这类诡异的类型值。

2. 未按完整FastCGI记录读取 #

Unix套接字是流协议，读取时可能返回不完整的记录片段。如果直接把不完整的字节流当成完整的FastCGI头部解析，会把数据内容误判为头部字段，导致后续解析完全混乱。

3. 循环逻辑未区分记录类型 #

php-fpm的响应会包含多个记录：FCGI_STDOUT（输出内容）、FCGI_STDERR（错误信息）、最后才是FCGI_END_REQUEST。如果循环时没先处理STDOUT/STDERR，直接判断是否为END_REQUEST，会把输出内容当成未知记录类型。

修正后的代码示例 #

下面是修复后的核心逻辑，包含正确的字节序处理、完整记录读取、多类型记录处理：

use std::os::unix::net::UnixStream;
use std::io::{Read, Write};

// 定义FastCGI常量（注意类型值必须正确）
const FCGI_VERSION_1: u8 = 1;
const FCGI_STDOUT: u8 = 6;
const FCGI_STDERR: u8 = 7;
const FCGI_END_REQUEST: u8 = 3;

#[derive(Debug)]
struct FcgiHeader {
    version: u8,
    type_: u8,
    request_id: u16,
    content_length: u16,
    padding_length: u8,
    reserved: u8,
}

impl FcgiHeader {
    // 从字节流解析FastCGI头部，处理大端字节序
    fn from_bytes(bytes: &[u8]) -> Result<Self, &'static str> {
        if bytes.len() < 8 {
            return Err("Insufficient bytes for FCGI header");
        }
        Ok(Self {
            version: bytes[0],
            type_: bytes[1],
            request_id: u16::from_be_bytes([bytes[2], bytes[3]]),
            content_length: u16::from_be_bytes([bytes[4], bytes[5]]),
            padding_length: bytes[6],
            reserved: bytes[7],
        })
    }
}

fn main() -> std::io::Result<()> {
    // 连接php-fpm的Unix套接字（路径根据你的配置调整）
    let mut stream = UnixStream::connect("/run/php-fpm/www.sock")?;

    // 发送FastCGI请求（这里省略请求构造，假设你原代码的请求发送是正确的）
    // ... 原请求发送代码 ...

    let mut buffer = [0u8; 4096];

    loop {
        // 先读取完整的FastCGI头部（8字节）
        let header_bytes = match stream.read_exact(&mut buffer[0..8]) {
            Ok(_) => &buffer[0..8],
            Err(e) if e.kind() == std::io::ErrorKind::UnexpectedEof => break,
            Err(e) => return Err(e),
        };

        let header = FcgiHeader::from_bytes(header_bytes).unwrap();

        // 验证版本和请求ID（根据你的请求ID调整，这里假设是1）
        if header.version != FCGI_VERSION_1 || header.request_id != 1 {
            eprintln!("Invalid FCGI version or request ID");
            break;
        }

        // 读取内容部分
        let content_len = header.content_length as usize;
        let padding_len = header.padding_length as usize;
        stream.read_exact(&mut buffer[8..8+content_len])?;

        // 处理不同类型的记录
        match header.type_ {
            FCGI_STDOUT => {
                // 输出STDOUT内容，跳过空记录（空STDOUT表示输出结束）
                if content_len > 0 {
                    print!("{}", String::from_utf8_lossy(&buffer[8..8+content_len]));
                }
            }
            FCGI_STDERR => {
                eprintln!("PHP Error: {}", String::from_utf8_lossy(&buffer[8..8+content_len]));
            }
            FCGI_END_REQUEST => {
                // 解析FCGI_END_REQUEST内容，确认请求状态
                let app_status = u32::from_be_bytes([buffer[8], buffer[9], buffer[10], buffer[11]]);
                let protocol_status = buffer[12];
                eprintln!("\nRequest ended. App status: {}, Protocol status: {}", app_status, protocol_status);
                break;
            }
            _ => {
                eprintln!("Unknown FCGI record type: {}", header.type_);
            }
        }

        // 跳过填充字节
        if padding_len > 0 {
            stream.read_exact(&mut buffer[8+content_len..8+content_len+padding_len])?;
        }
    }

    Ok(())
}

关键修复说明 #

1. 强制读取完整头部：每次循环先读取8字节的完整FastCGI头部，避免解析不完整的字节流。
2. 大端字节序转换：用u16::from_be_bytes和u32::from_be_bytes处理多字节字段，确保解析值符合FastCGI协议要求。
3. 分类型处理记录：先处理FCGI_STDOUT和FCGI_STDERR，直到遇到FCGI_END_REQUEST才终止循环，避免把输出内容误判为未知记录。
4. 处理空STDOUT记录：php-fpm会发送一个空的STDOUT标记输出结束，这时候不需要输出内容。

内容的提问来源于stack exchange，提问作者DFG