Need help with ali-ons?
Click the “chat” button below for chat support from the developer who created it, or find similar developers for support.

About the developer

142 Stars 42 Forks MIT License 88 Commits 13 Opened issues


Aliyun Open Notification Service Client

Services available


Need anything else?

Contributors list


NPM version build status David deps

Aliyun Open Notification Service Client (base on opensource project RocketMQ)

Sub module of ali-sdk.


npm install ali-ons --save



'use strict';

const httpclient = require('urllib'); const Consumer = require('ali-ons').Consumer; const consumer = new Consumer({ httpclient, accessKeyId: 'your-accessKeyId', accessKeySecret: 'your-AccessKeySecret', consumerGroup: 'your-consumer-group', // namespace: '', // aliyun namespace support // isBroadcast: true, });

consumer.subscribe(config.topic, '*', async msg => { console.log(receive message, msgId: ${msg.msgId}, body: ${msg.body.toString()}) // return Consumer.ACTION_RETRY; // you can return ACTION_RETRY, then this message will be directly retried });

consumer.on('error', err => console.log(err));


'use strict';
const httpclient = require('urllib');
const Producer = require('ali-ons').Producer;
const Message = require('ali-ons').Message;

const producer = new Producer({ httpclient, accessKeyId: 'your-accessKeyId', accessKeySecret: 'your-AccessKeySecret', producerGroup: 'your-producer-group', // namespace: '', // aliyun namespace support });

(async () => { const msg = new Message('your-topic', // topic 'TagA', // tag 'Hello ONS !!! ' // body );

// set Message#keys msg.keys = ['key1'];

// delay consume // msg.setStartDeliverTime( + 5000);

const sendResult = await producer.send(msg); console.log(sendResult); })().catch(err => console.error(err))

Secure Keys

Please contact to @gxcsoccer to give you accessKey



We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.