如何解决NodeJS调用AWS S3异步回调导致HTTP响应提前结束问题

嘿，你碰到的这个问题其实是Node.js里异步操作的经典坑——s3.listObjects是异步执行的，它会在后台发起S3请求，而你的response.write(str)和response.end()会立刻执行，这时候str还没被填充，所以返回的是空内容。我给你两种修复方案，都能解决这个问题：

方案1：把响应逻辑移到异步回调里 #

最直接的做法是，只有等S3请求完成、拿到数据之后，再生成并发送HTTP响应。修改后的代码如下：

var AWS = require('aws-sdk'); 
var http = require("http"); 

function onRequest(request, response) { 
    response.writeHead(200, { 'Content-Type': 'application/json' }); 
    
    var credentials = new AWS.SharedIniFileCredentials(); 
    AWS.config.credentials = credentials; 
    AWS.config.logger = console; 
    
    var s3 = new AWS.S3(); 
    var params = { 
        Bucket: 'bucketname', 
        Delimiter: '/', 
        Prefix: 'path/to/the/folder' 
    }; 

    s3.listObjects(params, function(err, data) { 
        // 先处理错误情况，避免服务器挂起
        if (err) {
            response.writeHead(500, { 'Content-Type': 'application/json' });
            response.end(JSON.stringify({ error: err.message }));
            console.error("S3 request failed:", err);
            return;
        }

        var str = "";
        for (var i = 0; i < data.Contents.length; i++) { 
            var tokens = data.Contents[i].Key.split("/"); 
            str += tokens[tokens.length - 1]; 
            // 修正原代码的逗号判断：只有不是最后一个元素时才加逗号
            if (i !== data.Contents.length - 1) {
                str += ","; 
            } 
        } 
        console.log("Final text:" + str); 
        response.write(str); 
        response.end(); 
    }); 
} 

http.createServer(onRequest).listen(8081); 
console.log('Server running at http://127.0.0.1:8081/');

关键改动： #

• 把str的初始化和数据填充逻辑移到了listObjects的回调内部，确保只有拿到S3数据后才生成响应内容
• 增加了错误处理：如果S3请求失败，返回500状态码和错误信息，避免请求一直挂着
• 修复了原代码里的逗号拼接错误：原代码会给最后一个文件名也加逗号，现在改成只给前n-1个元素加逗号

方案2：用Async/Await写更清晰的代码 #

现在AWS SDK支持将异步方法转换为Promise，你可以用async/await语法让代码看起来更像“同步”逻辑，可读性更强：

const AWS = require('aws-sdk'); 
const http = require("http"); 

// 将请求处理函数标记为async
async function onRequest(request, response) { 
    try {
        const credentials = new AWS.SharedIniFileCredentials(); 
        AWS.config.credentials = credentials; 
        AWS.config.logger = console; 

        const s3 = new AWS.S3(); 
        const params = { 
            Bucket: 'bucketname', 
            Delimiter: '/', 
            Prefix: 'path/to/the/folder' 
        }; 

        // 用await等待S3请求完成，拿到数据
        const data = await s3.listObjects(params).promise();
        
        // 用map和join简化文件名拼接逻辑
        const filenames = data.Contents.map(item => {
            const tokens = item.Key.split("/");
            return tokens[tokens.length - 1];
        });
        const str = filenames.join(",");
        
        console.log("Final text:" + str); 
        response.writeHead(200, { 'Content-Type': 'application/json' });
        response.write(str); 
        response.end(); 
    } catch (err) {
        // 统一捕获所有同步/异步错误
        console.error("Error fetching S3 objects:", err);
        response.writeHead(500, { 'Content-Type': 'application/json' });
        response.end(JSON.stringify({ error: err.message }));
    }
} 

http.createServer(onRequest).listen(8081); 
console.log('Server running at http://127.0.0.1:8081/');

这种写法的优势： #

• 代码逻辑是线性的，避免了嵌套回调的“回调地狱”
• 用try/catch统一处理所有错误，代码更健壮
• 用map和join替代手动循环拼接，代码更简洁易读

内容的提问来源于stack exchange，提问作者Vikas Thange