
本文旨在指导开发者如何在使用 Node.js 和 Express 框架时,正确地处理 POST 请求接收到的数据,并将其传递到另一个函数中进行进一步处理。我们将重点关注服务器端的数据接收和处理,以及客户端如何通过 AJAX 请求获取处理后的数据,并最终在前端页面动态构建内容。
首先,确保你的 Express 应用正确配置了中间件,以便能够解析 POST 请求体中的数据。常用的中间件包括 express.json() 和 express.urlencoded({ extended: true })。
const express = require('express');
const http = require('http');
const app = express();
// 添加中间件以解析 JSON 格式的请求体
app.use(express.json());
// 添加中间件以解析 URL 编码格式的请求体
app.use(express.urlencoded({ extended: true }));
app.post("/movies", function (req, res) {
const imdbIDs = req.body;
if (!Array.isArray(imdbIDs)) {
return res.status(400).send("Invalid input: imdbIDs must be an array.");
}
const apiKey = 'YOUR_API_KEY'; // 替换为你的OMDb API密钥
const movies = [];
let completedRequests = 0; // 用于跟踪已完成的请求数量
if (imdbIDs.length === 0) {
return res.status(200).send(movies); // 如果imdbIDs为空,直接返回空数组
}
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).send(movies);
}
}
});
}).on('error', (error) => {
console.error('Error fetching movie data:', error);
completedRequests++;
if (completedRequests === imdbIDs.length) {
// 即使有错误,也发送响应
res.status(200).send(movies);
}
});
});
});
app.listen(3000, () => {
console.log('Server listening on port 3000');
});关键改进:
注意事项:
在前端,使用 XMLHttpRequest 或 fetch API 向 /movies 发送 POST 请求,并将选中的电影 ID 作为请求体发送。然后,处理服务器返回的电影数据,动态构建 HTML 元素。
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");
// 清空 main 元素
while (mainElement.firstChild) {
mainElement.firstChild.remove();
}
if (xhr.status === 200) {
try {
const movies = JSON.parse(xhr.responseText);
movies.forEach(movie => {
// 使用 MovieBuilder 构建电影元素,并添加到 main 元素
const movieElement = new MovieBuilder(movie, deleteMovie).build(); // 假设 MovieBuilder 有 build 方法
mainElement.appendChild(movieElement);
});
} catch (error) {
console.error("Error parsing JSON:", error);
mainElement.textContent = "Error parsing movie data.";
}
} else {
mainElement.textContent = `Data could not be loaded, status ${xhr.status} - ${xhr.statusText}`;
}
};
xhr.onerror = function () {
const mainElement = document.querySelector("main");
mainElement.textContent = "Network error occurred.";
};
xhr.send(JSON.stringify(imdbIDs)); // 发送 JSON 字符串
}
// 示例:假设有一个表单,用户选择了一些电影的 imdbID
document.getElementById("movieForm").addEventListener("submit", function (event) {
event.preventDefault(); // 阻止默认的表单提交
const selectedMovies = [];
const checkboxes = document.querySelectorAll('input[name="movie"]:checked'); // 假设checkbox的name是movie
checkboxes.forEach(checkbox => {
selectedMovies.push(checkbox.value); // 获取选中的 imdbID
});
loadMovies(selectedMovies); // 调用 loadMovies 函数,传递选中的 imdbID 数组
});
// 假设的 MovieBuilder 类 (需要根据你的实际代码调整)
class MovieBuilder {
constructor(movie, deleteMovieCallback) {
this.movie = movie;
this.deleteMovieCallback = deleteMovieCallback;
}
build() {
const movieElement = document.createElement('div');
movieElement.classList.add('movie');
// 添加电影信息到元素 (根据你的数据结构调整)
const titleElement = document.createElement('h2');
titleElement.textContent = this.movie.Title || 'Untitled';
movieElement.appendChild(titleElement);
const releasedElement = document.createElement('p');
releasedElement.textContent = `Released: ${this.movie.Released || 'N/A'}`;
movieElement.appendChild(releasedElement);
// 其他电影信息的添加...
return movieElement;
}
}关键改进:
注意事项:
本教程详细介绍了如何使用 Node.js/Express 处理 POST 请求,并将数据传递到另一个函数中进行处理。通过合理地组织代码,并注意错误处理和异步处理,可以构建一个高效且稳定的应用。
以上就是使用 Node.js/Express 处理 POST 请求数据并在另一函数中应用的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号