集成Node.js与php-cgi时$_POST参数未填充问题的解决方案

// 原始的错误尝试
process.env["CONTENT_LENGTH"] = queryString.length;
process.env["CONTENT_TYPE"] = "application/x-www-form-urlencoded";
// ... 其他环境变量

// 这里的queryString只是一个局部变量，没有被传递给php-cgi的stdin
content = execSync(phpPath + "php-cgi", process.env);

// 正确的实现方式
const phpPath = './path/to/php/'; // 假设php-cgi的路径
const resource = '/path/to/your/script.php'; // PHP脚本路径
const requestMethod = 'POST'; // 或 'GET'
const queryString = 'param1=value1&param2=value2'; // GET或POST的参数字符串

// 准备环境变量
let env = {
    "GATEWAY_INTERFACE": "CGI/1.1",
    "SCRIPT_FILENAME": path.resolve(resource),
    "REQUEST_METHOD": requestMethod,
    "REDIRECT_STATUS": 200,
    // 其他根据需要设置的环境变量
};

let execOptions = { env: env };
let postData = '';

if (requestMethod === 'POST') {
    // 对于POST请求，将参数作为stdin输入
    postData = queryString; // 假设queryString就是POST请求体
    env["CONTENT_LENGTH"] = Buffer.byteLength(postData, 'utf8'); // 使用Buffer获取字节长度
    env["CONTENT_TYPE"] = "application/x-www-form-urlencoded"; // 或其他Content-Type
    execOptions.input = postData; // 关键：通过input选项传递POST数据
} else if (requestMethod === 'GET') {
    // 对于GET请求，将参数作为QUERY_STRING环境变量
    env["QUERY_STRING"] = queryString;
}

try {
    const content = execSync(phpPath + "php-cgi", execOptions);
    console.log(content.toString());
} catch (error) {
    console.error("Error executing php-cgi:", error.message);
}

const path = require('path');
const { execSync } = require('child_process');

function executePhpCgi(phpPath, resource, requestMethod, paramsString, contentType = 'application/x-www-form-urlencoded') {
    let env = {
        "GATEWAY_INTERFACE": "CGI/1.1",
        "SCRIPT_FILENAME": path.resolve(resource),
        "REQUEST_METHOD": requestMethod,
        "REDIRECT_STATUS": 200,
        // 根据实际需求添加其他CGI环境变量，例如REMOTE_ADDR, SERVER_NAME等
    };

    let execOptions = { env: env };
    let phpOutput = '';

    if (requestMethod === 'POST') {
        // 对于POST请求，数据通过stdin传递
        const postBuffer = Buffer.from(paramsString, 'utf8');
        env["CONTENT_LENGTH"] = postBuffer.byteLength;
        env["CONTENT_TYPE"] = contentType;
        execOptions.input = postBuffer; // 使用Buffer更安全地处理二进制数据
    } else if (requestMethod === 'GET') {
        // 对于GET请求，数据通过QUERY_STRING环境变量传递
        env["QUERY_STRING"] = paramsString;
    } else {
        // 其他HTTP方法，例如HEAD, PUT, DELETE等，根据需要处理
        console.warn(`Unsupported HTTP method: ${requestMethod}`);
        return '';
    }

    try {
        phpOutput = execSync(phpPath + "php-cgi", execOptions).toString();
    } catch (error) {
        console.error(`Error executing php-cgi for ${requestMethod} ${resource}:`, error.message);
        // 捕获错误，例如PHP脚本执行错误或php-cgi找不到
        // 可以根据需要抛出或返回错误信息
        phpOutput = `PHP execution failed: ${error.stderr ? error.stderr.toString() : error.message}`;
    }
    return phpOutput;
}

// 示例用法：

// 1. GET请求
const getParams = "name=Alice&age=30";
const getResult = executePhpCgi(
    'C:/php/php-8.x.x/', // 替换为你的php-cgi实际路径
    './test_get.php', // 假设存在一个test_get.php文件
    'GET',
    getParams
);
console.log("GET Request Result:\n", getResult);
// test_get.php 内容示例: <?php print_r($_GET); ?>

// 2. POST请求
const postParams = "product=Laptop&price=1200";
const postResult = executePhpCgi(
    'C:/php/php-8.x.x/', // 替换为你的php-cgi实际路径
    './test_post.php', // 假设存在一个test_post.php文件
    'POST',
    postParams
);
console.log("POST Request Result:\n", postResult);
// test_post.php 内容示例: <?php print_r($_POST); ?>

// 3. POST请求 with JSON
const jsonParams = JSON.stringify({ item: "book", quantity: 2 });
const jsonPostResult = executePhpCgi(
    'C:/php/php-8.x.x/', // 替换为你的php-cgi实际路径
    './test_json_post.php', // 假设存在一个test_json_post.php文件
    'POST',
    jsonParams,
    'application/json' // 更改Content-Type
);
console.log("JSON POST Request Result:\n", jsonPostResult);
// test_json_post.php 内容示例: <?php $data = json_decode(file_get_contents('php://input'), true); print_r($data); ?>