Nodejs中的回调函数+异步？

Nodejs中的回调函数+异步？

刚开始接触nodejs，对于nodejs中的函数返回值没弄明白~~ 假设 A是从文件中读取数据 B从数据库读出数据 C把A、B得到的数据整合进行过滤 D过滤过的数据写入数据库， 是用callback返回A的数据，然后再依次传下去么…… 现在用的async的waterfall来写的，可以直接传递，但是感觉这样就是顺序执行的，但是A和B又是并发执行的。对于nodejs中一个函数调用另一个函数的返回值，是不是用callback呢？

7 回复

当然可以！你提到的问题涉及到了Node.js中的异步编程和回调函数。让我们详细探讨一下这个问题，并通过一些示例代码来说明。

回调函数与异步编程

在Node.js中，很多操作都是异步的，比如文件读取、数据库查询等。为了处理这些异步操作的结果，我们通常使用回调函数。回调函数是在某个操作完成时被调用的函数，它接收操作的结果作为参数。

示例代码

假设你有以下任务：

  1. 从文件中读取数据（A）。
  2. 从数据库中读取数据（B）。
  3. 将两个数据集合并并进行过滤（C）。
  4. 将过滤后的数据写入数据库（D）。

我们可以使用回调函数来处理这些异步操作：

const fs = require('fs');
const db = require('./db'); // 假设这是你的数据库模块

// 从文件中读取数据
function readFile(callback) {
    fs.readFile('data.txt', 'utf8', (err, data) => {
        if (err) return callback(err);
        callback(null, data);
    });
}

// 从数据库中读取数据
function readDatabase(callback) {
    db.query('SELECT * FROM table', (err, data) => {
        if (err) return callback(err);
        callback(null, data);
    });
}

// 合并并过滤数据
function processAndFilter(fileData, dbData, callback) {
    const combinedData = fileData.concat(dbData); // 假设这里只是简单地合并数据
    const filteredData = combinedData.filter(item => item.someProperty === 'someValue'); // 进行过滤
    callback(null, filteredData);
}

// 将过滤后的数据写入数据库
function writeDataToDatabase(filteredData, callback) {
    db.insertMany(filteredData, (err) => {
        if (err) return callback(err);
        callback(null);
    });
}

// 主流程
function main() {
    readFile((err, fileData) => {
        if (err) return console.error(err);

        readDatabase((err, dbData) => {
            if (err) return console.error(err);

            processAndFilter(fileData, dbData, (err, filteredData) => {
                if (err) return console.error(err);

                writeDataToDatabase(filteredData, (err) => {
                    if (err) return console.error(err);
                    console.log('数据处理完成');
                });
            });
        });
    });
}

main();

解释

  1. readFile: 读取文件内容，并将结果通过回调函数传递给下一个步骤。
  2. readDatabase: 查询数据库内容，并将结果通过回调函数传递给下一个步骤。
  3. processAndFilter: 接收文件和数据库的数据，进行合并和过滤，并将结果通过回调函数传递给下一个步骤。
  4. writeDataToDatabase: 将过滤后的数据写入数据库，并通过回调函数通知完成情况。
  5. main: 这是主流程函数，它按顺序调用上述函数，并通过回调函数传递数据。

这种方式虽然简单，但当处理多个异步操作时可能会导致回调地狱（Callback Hell）。为了解决这个问题，可以考虑使用Promise或async/await语法来简化代码。


嗯，就是通过callback的值不断往下传对吧，你给的书中没看到相关内容 现在有下面这种情况， async.auto({ func1: function (callback, results) { callback(null, “abc”, “bbc”); },

func2: function (callback, results) { 
    console.log("Print#1:\n" + util.inspect(results)); 
    callback(null, { "puncha": "during" }); 
}, 
func3: ["func2", function (callback, results) { 
    //调用2的返回值…………
    //判断是否符合条件，再从头执行fun1、fun2、fun3
    callback(null, 3); 
}]

});
在fun3中“//判断是否符合条件，再从头执行fun1、fun2、fun3”，这个应该怎么来写呢，一直纠结在这个循环上，不知道怎么写，没有思路，谢谢啦

