Articles of amqp

node-amqp不能发送消息给RabbitMQ

我正在使用rabbitmq-tutorials ,ruby版本正常,但是node.js版本不能发送消息。 我不知道什么是错的。 var amqp = require('amqp'); var amqp_hacks = require('./amqp-hacks'); var connection = amqp.createConnection({host: 'localhost'}); connection.on('ready', function(){ connection.publish('hello_node', 'Hello World!'); console.log(" [x] Sent 'Hello World!'"); amqp_hacks.safeEndConnection(connection); }); 在运行node send.js ,运行进程node recv.js不能node recv.js任何东西。 而rabbitmqctl list_queues不显示hello_node队列。

如何使用node.js amqp模块将AQMP消息缓冲区转换为JSON对象?

我正在使用node.js amqp模块来读取队列中的消息。 以下是队列中有消息时调用的callback函数: function onMessage(message, headers, deliveryInfo) { console.log(message); //This prints buffer //how to convert message (which I expect to be JSON) into a JSON object. //Also how to get the JSON string from the 'message' which seems to be a buffer } 谢谢。

从STOMP / AMQP中select哪一个?

我使用node.js作为jms topic的客户端。有两个协议可用于在Topic上进行连接。 这些是Stomp和AMQP。 我在http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol和http://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocol上了解他们的简介。 两者似乎都是有线协议,即通过networking作为八位字节stream发送的数据。我没有发现任何一个应该被优选的具体原因。 如果有人能阐明它,这将是有益的。 还有一点是协议引以为傲的说他们互通。 互操作术语意味着如果有人想要脱离特定的消息代理实现说apache主动MQ,而是想要插入Websphere MQ,过渡将是平稳的(既提供支持AMQP / STOMP或任何其他有线协议)?

RabbitMQ vs Socket.io?

我正在做实时的Web应用程序开发。 浏览器用户应该能够通过node.js服务器与彼此进行通信。 其中一个用户写邮件,所有其他用户将得到它。 我不太清楚RabbitMQ是如何工作的。 但从快速阅读看来,它似乎处理消息的发布/订阅。 一个用户(在浏览器中)发布一些东西和订阅者(​​在其他浏览器中)得到这个消息。 这不是什么Socket.io使用websockets? 这是我的问题: 他们每个人有什么优点/缺点? 可以用Socket.ioreplaceRabbitMQ吗? 有没有我需要RabbitMQ的networking应用程序,其中Socket.io不足够?