異步異常處理

異步異常的特點

由于node的回調(diào)異步特性，無法通過try catch來捕捉所有的異常：

try {
 process.nextTick(function () {
  foo.bar();
 });
} catch (err) {
 //can not catch it
}

而對于web服務(wù)而言，其實是非常希望這樣的：

//express風(fēng)格的路由
app.get('/index', function (req, res) {
 try {
  //業(yè)務(wù)邏輯
 } catch (err) {
  logger.error(err);
  res.statusCode = 500;
  return res.json({success: false, message: '服務(wù)器異常'});
 }
});

如果try catch能夠捕獲所有的異常，這樣我們可以在代碼出現(xiàn)一些非預(yù)期的錯誤時，能夠記錄下錯誤的同時，友好的給調(diào)用者返回一個500錯誤?？上В瑃ry catch無法捕獲異步中的異常。所以我們能做的只能是：

app.get('/index', function (req, res) {
 // 業(yè)務(wù)邏輯 
});

process.on('uncaughtException', function (err) {
 logger.error(err);
});

這個時候，雖然我們可以記錄下這個錯誤的日志，且進(jìn)程也不會異常退出，但是我們是沒有辦法對發(fā)現(xiàn)錯誤的請求友好返回的，只能夠讓它超時返回。

domain

在node v0.8+版本的時候，發(fā)布了一個模塊domain。這個模塊做的就是try catch所無法做到的：捕捉異步回調(diào)中出現(xiàn)的異常。

于是乎，我們上面那個無奈的例子好像有了解決的方案：

var domain = require('domain');

//引入一個domain的中間件，將每一個請求都包裹在一個獨立的domain中
//domain來處理異常
app.use(function (req,res, next) {
 var d = domain.create();
 //監(jiān)聽domain的錯誤事件
 d.on('error', function (err) {
  logger.error(err);
  res.statusCode = 500;
  res.json({sucess:false, messag: '服務(wù)器異常'});
  d.dispose();
 });
 
 d.add(req);
 d.add(res);
 d.run(next);
});

app.get('/index', function (req, res) {
 //處理業(yè)務(wù)
});

我們通過中間件的形式，引入domain來處理異步中的異常。當(dāng)然，domain雖然捕捉到了異常，但是還是由于異常而導(dǎo)致的堆棧丟失會導(dǎo)致內(nèi)存泄漏，所以出現(xiàn)這種情況的時候還是需要重啟這個進(jìn)程的，有興趣的同學(xué)可以去看看domain-middleware這個domain中間件。

詭異的失效

我們的測試一切正常，當(dāng)正式在生產(chǎn)環(huán)境中使用的時候，發(fā)現(xiàn)domain突然失效了！它竟然沒有捕獲到異步中的異常，最終導(dǎo)致進(jìn)程異常退出。經(jīng)過一番排查，最后發(fā)現(xiàn)是由于引入了redis來存放session導(dǎo)致的。

var http = require('http');
var connect = require('connect');
var RedisStore = require('connect-redis')(connect);
var domainMiddleware = require('domain-middleware');

var server = http.createServer();
var app = connect();
app.use(connect.session({
 key: 'key',
 secret: 'secret',
 store: new RedisStore(6379, 'localhost')
}));
//domainMiddleware的使用可以看前面的鏈接
app.use(domainMiddleware({
 server: server,
 killTimeout: 30000
}));

此時，當(dāng)我們的業(yè)務(wù)邏輯代碼中出現(xiàn)了異常，發(fā)現(xiàn)竟然沒有被domain捕獲！經(jīng)過一番嘗試，終于將問題定位到了：

var domain = require('domain');
var redis = require('redis');
var cache = redis.createClient(6379, 'localhost');

function error() {
 cache.get('a', function () {
  throw new Error('something wrong');
 });
}

function ok () {
 setTimeout(function () {
  throw new Error('something wrong');
 }, 100);
}
var d = domain.create();
d.on('error', function (err) {
 console.log(err);
});

