小编Yos*_*shi的帖子

我正在构建一个包含许多部分的小型系统,我想使用消息pub/sub服务在各部分之间进行通信.

我读到了一些像RabbitMQ和ZeroMQ这样的消息队列服务,但我觉得它们太复杂了,感觉它是为分布式系统而生的.我的系统的所有部分都将用C++/Linux编写并放在一个小型的Raspberry Pi CPU上,因此我不需要像可扩展,跨平台,其他语言客户端这样的功能......

你们能给我一些适合我需要的服务或图书馆的建议吗？

我正在使用 RxJS 学习反应式编程，并遇到需要逐行读取文件的情况。实际上我使用类似的解决方案解决了它：

https://gist.github.com/yvele/447555b1c5060952a279

它可以工作，但我需要使用一些普通的 JS 代码将缓冲区流转换为行流。（在上面的示例中使用“readline”模块）

我想知道是否还有其他方法可以使用 RxJS 运算符将 Buffer 的 Observable 转换为 Line 的 Observable ，如下例所示。

var Rx = require('rx');
var fs = require('fs');
var lines = Rx.Observable
  .fromEvent(rl, 'data') // emits buffers overtime
  // some transforms ...
  .subscribe(
    (line) => console.log(line), // emit string line by line
    err => console.log("Error: %s", err),
    () => console.log("Completed")
  );

我正在制作一个应用程序，允许用户使用 AWS S3 将视频上传到我们的终端。我使用服务器生成签名的 url 并将其返回给客户端（网络浏览器），然后客户端使用该 url 上传到我们的后端。它工作得很好，但我有一个小问题，我们无法跟踪从浏览器启动的文件上传的进度。

那么有什么方法可以从我们的服务器获取上传进度呢？

在一些开源JavaScript项目中,我看到人们检查变量是否是函数('function' === typeof x).我想知道为什么人们会使用它而不是(typeof x === 'function').

我觉得第二种方式更自然.有没有什么好的理由使用第一种方式？性能？错误潜力？或者只是风格问题？