kaazing publishBasic传递json数据并在node.js中捕获它

Question

kaazing publishBasic传递json数据并在node.js中捕获它

下面是通过kaazing AMQP库将数据发布到RabbitMQ的代码

var body = new ByteBuffer();
body.putString("new_bidder", Charset.UTF8);
body.flip();

var headers = {};
publishChannel.publishBasic(body, headers, consumeExchange, "server.aa.bb", false, false);

下面是捕获node.js中的数据的代码

q.subscribe(function (message) {
// Print messages to stdout
var msg = message.toString('UTF-8');
console.log(msg.length);
// console.log(message);
})

问题是publishBasic函数需要以字节为单位正文，而我希望传递json并以node.js格式获取该json

任何帮助都将受到高度的感谢。

Answer 1

只需使用JSON.stringify即可。

var myObject = {
     bidder : "new_bidder",
     property2 : property2_value,
};

var body = new ByteBuffer();
body.putString(JSON.stringify(myObject), Charset.UTF8);
body.flip();

publishChannel.publishBasic(body, headers, consumeExchange, "server.aa.bb", false, false);

在Node.JS中，您可以使用JSON.parse：

q.subscribe(function (message) {
   var msg = message.toString('UTF-8'); 
   // Print messages to stdout
   console.log(msg);
   // now convert back to JSON object so you can use in your code
   var myObject = new Object();
   myObject = JSON.parse(msg);
   console.log(msg.bidder);
})