这种情况用 async.parallel

async.parallel([ function(callback){ setTimeout(function(){ callback(null, ‘one’); }, 200); }, function(callback){ setTimeout(function(){ callback(null, ‘two’); }, 100); } ], // optional callback function(err, results){ // the results array will equal [‘one’,‘two’] even though // the second function had a shorter timeout. });

https://github.com/caolan/async#parallel

除了async，你也可以选用eventproxy，学习成本低很多，代码可读性在你这个功能的实现上，相对也高一些。

用async.auto也可以吧，现在用的async.auto. 然后有下面这种情况， async.auto({ func1: function (callback, results) { callback(null, “abc”, “bbc”); },

func2: function (callback, results) { console.log(“Print#1:\n” + util.inspect(results)); callback(null, { “puncha”: “during” }); }, func3: [“func2”, function (callback, results) { //调用2的返回值………… //判断是否符合条件，再从头执行fun1、fun2、fun3 callback(null, 3); }] }); 在fun3中“//判断是否符合条件，再从头执行fun1、fun2、fun3”，这个应该怎么来写呢，一直纠结在这个循环上，不知道怎么写，没有思路，能不能说一下思路，谢谢啦

看大多数用的是async，所以在学习这个

在 Node.js 中，处理异步操作通常依赖于回调函数。你提到的场景涉及文件读取、数据库读取、数据处理以及数据写入等异步操作。使用回调函数可以确保这些操作按顺序完成，同时处理异步并发问题。

以下是一个简单的示例，展示如何使用回调函数实现你的需求：

示例代码

const fs = require('fs');
const { Client } = require('pg'); // 假设使用 PostgreSQL 数据库

// A: 从文件中读取数据
function readFile(filePath, callback) {
    fs.readFile(filePath, 'utf8', (err, data) => {
        if (err) return callback(err);
        callback(null, data);
    });
}

// B: 从数据库读取数据
function readDatabase(client, callback) {
    client.query('SELECT * FROM my_table', (err, res) => {
        if (err) return callback(err);
        callback(null, res.rows);
    });
}

// C: 数据整合和过滤
function processData(fileData, dbData, callback) {
    const combinedData = fileData + dbData; // 假设简单的字符串拼接
    const filteredData = combinedData.filter(item => item.someProperty === 'someValue'); // 假设过滤条件
    callback(null, filteredData);
}

// D: 将过滤后的数据写入数据库
function writeDatabase(filteredData, client, callback) {
    const values = filteredData.map(item => [item.someColumn]);
    client.query('INSERT INTO my_table(some_column) VALUES($1)', values, err => {
        if (err) return callback(err);
        callback(null, 'Data written successfully');
    });
}

// 主逻辑
const client = new Client({ connectionString: 'postgresql://user:password@localhost:5432/mydb' });
client.connect();

readFile('path/to/file.txt', (err, fileData) => {
    if (err) return console.error(err);

    readDatabase(client, (err, dbData) => {
        if (err) return console.error(err);

        processData(fileData, dbData, (err, filteredData) => {
            if (err) return console.error(err);

            writeDatabase(filteredData, client, (err, result) => {
                if (err) return console.error(err);
                console.log(result);
                client.end();
            });
        });
    });
});

解释

  1. A 和 B 操作：readFile 和 readDatabase 函数都是异步操作，它们分别从文件系统和数据库读取数据。当读取完成后，会通过回调函数将结果传递给下一个步骤。
  2. C 操作：processData 函数接收两个参数（来自 A 和 B 的数据），进行数据整合和过滤，并将结果通过回调函数传递给下一步。
  3. D 操作：writeDatabase 函数接收过滤后的数据，并将其写入数据库。同样，它通过回调函数通知最终的操作完成情况。
  4. 主逻辑：在主逻辑中，我们首先连接到数据库，然后依次调用各个异步函数，并通过回调函数确保每个操作都成功完成后再继续下一步。

这种方法虽然有些繁琐，但它能有效地处理异步操作，确保每个步骤都能按预期顺序执行。

回到顶部