前面一篇文章寫的是rabbitMQ+thrift傳送消息廷支，這里我也寫一下用pb來傳送消息的方法吧
首先我們定義一個demo.user.proto文件
package com.kang;
message user{
required string userId = 1;
optional string nick = 2;
optional string avator = 3;
}
很多人想著接下來就是用pb命令來生成desc了，但我們用的protocol-buffers是不需要生成desc文件的坛悉，直接就可以拿proto來用
這里發(fā)一下send.js
var fs = require('fs');
var protocolBuffers = require('protocol-buffers');
var amqp = require('amqplib/callback_api');
var AMPQ_URI = 'amqp://localhost:5672';
var Schema = protocolBuffers(fs.readFileSync('./demo.user.proto'));
amqp.connect(AMPQ_URI, function(err, conn){
conn.createChannel(function(err, ch){
var q = 'hello';
var obj = {
userId: '0001',
nick: 'helloworld',
avator: 'pic1'
}
var buf = Schema.user.encode(obj);
ch.assertQueue(q, {durable: false});
ch.sendToQueue(q, buf);
console.log(" [x] Send Data Finish");
});
setTimeout(function(){
conn.close();
process.exit(0);
}, 500);
})
這里重要點(diǎn)介紹這個Schema，Schema里是會直接處理proto文件的响谓，所以我們只要直接用Schema就可以了亿絮，太方便了鼠锈。
再發(fā)一個receive.js
var fs = require('fs');
var protocolBuffers = require('protocol-buffers');
var amqp = require('amqplib/callback_api');
var Schema = protocolBuffers(fs.readFileSync('./demo.user.proto'));
var AMQP_URI = 'amqp://localhost:5672';
amqp.connect(AMQP_URI, function(err, conn){
conn.createChannel(function(err, ch){
var q = 'hello';
ch.assertQueue(q, {durable: false});
console.log('[*] Waiting for message in %s. To exit press CTRL+C', q);
ch.consume(q, function(msg){
// console.log(msg);
var obj = Schema.user.decode(msg.content);
console.log(obj);
console.log('[x] Received Data Finish');
}, {noAck: true});
})
})
也是運(yùn)行
node send.js
再開個窗口運(yùn)行
node receive.js
效果跟前面的rabbitmq+thrift的是一樣的，這里我們介紹了兩種將對象生成buf的方法晨抡，個人建議還是用pb來傳送消息氛悬，畢竟這種方法太方便了，當(dāng)然你也可以用json生成buffer來扔給rabbitMQ耘柱，但數(shù)據(jù)量大的話如捅，每個消息壓縮一點(diǎn)，累積起來還是很可觀的调煎。好了镜遣，就寫到這里。
