carrotmq中文文档
2016年3月29日 carrotmq中文文档无评论CarrotMQ是一个给NodeJS使用的RabbitMQ客户端，基于官方的amqplib，能够简化amqplib的复杂的操作
使用姿势
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
var carrotmq = require('carrotmq'); //var rabbitmqSchema = require('rabbitmq-schema'); var rabbitmqSchema = carrotmq.schema; //see https://www.npmjs.com/package/rabbitmq-schema var schema = new rabbitmqSchema({ exchange: 'exchange0', type: 'topic', bindings: [{ routingPattern: 'foo.bar.#', destination: { queue: 'fooQueue', messageSchema: {} } }] }) var mq = new carrotmq('amqp://localhost', schema); mq.queue('fooQueue', function (data){ console.log(data); this.ack(); //this.nack(); //this.reject(); //this.cancel(); cancel this consumer; this.reply({date: new Date}); //reply to message.properties.relyTo this.carrotmq //carrotmq instrance }); mq.sendToQueue('queue', {msg: 'message'}); mq.publish('exchange', 'foo.bar.key', {msg: 'hello world!'}); |
RPC
|
1 2 3 4 5 6 |
mq.rpc('queue', {data: new Date}, function(data){ //same as queue consumer this.ack(); return data; }).then((data)=>{ //above return value }); |