正確腳手架的Node.js應用程序，而不快遞（應用程序不接受請求）

Question

[這個問題是相當模糊的，我爲此道歉。我試圖回答自己的問題]

我的建築內，在給定的時間間隔執行各種任務的Node.js應用程序，以解決我的種種煩惱。這裏是全球腳手架（包括青鳥承諾和貓鼬爲DB交互）：

var Promise = require("bluebird"); 
 
var mongoose = require('mongoose'); 
 
mongoose.Promise = require('bluebird'); 
 

 
// Personal modules 
 
var bootApp = require(...); 
 
var doStuffA = require(...); 
 
var doStuffB = require(...); 
 
var doStuffC = require(...); 
 

 
// running locally, but meant to be deployed at some point 
 
mongoose.connect('mongodb://localhost:27017/myDatabase'); 
 
var db = mongoose.connection; 
 

 
db.on('error',() => { 
 
    console.log("Error : lost connection !")); 
 
    process.exit(1); 
 
}); 
 

 
db.once('open',() => { 
 
\t 
 
    bootApp() // always start by booting 
 
    .then(() => { // then start the infinite loop of events 
 

 
    setInterval(doStuffA, 1000*60*60); // 1x/1h 
 
    setInterval(doStuffB, 1000*60*10); // 1x/10min 
 
    setInterval(doStuffC, 1000*60*3); // 1x/3min 
 

 
    }).catch((e) => { // errors are handled by doStuffX(), so we should never catch anything here 
 
    console.log(e.message); 
 
    process.exit(1); 
 
    }); 
 
});

每個模塊doStuffX是返回一個承諾，處理自己的錯誤的功能，並且應該在某個時候完成。整個應用

預期的行爲：

• 的應用程序應該能夠永遠
• 運行應用程序應儘量doStuffX()在給定的時間間隔，無論是成功還是上次失敗。
• [可選：該應用程序應在接收到「關閉」信號平滑地關閉而不重試任何doStuff。

我的問題：如何建立一個乾淨的支架對於這樣的應用程序？我可以擺脫setInterval並使用承諾嗎？我主要關心的一個問題是，確保之前的doStuffX()實例在開始下一個實例之前完成，即使它涉及以某種方式「殺死」它。

我對任何有關腳手架應用程序的鏈接都開放，但請不要給我一個答覆/涉及EXPRESS的鏈接：我不需要快遞，因爲我的應用程序沒有收到任何請求。 （一切我迄今發現開始與快遞：/）

Answer 1

如果您不想開始下一個doStuffX()，直到前一個完成，則可以用重複的setTimeout()呼叫替換您的setInterval()。

function runA() { 
    setTimeout(function() { 
     doStuffA().then(runA).catch(function(err) { 
      // decide what to do differently if doStuffA has an error 
     }); 
    }, 1000*60*60); 
} 

runA(); 

你也可以添加一個超時這個，這樣，如果doStuffA()沒有一定的時間內響應，那麼你採取一些其他措施。這將涉及使用另一個計時器和超時標誌。

Answer 2

[我回答我的問題，想在這裏把所有的東西我後來改變了，萬一有人掉入這個頁面有一天...]

對於支架的貓鼬的一部分，這裏是我走到這一步，一個可靠的長期DB連接：

• 的Mongoose documentation給人以奇特的方式，以確保司機絕不會放棄試圖與reconnectTries
重新連接
• 我真的不明白socketOptions和keepalive似乎與副本有關，所以我現在將它們從我的代碼中刪除
• 由於Mongoose應該在出現問題時自動重新連接，因此我將保留db.once('open')作爲應用程序代碼本身的訪問權限，即使我不「噸真的聽懂了沒有用db.on('connected')
• 我建議你閱讀this的差異。

var Promise = require("bluebird"); 
 
var mongoose = require('mongoose'); 
 
mongoose.Promise = require('bluebird'); 
 

 
// Personal modules 
 
var bootApp = require(...); 
 
var doStuffA = require(...); 
 
var doStuffB = require(...); 
 
var doStuffC = require(...); 
 

 
// running locally, but meant to be deployed at some point 
 
var uri = 'mongodb://localhost:27017/myDatabase'; 
 
// the added option makes sure the app will always try to reconnect... 
 
mongoose.connect(uri, { server: { reconnectTries: Number.MAX_VALUE } }); 
 
var db = mongoose.connection; 
 

 
db.on('error',() => { 
 
    console.log("Error with Mongoose connection.")); 
 
}); 
 

 
db.once('open',() => { 
 
\t 
 
    bootApp() // always start by booting 
 
    .then(() => { // then start the infinite loop of events 
 

 
    ////////////////////////////////// 
 
    /// Here goes the actual stuff /// 
 
    ////////////////////////////////// 
 

 
    }).catch((e) => { // errors are handled by doStuffX(), so we should never catch anything here 
 
    console.log(e.message); 
 
    }); 
 
});

現在，對於實際的重複的東西，我的目標是確保一切順利，並沒有進程被卡住。關於我所做的更改：

• 使用的方法不是本地ES6，但是特定於藍鳥。你可以閱讀關於.timeout()和.delay()，我發現它非常有用於在乾淨的代碼中鏈接超時和間隔。
• 在我的腦海裏，.then(runA, runA)應該總是推出runA一個唯一的實例，但我很擔心我是否能最終真正發動兩場並行實例...

// Instead of using setInterval in a bluebird promised environment... 
 

 
setInterval(doStuffA, 1000*60*60); // 1x/1h 
 

 
// I would have liked a full promise chain, but as jfriend00 stated, 
 
// It will end up crashing because the initial promise is never resolved... 
 

 
function runA() { 
 
    return doStuffA() 
 
    .timeout(1000*60*30) // kill the running instance if it takes longer than 30min 
 
    .delay(1000*60*60) // wait 60min 
 
    .then(runA, runA); // whatever the outcome, restart the process 
 
} 
 
runA(); 
 

 
// Therefore, a solution like jfriend00's seems like the way to go : 
 

 
function runA() { 
 
    setTimeout(function() { 
 
     doStuffA() 
 
     .timeout(1000*60*30) 
 
     .then(runA, runA) 
 
    }, 1000*60*60); 
 
} 
 
runA();