Nodejs做proxy时如何发送post数据

Nodejs做proxy时如何发送post数据

今天想实现一个proxy功能，官方文档里的http.request里面没发现有发送content的地方，构造request数据时都是通过head来做，请问要构造请求参数该怎么做？

4 回复

当然可以。在使用 Node.js 实现代理功能时，如果你需要向目标服务器发送 POST 数据，可以通过 http 或 https 模块中的 request 方法来完成。下面是一个简单的示例，展示了如何在代理过程中发送 POST 请求。

示例代码

const http = require('http');
const https = require('https');

function proxyRequest(req, res) {
    // 获取请求的URL和方法
    const targetUrl = req.url;
    const method = req.method;

    // 创建一个POST请求到目标服务器
    let postData = JSON.stringify({
        key: 'value'
    });

    // 设置请求头
    let headers = {
        'Content-Type': 'application/json',
        'Content-Length': Buffer.byteLength(postData)
    };

    if (method === 'POST') {
        // 根据目标URL选择使用http或https模块
        const module = targetUrl.startsWith('https') ? https : http;
        
        // 发送POST请求
        module.request(targetUrl, {
            method: 'POST',
            headers: headers
        }, (targetRes) => {
            let data = '';
            targetRes.on('data', (chunk) => {
                data += chunk;
            });

            targetRes.on('end', () => {
                res.writeHead(200, { 'Content-Type': 'application/json' });
                res.end(data);
            });
        }).on('error', (e) => {
            console.error(`Problem with request: ${e.message}`);
            res.writeHead(500, { 'Content-Type': 'text/plain' });
            res.end('Internal Server Error');
        }).write(postData);

        // 结束请求
        req.on('close', () => {
            proxyReq.abort();
        });
    } else {
        res.writeHead(405, { 'Content-Type': 'text/plain' });
        res.end('Method Not Allowed');
    }
}

// 创建HTTP服务器
const server = http.createServer((req, res) => {
    proxyRequest(req, res);
});

server.listen(3000, () => {
    console.log('Server running at http://127.0.0.1:3000/');
});

解释

  1. 引入模块：首先引入 http 和 https 模块。
  2. 定义代理函数：创建一个名为 proxyRequest 的函数，它接受两个参数：req（客户端请求）和 res（响应对象）。
  3. 获取目标URL和方法：从客户端请求中获取目标URL和方法。
  4. 构造POST数据：将POST数据转换为字符串形式。
  5. 设置请求头：根据POST数据设置请求头。
  6. 发送请求：根据目标URL选择使用 http 或 https 模块，并发起POST请求。
  7. 处理响应：监听目标服务器的响应，并将其传递回客户端。
  8. 错误处理：处理任何可能发生的错误。
  9. 启动服务器：创建一个HTTP服务器并监听端口3000。

这个示例展示了如何在代理过程中发送POST请求。你可以根据实际需求调整代码。希望这对你有所帮助！


调用http.request()的时候设置options.method=“POST”，然后这个方法会返回http.ClientRequest对象，这个对象是一个stream，可以调用这个对象的write方法来发送content。

附上官方文档里的例子：

var options = {
  hostname: 'www.google.com',
  port: 80,
  path: '/upload',
  method: 'POST'
};

var req = http.request(options, function(res) {
console.log('STATUS: ’ + res.statusCode);
console.log('HEADERS: ’ + JSON.stringify(res.headers));
res.setEncoding(‘utf8’);
res.on(‘data’, function (chunk) {
console.log('BODY: ’ + chunk);
});
});


req.on(‘error’, function(e) {
console.log('problem with request: ’ + e.message);
});


// write data to request body
req.write(‘data\n’);
req.write(‘data\n’);
req.end();

多谢

要在Node.js中实现一个代理（proxy）并发送POST数据，可以使用http模块或者更高级的http(s)_request封装库如axios或request。这里以axios为例，因为它提供了简洁且易用的API来处理HTTP请求。

示例代码

const axios = require('axios');

async function sendPostData(proxyUrl, targetUrl, postData) {
    try {
        const response = await axios.post(targetUrl, postData, {
            proxy: {
                host: new URL(proxyUrl).hostname,
                port: new URL(proxyUrl).port,
                auth: `${new URL(proxyUrl).username}:${new URL(proxyUrl).password}`
            },
            headers: {
                'Content-Type': 'application/json'
            }
        });

        console.log('Response:', response.data);
    } catch (error) {
        console.error('Error:', error.message);
    }
}

// 使用示例
sendPostData('http://your-proxy-host:port', 'http://target-server-url/api/endpoint', { key: 'value' });

解释

  1. 安装axios: 首先需要安装axios库，可以通过npm安装：

    npm install axios

  2. 定义函数: sendPostData函数接收三个参数：代理服务器的URL、目标服务器的URL以及要发送的数据。

  3. 设置代理: 在axios.post方法中通过proxy对象配置代理信息。这里我们从proxyUrl解析出代理的主机名、端口和认证信息。

  4. 发送POST请求: 使用axios.post方法发送POST请求到指定的目标URL，并携带要发送的数据和头部信息。

  5. 错误处理: 使用try...catch结构来捕获和处理可能发生的错误。

通过这种方式，你可以方便地使用Node.js中的axios库来实现一个简单的代理功能，并发送POST请求。如果你需要处理HTTPS请求，只需将axios.post替换为axios.post即可，axios会自动处理HTTPS请求。

回到顶部