阿里云MQS nodejs SDK
发布于 11 年前 作者 vfasky 5665 次预览 最后一次回复是 11 年前 来自 分享
demo
var MQSClient = require('aliyun_mqs');
var client = new MQSClient({
accessKeyId: 'you accessKeyId',
accessKeySecret: 'you accessKeySecret',
url: 'http://{you}.aliyuncs.com'
});
//创建队列
client.queue.create('test', {}, function(err, url){
if(!err){
//发消息
client.message.send('test', {
msg: 'test'
}, function(err, data){
console.log(data);
});
}
});
3 回复
我乱说几句哈。
client.queue.create('test', {})应该有返回值,返回一个代表队列的对象,比如var testQueue。然后我们可以调用
testQueue.send(msgObject, callback)。send方法应该是向一个自身的队列压入msgObject,如果队列已经连接好了,那么直接 执行;如果队列没连接好,就等待连接,当连接完成的事件触发,再一次性全部send出去。@alsotang 好主意!
顶一个