發送響應後異步函數無法正確執行

Question

我寫了一個名爲deploy.js的文件，它通過它的API將文件夾的所有文件上傳到github。它需要兩個參數 - 您想要上傳的用戶和文件夾的accessToken。我通過passport-github獲得訪問令牌。我有一個主要的app.js文件，deploy.js可以通過變量deploy獲得。 App.js有一個路由/what，它調用了部署功能。問題是下面的代碼有效。

app.get('/what', function(req, res) { 
     //req.user.token contains the oauth token of the user 
     deploy(req.user.token, folder, function() { 
      res.send("completed"); 
     }); 
    }); 

但如果我把回調res.send()之外，它並沒有完全執行。

app.get('/what', function(req, res) { 
     deploy(req.user.token, folder, function() { 
      console.log("deploy completed"); 
     }); 
     res.send("Work being done"); 
    }) 

這是我寫的deploy.js文件。我已經使用了npm-github圖書館爲節點封裝本地github API.

var distHelper = require('./dist.js'); 
var fs = require('fs'); 
var path = require('path'); 
var github = require('github'); 
var gh = new github(); 

module.exports = function(accessToken, folder, callback) { 
    //Authenticating using the oauth accessToken received above 
    gh.authenticate({ type:"oauth", token: accessToken}); 

    var fullPath = distHelper.distPath + "/" + folder; 
    var eventName = folder.substr(folder.search("/") + 1); 

    //the below function returns a list of all files in a directory recursively 
    var walk = function(dir, done) { 
     var results = []; 
     fs.readdir(dir, function(err, list) { 
      if (err) return done(err); 
      var i = 0; 

      (function next() { 
       var file = list[i++]; 
       if (!file) return done(null, results); 
       file = dir + '/' + file; 
       fs.stat(file, function(err, stat) { 
        if (stat && stat.isDirectory()) { 
         walk(file, function(err, res) { 
          results = results.concat(res); 
          next(); 
         }); 
        } else { 
         results.push(file); 
         next(); 
        } 
       }); 
      })(); 
     }); 
    }; 
    //creating a repo 

    gh.repos.create({name: 'b', auto_init: 1}, function(err, response) { 
     if(err) { 
      console.log(err); 
     } 

     walk(fullPath, function(err, results) { 
      if(err) { 
       console.log(err); 
      } 

      //Base64 encoding of a file 
      function encode(file) { 
       var bitmap = fs.readFileSync(file); 
       return new Buffer(bitmap).toString('base64'); 
      } 

      //Function which uploads file to the github one by one 
      function doOne() { 
       var elem = results.shift(); 
       var fileName = elem.substr(elem.search(eventName)+eventName.length + 1); 
       console.log(fileName); 
       gh.repos.createFile({owner: "princu7", repo: "b", path: fileName, message: "please work", content:encode(elem)}, function(err, res) { 
        if(err) { 
         console.log(err); 
        } 
        else { 
         console.log("got response"); 
        } 
        if(results.length > 0) { 
         doOne(); 
        } 
        else { 
         // when all files are finished uploading, then the below function is called 
         callback(); 
        } 
       }); 
      } 
      doOne(); 
     }); 
    }); 
}; 

各地我已經撞了我的頭撞在牆上尋找原因，但我一直沒能找到任何。這可能與封鎖有關，但我不確定。如果有人願意幫忙，我會很感激。謝謝。

Answer 1

你應該使用websocket波紋管：

1. 在您的服務器。 app.js

var app = require('express')(); 
 
var http = require('http').Server(app); 
 
var io = require('socket.io')(http); 
 

 
app.get('/', function(req, res){ 
 
    res.sendFile(__dirname + '/index.html'); 
 
}); 
 

 
io.on('connection', function(socket){ 
 
    
 
    socket.on('doplyment', (msg) => { 
 
    socket.emit('deploying', 'I will notify you after deployment'); 
 
    setTimeout(function(){ 
 
     socket.emit('doployed', 'your request done.') 
 
    }, 3000) 
 
    }); 
 
}); 
 

 
http.listen(3000, function(){ 
 
    console.log('listening on *:3000'); 
 
});

1. 你的客戶端。 client.js

<script src="https://cdn.socket.io/socket.io-1.2.0.js"></script> 
 
<script> 
 
     var socket = io(); 
 
     socket.on('connect', function(){ 
 
     
 
      socket.emit('doployment', 'I am wating'); 
 
      socket.on('deploying', function(mas){ 
 
      console.log(mas); 
 
      }); 
 
      socket.on('deployed', function (msg) { 
 
      console.log(msg); 
 
      }); 
 
     }) 
 
</script>