Node.JS 模块驱动的方法学和标准化的 Stream 很适合创建 “微服务”(Microservices) 的系统架构 《What are some best architecture practices when designing a nodejs system?》。

James Halliday(Substack) 4年前有写了一系列的模块来帮助构建基于“微服务”(虽然那个时候这个名词还不流行)的系统架构。其中服务间调用的核心模块就是 dnode。dnode 已经很久没更新了，原因是代码和功能（很小的功能集）已经非常稳定。

Vanilar Version

一个简单的 dnode 例子如下：

dnode = require 'dnode'
net = require 'net'
grappling = require 'grappling-hook'

log = console.log.bind console
error = console.error.bind console

apis =
    transform: (s, cb) ->
        log '--original func calls'
        cb null, s.replace(/[aeiou]{2,}/, 'oo').toUpperCase()

server = net.createServer (c) ->
    d = dnode apis
    c.pipe(d).pipe c

server.listen 5004

d = dnode()
d.on 'remote', (remote) ->
    remote.transform 'beep', (err, s) ->
        if err?
            error 'Errors', err
        else
            log 'beep => ' + s
        d.end()

c = net.connect 5004
c.pipe(d).pipe c

这段代码很简短，执行结果是：

--original func calls
beep => BOOP

其功能为 Server 自动向 Client 发布了 apis 这个 rpc 接口，Client 可以在 d.on 'remote' 事件中获得这个接口，然后调用 Server 提供的 transform 方法。

我在这里不会详细介绍 dnode，你可以去它的 Github Repos. 学习。如果想了解协议细节，我这有个中文版。

Hooked Version

我的需求是，要在 dnode Server 的 API 上，添加 Hook，这样我可以在每个 API 方法的运行前后，根据需要插入特定的 pre 或者 post 逻辑。这样的“注入”需求在后台开发中很常见。

Javascript 的Hook 库很多，我这里用的是 grappling-hook。用它的原因一方面是因为其功能比较丰富，另一方面是前一段研究 keystone.js，对这块比较熟悉。
Hook 一个对象方法的例子如下：

grappling = require 'grappling-hook'
instance = grappling.create()
instance.addHooks {
    transform: (s, cb) ->
        cb null, s.replace(/[aeiou]{2,}/, 'oo').toUpperCase()
}
instance.pre 'transform', (s, done) ->
    log 'before transform'
    done()
.post 'transform', (s, done) ->
    log 'after transform!'
    done()
instance.transform 'beep', (err,  res)-> console.log 'result', res

grappling-hook 的详细用法请自行读文档。
上面这段程序的输出结果是：

before transform
BOOP
after transform!

看起来可以工作了。
不过这里有一个问题，就是如果你把 instance 直接传递给 dnode (例如:d = dnode instance)是有问题的。因为 instance 除了有 transform 之外包含大量的辅助方法。这些东西可多会被 dnode 作为接口定义传递给 Client，这不是我们要的，因此要清理，例子代码如下：

...
apis =
    transform: (s, cb) ->
        log '--original func calls'
        cb null, s.replace(/[aeiou]{2,}/, 'oo').toUpperCase()

wrap = (apis) ->
    instance = grappling.create()
    instance.addHooks apis

    hooked = {}
    hooked[k] = instance[k] for k of apis
    { instance, hooked }

{instance, hooked} = wrap apis

# Equip middlewares
# Callback func MUST have same numbers of arguments as the origin
instance.pre 'transform', (s, done) ->
    log 'before transform'
    done()
.post 'transform', (s, done) ->
    log 'after transform!'
    done()
...

wrap 函数返回一个“干净的” hooked 过的 API 定义对象，这是可以被作为接口定义传递给 Client 的。同时，你可以通过 wrap 返回的另一个 instance 对象来慢慢添加你的 pre、post 方法。而且，这些你可以对同一个方法添加不止一个 pre、post hooks。

任务完成。如果想直接看可执行程序，源代码在这里：https://github.com/jacobbubu/dnodeHook 。