Articles of rabbitmq

如何在Node.js中以编程方式获取远程运行的RabbitMQ服务器的版本?

我有一个使用rabbot连接到RabbitMQ的节点服务器。 这工作正常,我可以发布消息,消费消息等 现在我希望能够问RabbitMQ服务器它正在运行的版本。 我希望我能够发布一个消息询问版本,并通过答复队列得到答案。 或者我也可以通过HTTP进行请求,我没有偏好。 但奇怪的是,我找不到这样做的任何方法。 因此,我的问题:我怎样才能以Node.js编程方式获得远程运行的RabbitMQ服务器的版本? 非重复: validationrabbitmq的版本 以上不是重复的,因为它不需要以编程方式find版本,也不提供任何Node.js解决scheme。 另外,大多数解决scheme只适用于本地的rabbitmq-server,而不是远程的。

RabbitMQ:`rabbitmqctl list_exchanges`下的'direct'标题是什么意思?

如果我使用php的amqp类创buildexchangem交换types设置为direct和唯一的选项指定是durable ,然后尝试连接到node.js交换,我得到一个Cannot redeclare exchange with different options error你看到如果你的select不匹配。 但是,据我所知,我正在使用完全相同的选项(键入直接和选项持久)。 所以我做了一个testing,并在php中创build了一个名为php_exchange交换和一个名为node_exchange node.js,并运行rabbitmqctl list_exchanges并获得了一些有趣的输出: Listing exchanges … node_exchange direct amq.headers headers amq.direct direct amq.match headers amq.fanout fanout direct php_exchange direct amq.topic topic …done. direct标题在这种情况下意味着什么(显然它不是直接types的所有交换,因为它将node_exchange列为直接types)? 我怎样才能得到node.js创build一个相同的amqp交换(以便它不会失败时,连接到一个持久的交stream)? 我正在使用PECL php amqp库和node-amqp库(https://github.com/ry/node-amqp) 谢谢。 编辑: 以下是rabbitmqctl list_exchanges name type auto_delete internal arguments的输出(为简洁起见,删除了其他交换): Listing exchanges … node_exchange direct false false [] php_exchange direct […]

在Node.js中使用node-amqp模块进行手动确认

我正在使用postwait模块node- amqp。 我能够发布/订阅队列的一些消息,但我想手动确认消息。 例如,我希望消息被读取并且不被确认,然后对这个消息执行一些计算,然后发送一个q.shift()来确认消息并且通过第二个消息。 我想要确认手动使用。 其实我有一个允许订阅国旗{ack: false}的函数,那么我有一个函数来手动创build一个q.shift() (如文档中所述)。 但是,当我发布2条消息,然后我读了2条消息,没有确认,我看到了2条消息。 但是我希望子文件重复最初收到的同样的信息,直到我不承认它。 我怎样才能使用这些方法?

RabbitMQ(和node.js)中的asynchronous确认

我有一个RabbitMQ的具体使用案例,我想澄清一些事情,并要求build议。 考虑这种情况: 1 – 我发布两个消息,即要执行的任务:messageA然后messageB 2-我的消费者得到messageA,执行包含在这个消息中的任务,但是当任务正在运行时,服务器崩溃 我的问题是:当服务器重新启动时,messageA将被重新sorting,并且会在messageB(与崩溃之前的顺序相同)之前重新sorting? 据我所知,messageA会丢失,如果服务器崩溃,因为我的消费者默认情况下收到消息后确认。 所以我的想法是单独使用和确认消息:先消耗,运行任务,然后在任务成功执行后确认消息。 你觉得这个方法有问题吗? 你会build议我做其他事吗?

如果接收器没有运行,Node.js RabbitMQ消息会丢失

这是我的问题 1.如果接收器先启动然后发送消息,则消息被传送 2但是,如果接收器没有启动,那么代码表示发送的消息,但启动接收器不会得到消息。 如果我使用pika在Python中尝试相同的顺序,那么事情似乎正常工作。 我还validation没有使用rabbitmqctl –list_queues命令的消息 我正在运行node.js 0.70并在Ubuntu 11.04 64位版本上运行 我在我的send.js中有以下代码 var util= require('util') var amqp = require('amqp'); var connection = amqp.createConnection({host:'localhost', login:'guest', password:'guest'}); var pubMessage = function pubM(msg) { var x = connection.exchange(); var q = connection.queue('helloNode', { autoDelete: true, durable: false, exclusive: false } ); x.publish('helloNode',{helloNode: "This is a message"}); }; connection.addListener('ready', pubMessage); […]

ETIMEDOUT与node.js&amqp的问题

我有两个生产者和两个消费者在我的项目中使用rabbitmq通过node.js中的amqp模块。 为消费者build立连接的代码如下所示: function init_consumers( ) { console.log( 'mq: consumers connection established. Starting to init stuff..' ); global.queue.consumers.connection = con_c; var fq_name = global.queue.fq_name; var aq_name = global.queue.aq_name; var q_opts = { durable:true }; var subscr_opt = { ack: true, prefetchCount: 1 }; var fq = con_c.queue( fq_name, q_opts, function() { console.log( 'mq: consumer f queue […]

RabbitMQ – 如何检测消费者队列已被破坏?

所有我正在开发的应用程序中,客户端正在与rabbitmq服务器创build队列,还有另一个服务器,将pipe理所有的计算服务器。 我面临着在服务器端检测队列销毁的问题。 例如:从android客户端创build名称为“a”的队列,现在用户将要杀死该应用程序,该时间队列将被销毁。 但服务器仍处于该队列的未知状态。 所以我想要听任何事件或任何方法来调用侦测队列已从客户端摧毁。 谢谢

如何构build一个消息总线与Node.js和API分布在几个听众?

这是我想要发生的事情: 我的用户会打到一个端点,比如/api/findFile/app.js 。 express正在监听这个调用(标准的RESTtypes的东西),并会联系几个工作人员(可以是任意数量)要求他们执行工作,具体查找文件。 当第一个这样做的时候,它应该回应express的function,以便将结果发回给用户。 我想像某种消息总线/ AMQP设置将需要。 我认为快递function可以向工作人员publish请求,每个人都subscribe这个事件: bus.publish('findFile', {fileName: 'app.js'}}; 沿着这些线的东西。 工人有: bus.subscribe('findFile', function(event) {…. 每个工人将检查它是否有硬盘上的文件。 该文件可以在MULTIPLE工作盘上。 所以当第一个find它的时候,我想以某种方式中止别人回来expression。 为了回到expression,我想我们会做一个反向的pub/sub订阅,这次是明确地听取回应? 任何想法如何正确地devise这个? 特别是与比赛条件。

HTTP请求期间的RabbitMQ事件上的Express.js – res.send()?

我在我的网站上进行用户注册。 exports.regitser = (req, res)-> user = unique_id : "RANDOM_HASH" name : escape(req.body.name) pass : escape(req.body.pass) … # registrations starts here 在这一刻我需要推送数据到RabbitMQ交换,并等待在单独的队列"reg_results"响应。 当我在unique_id="RANDOM_HASH" "reg_results ”中收到消息后,似乎这个用户(对于这个HTTP请求)的注册成功完成,现在我可以给客户端res.send("You are registered!") 在继续来自客户端的HTTP请求的情况下处理这种模式的最好方法是什么? 提前致谢。

如何在nodejs上只消耗一个来自rabbit mq的消息

我使用amqp.node库来将rabbitmq集成到我的系统中。 但在消费者,我想只处理一个消息,然后确认消息,然后消耗队列中的下一条消息。 目前的代码是: // Consumer open.then(function(conn) { var ok = conn.createChannel(); ok = ok.then(function(ch) { ch.assertQueue(q); ch.consume(q, function(msg) { if (msg !== null) { othermodule.processMessage(msg, function(error, response){ console.log(msg.content.toString()); ch.ack(msg); }); } }); }); return ok; }).then(null, console.warn); ch.consume将一次处理通道中的所有消息,模块的function在这里调用,其他模块不会在同一时间线上执行。 我想等待其他模块函数完成之后才能使用队列中的下一条消息。