如何勾勒出事件驱动的系统？

Question

我正在尝试在 Node.js 中设计一个系统（尝试解决 我之前的问题，使用 Node 的并发性），但我在弄清楚如何制定事物应该如何运行的计划时遇到了麻烦。

我对回调而不是返回值的思考感到非常困惑。流程不是线性的，这真的让我难以起草它。如何绘制事件驱动系统的操作流程？

我需要一些我可以看到的东西，然后说“好吧，是的，这就是它的工作原理。我会在这里重新开始，它会在这里给我返回这些结果。”

图片对此非常有帮助。谢谢。

编辑：我正在寻找比UML更精细的东西，具体来说，它将帮助我从我习惯的阻塞和面向对象的编程结构过渡到我不熟悉的非阻塞和事件驱动的结构。

Answer 1

基于 https://i.sstatic.net/9DDQP.png 你需要的是一个很好的流库，允许您在节点中管道同步和异步调用。

其中一个库是 https://github.com/isaacs/slide-flow-control （查看幻灯片预览也），您需要执行的操作的代码大纲如下。

它是自我文档化的，正如你所看到的，它非常简洁，不需要纯 Nodejs、uml、img 等。

var chain = require("slide/chain")
    , asyncMap = require("slide/async-map")
    ;

// start processing
main_loop(function() { 
    console.log("its done"); // when finished
});

function main_loop(cb) {
    var res = [];
    // each entry in chain below fires sequentially i.e. after
    // the previous function completes
    chain
        ( [ [start_update_q, "user-foo"]
          , [get_followed_users, chain.last]
          , [get_favorites, chain.last]
          , [calc_new_q]
          , [push_results, chain.last]
          ]
          , res
          , cb
        )
}

function get_favorites(users, cb) {
    function fn(user, cb_) {
        get_one_users_favorites(user, cb_);
    }
    // this will run thru get_favorites in parallel
    // and after all user favorites are gotten it will fire 
    // callback cb
    asyncMap(users, fn, cb);
}

// code in the various functions in chain here,
// remember to either return the callback on completion.
// or pass it as an arg to the async call you make within the
// function as above i.e. asyncMap will fire cb on completion

Answer 2

UML 可能比较合适。我会查看行为图。