d.run(ok);  //domain捕獲到異常
d.run(error); //異常被拋出

奇怪了！都是異步調(diào)用，為什么前者被捕獲，后者卻沒辦法捕獲到呢？

Domain剖析

回過頭來，我們來看看domain做了些什么來讓我們捕獲異步的請求(代碼來自node v0.10.4，此部分可能正在快速變更優(yōu)化)。

node事件循環(huán)機(jī)制

在看Domain的原理之前，我們先要了解一下nextTick和_tickCallback的兩個方法。

function laterCall() {
 console.log('print me later');
}

process.nextTick(laterCallback);
console.log('print me first');

上面這段代碼寫過node的人都很熟悉，nextTick的作用就是把laterCallback放到下一個事件循環(huán)去執(zhí)行。而_tickCallback方法則是一個非公開的方法，這個方法是在當(dāng)前時間循環(huán)結(jié)束之后，調(diào)用之以繼續(xù)進(jìn)行下一個事件循環(huán)的入口函數(shù)。

換而言之，node為事件循環(huán)維持了一個隊列，nextTick入隊，_tickCallback出列。

domain的實現(xiàn)

在了解了node的事件循環(huán)機(jī)制之后，我們再來看看domain做了些什么。

domain自身其實是一個EventEmitter對象，它通過事件的方式來傳遞捕獲的錯誤。這樣我們在研究它的時候，就簡化到兩個點：

什么時候觸發(fā)domain的error事件：

進(jìn)程拋出了異常，沒有被任何的try catch捕獲到，這時候?qū)|發(fā)整個process的processFatal，此時如果在domain包裹之中，將會在domain上觸發(fā)error事件，反之，將會在process上觸發(fā)uncaughtException事件。

domain如何在多個不同的事件循環(huán)中傳遞：

1. 當(dāng)domain被實例化之后，我們通常會調(diào)用它的run方法（如之前在web服務(wù)中的使用），來將某個函數(shù)在這個domain示例的包裹中執(zhí)行。被包裹的函數(shù)在執(zhí)行的時候，process.domain這個全局變量將會被指向這個domain實例。當(dāng)這個事件循環(huán)中，拋出異常調(diào)用processFatal的時候，發(fā)現(xiàn)process.domain存在，就會在domain上觸發(fā)error事件。
2. 在require引入domain模塊之后，會重寫全局的nextTick和_tickCallback,注入一些domain相關(guān)的代碼：

//簡化后的domain傳遞部分代碼
function nextDomainTick(callback) {
 nextTickQueue.push({callback: callback, domain: process.domain});
}

function _tickDomainCallback() {
 var tock = nextTickQueue.pop();
 //設(shè)置process.domain = tock.domain
 tock.domain && tock.domain.enter();
 callback();
 //清除process.domain
 tock.domain && tock.domain.exit();    
 }
};

這個是其在多個事件循環(huán)中傳遞domain的關(guān)鍵：nextTick入隊的時候，記錄下當(dāng)前的domain，當(dāng)這個被加入隊列中的事件循環(huán)被_tickCallback啟動執(zhí)行的時候，將新的事件循環(huán)的process.domain置為之前記錄的domain。這樣，在被domain所包裹的代碼中，不管如何調(diào)用process.nextTick, domain將會一直被傳遞下去。

當(dāng)然，node的異步還有兩種情況，一種是event形式。因此在EventEmitter的構(gòu)造函數(shù)有如下代碼：

 if (exports.usingDomains) {
  // if there is an active domain, then attach to it.
  domain = domain || require('domain');
  if (domain.active && !(this instanceof domain.Domain)) {
   this.domain = domain.active;
  }
 }

實例化EventEmitter的時候，將會把這個對象和當(dāng)前的domain綁定，當(dāng)通過emit觸發(fā)這個對象上的事件時，像_tickCallback執(zhí)行的時候一樣，回調(diào)函數(shù)將會重新被當(dāng)前的domain包裹住。

