本文旨在解决在使用 Promise.all() 方法处理异步数据时，如何正确地返回包含多个对象（特别是嵌套对象）的聚合结果。重点在于理解 Promise 的异步特性，以及如何在 map 函数中使用 async/await 确保所有 Promise 都被解析后再返回最终结果。通过本文的学习，你将能够避免返回空对象，并有效地处理和整合异步获取的数据。
在使用 Promise.all() 方法处理异步操作时，经常会遇到需要将多个异步请求的结果合并成一个包含嵌套对象的结构返回。一个常见的错误是，在 Promise.all() 内部的 map 函数中，直接返回一个包含 Promise 对象的对象，导致最终返回的是一个包含未解析 Promise 的对象，序列化后表现为空对象。 解决这个问题，需要理解 async/await 的作用，并确保在返回之前等待所有的 Promise 完成。
解决方案：使用 async/await 等待 Promise 解析
问题的根源在于 Promise 的异步性。当你在 map 函数中调用 users.findOne() 时，它返回的是一个 Promise 对象，而不是实际的数据。如果直接将这个 Promise 对象放到返回的对象中，Promise.all() 会立即返回，而不会等待 Promise 被解析。
要解决这个问题，需要在 map 函数中使用 async 关键字，并在调用 users.findOne() 之后使用 await 关键字等待 Promise 解析完成。
以下是修改后的代码示例：
import users from "@/models/users";
import { NextResponse } from "next/server";
import bcrypt from "bcryptjs";
import dbConnect from "@/util/mongodb";
export async function GET(req, { params }) {
await dbConnect();
try {
const data = await users.findOne({ username: params.id }, { pin: 0 });
const history = await Promise.all(
data.history.map(async (user) => {
const us = await users.findOne(
{ _id: user.id },
{ firstname: 1, username: 1, lastname: 1 }
);
return { user: us, amount: user.amount };
})
);
return NextResponse.json(history, { status: 200 });
} catch (err) {
return NextResponse.json(err, { status: 500 });
}
}在这个修改后的代码中，map 函数被标记为 async，并且在 users.findOne() 调用之前添加了 await 关键字。这确保了在将 user 对象添加到返回的对象之前，users.findOne() 返回的 Promise 已经被解析。
示例说明
假设 data.history 包含以下数据：
[
{ "id": "user1", "amount": 100 },
{ "id": "user2", "amount": 200 }
]并且 users.findOne() 方法能够根据 id 找到对应的用户信息。那么，修改后的代码将会返回类似以下的数据结构：
[
{
"user": { "firstname": "John", "username": "john_doe", "lastname": "Doe" },
"amount": 100
},
{
"user": { "firstname": "Jane", "username": "jane_doe", "lastname": "Doe" },
"amount": 200
}
]注意事项
- 错误处理: 在 async 函数中，建议使用 try...catch 块来处理可能发生的错误。
- 性能考虑: Promise.all() 并发执行 Promise，如果 Promise 数量过多，可能会对性能产生影响。可以考虑使用 Promise.all() 的分片处理或使用 async/await 配合循环来串行执行。
- 数据库连接: 确保数据库连接正确建立，并且在操作完成后及时关闭连接，避免资源泄露。
总结
使用 Promise.all() 处理异步数据时，理解 Promise 的异步特性至关重要。通过在 map 函数中使用 async/await，可以确保所有的 Promise 都被解析后再返回最终结果，从而避免返回包含未解析 Promise 的对象。 同时，需要注意错误处理和性能优化，以确保代码的健壮性和高效性。
