本文介绍了如何在 Node.js/Express 应用中接收 POST 请求发送的数据，并将其传递到另一个函数进行进一步处理。重点在于确保请求方法匹配，并正确地在客户端和服务器端处理数据传输。文章将提供示例代码，帮助你理解如何实现数据的接收、传递和使用。
理解 POST 请求的数据处理流程
在 Node.js/Express 应用中，处理 POST 请求并将其数据传递到另一个函数，需要理解以下几个关键步骤：
- 接收 POST 请求: 使用 app.post() 方法在 Express 中定义一个路由来处理 POST 请求。
- 解析请求体: 使用 req.body 访问 POST 请求体中的数据。通常需要使用 body-parser 中间件来解析请求体，使其成为可用的 JavaScript 对象。
- 数据处理: 在路由处理函数中，对接收到的数据进行必要的处理。
- 数据传递: 将处理后的数据传递给另一个函数进行进一步处理。
- 发送响应: 使用 res.send() 或 res.json() 方法将结果发送回客户端。
示例代码：接收 POST 请求并处理数据
以下是一个示例，展示了如何在 server.js 文件中接收 POST 请求，并处理数据：
const express = require('express');
const bodyParser = require('body-parser');
const http = require('http');
const app = express();
const port = 3000;
// 使用 body-parser 中间件解析请求体
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.post("/movies", function (req, res) {
const imdbIDs = req.body;
if (!Array.isArray(imdbIDs)) {
res.status(400).send('Invalid input. Expected an array of imdbIDs.');
return;
}
const apiKEY = 'YOUR_API_KEY'; // 替换为你的 API 密钥
const movies = [];
let completedRequests = 0;
imdbIDs.forEach((imdbID, index) => {
const apiUrl = `http://www.omdbapi.com/?&apikey=${apiKEY}&i=${imdbID}`;
http.get(apiUrl, (response) => {
let responseData = '';
response.on('data', (chunk) => {
responseData += chunk;
});
response.on('end', () => {
try {
const movieData = JSON.parse(responseData);
if (movieData.Response === 'True') {
const movie = {
Released: movieData.Released !== 'N/A' ? new Date(movieData.Released).toISOString() : null,
Runtime: movieData.Runtime !== 'N/A' ? parseInt(movieData.Runtime) : null,
Genres: movieData.Genre ? movieData.Genre.split(',').map(genre => genre.trim()) : [],
Directors: movieData.Director ? movieData.Director.split(',').map(director => director.trim()) : [],
Writers: movieData.Writer ? movieData.Writer.split(',').map(writer => writer.trim()) : [],
Actors: movieData.Actors ? movieData.Actors.split(',').map(actor => actor.trim()) : [],
MetaScore: movieData.Metascore !== 'N/A' ? parseInt(movieData.Metascore) : null,
imdbRating: movieData.imdbRating !== 'N/A' ? Number(movieData.imdbRating) : null
};
movies.push(movie);
} else {
console.error(`Error retrieving movie with imdbID ${imdbID}: ${movieData.Error}`);
}
} catch (error) {
console.error('Error parsing movie data:', error);
} finally {
completedRequests++;
if (completedRequests === imdbIDs.length) {
// 所有请求完成后发送响应
res.status(200).json(movies);
}
}
});
}).on('error', (error) => {
console.error('Error fetching movie data:', error);
completedRequests++;
if (completedRequests === imdbIDs.length) {
// 即使有错误，也在所有请求完成后发送响应
res.status(200).json(movies);
}
});
});
});
app.listen(port, () => {
console.log(`Server listening at http://localhost:${port}`);
});代码解释:
- bodyParser.urlencoded({ extended: true }) 和 bodyParser.json() 用于解析 Content-Type 为 application/x-www-form-urlencoded 和 application/json 的请求体。
- req.body 包含了 POST 请求发送的数据。
- 代码遍历 imdbIDs 数组，为每个 ID 发起一个 HTTP 请求。
- 使用 completedRequests 变量来跟踪已完成的请求数量，以确保在所有请求完成后发送响应。
- res.status(200).json(movies) 将包含电影数据的数组作为 JSON 响应发送回客户端。
客户端代码：发送 POST 请求并处理响应
以下是一个示例，展示了如何在 index.js 文件中发送 POST 请求，并处理服务器的响应：
function loadMovies(imdbIDs) {
const xhr = new XMLHttpRequest();
xhr.open("POST", "/movies");
xhr.setRequestHeader("Content-Type", "application/json"); // 设置请求头
xhr.onload = function () {
const mainElement = document.querySelector("main");
while (mainElement.childElementCount > 0) {
mainElement.firstChild.remove()
}
if (xhr.status === 200) {
JSON.parse(xhr.responseText)
.forEach(movie => {
// 这里可以调用 MovieBuilder，或者直接操作 DOM
console.log(movie); // 打印接收到的电影数据
//new MovieBuilder(movie, deleteMovie).appendTo(mainElement)
});
} else {
mainElement.append(`Data could not be loaded, status ${xhr.status} - ${xhr.statusText}`);
}
}
xhr.onerror = function() {
console.error("Request failed");
}
xhr.send(JSON.stringify(imdbIDs)); // 将数据转换为 JSON 字符串并发送
}
// 示例调用
const movieIds = ["tt0076759", "tt0080684", "tt0086190"]; // 示例 IMDB ID
loadMovies(movieIds);代码解释:
- xhr.open("POST", "/movies") 指定了请求方法为 POST，以及请求的 URL。
- xhr.setRequestHeader("Content-Type", "application/json") 设置了请求头，告知服务器发送的数据是 JSON 格式。
- xhr.send(JSON.stringify(imdbIDs)) 将 JavaScript 数组 imdbIDs 转换为 JSON 字符串，并作为请求体发送到服务器。
- xhr.responseText 包含了服务器返回的 JSON 字符串。
- JSON.parse(xhr.responseText) 将 JSON 字符串解析为 JavaScript 对象，以便进一步处理。
注意事项
- 请求方法匹配: 确保客户端和服务器端使用的请求方法一致（POST 或 GET）。
- Content-Type: 设置正确的 Content-Type 请求头，告知服务器请求体的格式。
- 错误处理: 在客户端和服务器端都进行适当的错误处理，以提高应用的健壮性。
- 异步处理: 由于 HTTP 请求是异步的，需要使用回调函数或 Promise 来处理响应。
- 中间件: 使用 body-parser 中间件来解析请求体。
总结
通过本文，你应该能够理解如何在 Node.js/Express 应用中接收 POST 请求发送的数据，并将其传递到另一个函数进行进一步处理。 关键在于正确设置请求方法和 Content-Type，以及使用 body-parser 中间件来解析请求体。 此外，良好的错误处理和异步处理也是必不可少的。 记住，客户端和服务端都需要正确地处理数据格式，才能保证数据传输的正确性。
