阿里云消息队列服务 ONS 的 Node.js SDK！

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 3230 天前的主题，其中的信息可能已经有所发展或是发生改变。

由于阿里云那边迟迟不出 Node.js 的 ONS SDK（ master 分支还没东西，在另一个分支），我就自己用 ONS 的 C++ SDK 撸了一个 Node.js 版本的。

其实我也是有想过给官方贡献代码，后来粗粗瞄了一眼，发现这货的协议没文档的情况下来写的话要耗费蛮大的精力的，我只能投机取巧用现成 SDK 撸了。

其实这个包在一个月前就写好了，不过当时没找到很好的支持 ACK 的方法，今天脑袋突然一亮，用 libuv 的黑科技搞定了对 ACK 的支持，我才搬上台面发出来。

不过有一点需要注意：

因为阿里云 ONS 的官方 C++ SDK 是闭源的，且只提供了 Linux 下的静态链接库（ libonsclient4cpp.a ），所以该包目前为止只支持在 Linux 下安装。

如需开发环境， OSX 用户请移步 Linux 或者启动一个 Vagrant 、 Docker 等。

但是等哪天阿里云的 C++ SDK 如果编译好了 OSX 的链接库的话我会马上做上支持的。

废话不多说，上包： https://github.com/XadillaX/aliyun-ons

ONS（开放消息服务）是基于阿里开源消息中间件 MetaQ （ RocketMQ ）打造的一款云消息产品。

安装

$ npm install --save ons

注意: 因为阿里云 ONS 的官方 C++ SDK 是闭源的，且只提供了 Linux 下的静态链接库（ libonsclient4cpp.a ），所以该包目前为止只支持在 Linux 下安装。

如需开发环境， OSX 用户请移步 Linux 或者启动一个 Vagrant 、 Docker 等。

还有一点，由于 C++ SDK 在线程中同步执行需要反馈处理结果，而 Node.js 需要异步执行，所以没法及时反馈结果，本包只能默许所有消息都成功处理，即 ACK 成功状态。（ACK 成功失败特性已编码完成！）

欢迎提供解决方案以及优化。

使用方法

首先你需要开通 ONS 服务并且获取 access key 以及 secret key，然后创建一个消费者 ID 或者生产者 ID ，还有就是话题（ topic ）。

详情可以参考阿里云 ONS 帮助或者阿里云控制台。

样例

你可以参考两个样例文件 consumer.js 以及 producer.js.

Consumer

通过下面的代码来创建一个 Consumer 。

var Consumer = require("ons").Consumer;
var consumer = new Consumer(CUSTOMER_ID, TOPIC, TAGS, ACCESS_KEY, SECRET_KEY);

然后创建一个获取消息的事件监听。

consumer.on("message", function(msg, ack) {
    // 做一些事情
    // 
    // 该函数会在收到消息之后被触发。
    //
    // 在你做完事情之后别忘了调用 `ack.done(true)` 或是 `ack.done(false)`
    // 来告诉 ONS 你已处理消息成功或者失败，若失败则 ONS 会重试
    //
    // `ack.done()` 等价于 `ack.done(true)`
});

当你完成创建和设置监听函数之后，就可以初始化 Consumer 并开始监听消息了。

consumer.init(function(err) {
    if(err) return console.log(err);
    consumer.listen();
});

以及，你也可以在你想要的时候停止它。

consumer.stop();

Producer

通过下面的代码来创建一个 Producer 。

var Producer = require("ons").Producer;
var producer = new Producer(PRODUCER_ID, ACCESS_KEY, SECRET_KEY);

创建完毕之后需要启动它才能发消息。

producer.start(function(err) {
    if(err) return console.log(err);
    console.log("Started!");
});

然后你就可以通过 send 函数来发消息了。

producer.send(KEY, TOPIC, TAGS, CONTENT, function(err, messageId) {
    console.log(arguments);
});

// `KEY` 参数并不是必选的，所以也可以如下调用

producer.send(TOPIC, TAGS, CONTENT, function(err, messageId) {
    console.log(arguments);
});