'use strict';constProducer=require('super-queue').Producer;constp=newProducer({// 队列名称queue: 'my_queue',// 设置Redis数据库连接redis: {host: 'localhost',port: 6379,db: 0},// 默认的消息有效时间(s)，为0表示永久maxAge: 0,// 心跳时间周期（s），默认2秒heartbeat: 2,});// 消息入队constdata='abcdefg';// 消息内容，必须为字符串类型constmaxAge=10;// 消息有效时间，当省略此参数时使用默认的maxAge值p.push({data, maxAge},(err,ret)=>{if(err){// 消息处理出错// 如果超过指定时间消费者未返回处理结果，则会返回MessageProcessingTimeoutErrorconsole.error(err);}else{// 消息的处理结果console.log(ret);}});// 初始化成功，触发start事件// 注意：一定要在触发此事件后再使用push()，否则可能无法收到消息处理结果p.on('start',()=>{console.log('start working');});// 退出p.exit();

'use strict';constConsumer=require('super-queue').Consumer;constc=newConsumer({// 队列名称queue: 'my_queue',// 设置Redis数据库连接redis: {host: 'localhost',port: 6379,db: 0},// 处理能力，如果当前消费者正在处理的消息数量超过该值则不再接收新消息，为0表示不限制capacity: 0,// 心跳时间周期（s），默认2秒heartbeat: 2,});// 监听队列c.listen(msg=>{// msg.data = 消息内容// msg.expire = 消息过期秒时间戳// msg.reject(err) 消息处理出错// msg.resolve(result) 消息处理成功// msg.checkTimeout(callback) 检查执行是否超时，如果在expire之后的时间还没有响应，则自动响应一个MessageProcessingTimeoutError，并执行回调函数});// 退出c.exit();

'use strict';constMonitor=require('super-queue').Monitor;constm=newMonitor({// 设置Redis数据库连接redis: {host: 'localhost',port: 6379,db: 0},// 自动检查时间间隔（s），默认为2秒interval: 2,});m.on('producerUp',info=>{// info.queue 队列名称// info.name 生产者名称});m.on('producerDown',info=>/* 同上 */);m.on('consumerUp',info=>{// info.queue 队列名称// info.name 消费者名称});m.on('consumerDown',info=>/* 同上 */);// 获取客户端状态m.clientStatus((err,info)=>{if(err){console.error(err);}else{// info.producers 生产者列表，同producerUp的info// info.consumers 消费者列表，同consumerUp的info}});// 获取队列状态m.queueStatus((err,list)=>{if(err){console.error(err);}else{// list 等待队列，包含信息：{name, length}}});// 退出m.exit();

'use strict';// 使用模块输出的promise属性下的ProducerconstProducer=require('super-queue').promise.Producer;// 用法一样constp=newProducer({// 队列名称queue: 'my_queue',// 设置Redis数据库连接redis: {host: 'localhost',port: 6379,db: 0},// 默认的消息有效时间(s)，为0表示永久maxAge: 0,// 心跳时间周期（s），默认2秒heartbeat: 2,});// 消息入队constdata='abcdefg';// 消息内容，必须为字符串类型constmaxAge=10;// 消息有效时间，当省略此参数时使用默认的maxAge值// 不需要传递callback参数，其他用法跟原来一样p.push({data, maxAge}).then(ret=>{// 消息的处理结果console.log(ret);}).catch(err=>{// 消息处理出错// 如果超过指定时间消费者未返回处理结果，则会返回MessageProcessingTimeoutErrorconsole.error(err);});// 返回的Promise对象使用的是bluebird模块，如果一定要使用callback可使用其asCallback()方法p.push({data, maxAge}).asCallback((err,ret)=>{if(err){// 消息处理出错// 如果超过指定时间消费者未返回处理结果，则会返回MessageProcessingTimeoutErrorconsole.error(err);}else{// 消息的处理结果console.log(ret);}});// 初始化成功，触发start事件// 注意：一定要在触发此事件后再使用push()，否则可能无法收到消息处理结果p.on('start',()=>{console.log('start working');});// 退出p.exit();