而另一種情況，是setTimeout和setInterval，同樣的，在timer的源碼中，我們也可以發(fā)現(xiàn)這樣的一句代碼:

 if (process.domain) timer.domain = process.domain;

跟EventEmmiter一樣，之后這些timer的回調(diào)函數(shù)也將被當(dāng)前的domain包裹住了。

node通過在nextTick, timer, event三個關(guān)鍵的地方插入domain的代碼，讓它們得以在不同的事件循環(huán)中傳遞。

更復(fù)雜的domain

有些情況下，我們可能會遇到需要更加復(fù)雜的domain使用。

domain嵌套：我們可能會外層有domain的情況下，內(nèi)層還有其他的domain，使用情景可以在文檔中找到

// create a top-level domain for the server
var serverDomain = domain.create();

serverDomain.run(function() {
 // server is created in the scope of serverDomain
 http.createServer(function(req, res) {
  // req and res are also created in the scope of serverDomain
  // however, we'd prefer to have a separate domain for each request.
  // create it first thing, and add req and res to it.
  var reqd = domain.create();
  reqd.add(req);
  reqd.add(res);
  reqd.on('error', function(er) {
   console.error('Error', er, req.url);
   try {
    res.writeHead(500);
    res.end('Error occurred, sorry.');
   } catch (er) {
    console.error('Error sending 500', er, req.url);
   }
  });
 }).listen(1337);
});

為了實現(xiàn)這個功能，其實domain還會偷偷的自己維持一個domain的stack，有興趣的童鞋可以在這里看到。

回頭解決疑惑

回過頭來，我們再來看剛才遇到的問題：為什么兩個看上去都是同樣的異步調(diào)用，卻有一個domain無法捕獲到異常？理解了原理之后不難想到，肯定是調(diào)用了redis的那個異步調(diào)用在拋出錯誤的這個事件循環(huán)內(nèi)，是不在domain的范圍之內(nèi)的。我們通過一段更加簡短的代碼來看看，到底在哪里出的問題。

var domain = require('domain');
var EventEmitter = require('events').EventEmitter;

var e = new EventEmitter();

var timer = setTimeout(function () {
 e.emit('data'); 
}, 10);

function next() {
 e.once('data', function () {
  throw new Error('something wrong here');
 });
}

var d = domain.create();
d.on('error', function () {
 console.log('cache by domain');
});

d.run(next);

此時我們同樣發(fā)現(xiàn)，錯誤不會被domain捕捉到，原因很清晰了：timer和e兩個關(guān)鍵的對象在初始化的時候都時沒有在domain的范圍之內(nèi)，因此，當(dāng)在next函數(shù)中監(jiān)聽的事件被觸發(fā)，執(zhí)行拋出異常的回調(diào)函數(shù)時，其實根本就沒有處于domain的包裹中，當(dāng)然就不會被domain捕獲到異常了！

其實node針對這種情況，專門設(shè)計了一個API：domain.add。它可以將domain之外的timer和event對象，添加到當(dāng)前domain中去。對于上面那個例子：

d.add(timer);
//or
d.add(e);

將timer或者e任意一個對象添加到domain上，就可以讓錯誤被domain捕獲了。

再來看最開始redis導(dǎo)致domain無法捕捉到異常的問題。我們是不是也有辦法可以解決呢？

其實對于這種情況，還是沒有辦法實現(xiàn)最佳的解決方案的。現(xiàn)在對于非預(yù)期的異常產(chǎn)生的時候，我們只能夠讓當(dāng)前請求超時，然后讓這個進(jìn)程停止服務(wù)，之后重新啟動。graceful模塊配合cluster就可以實現(xiàn)這個解決方案。

__domain十分強(qiáng)大，但不是萬能的。__希望在看過這篇文章之后，大家能夠正確的使用domian，避免踩坑。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評論