Tag: 的RabbitMQ

RabbitMQ命令不存在?

操作系统:Mac OSX 10.9 我通过home brew安装了rabbitmq ,当我到/usr/local/sbin运行rabbitmq-server它声明: rabbitmq-server: command not found即使sudo它声明了相同的错误。 如果不是命令,我如何才能启动rabbitmq? 我也试过chmod +x rabbitmq-server在那个目录下,让它成为一个可执行文件,同样的问题。

RabbitMQ使用立即和强制位

我已经使用RabbitMQ服务器和立即字段设置为真发布消息时,我试着发送50,000条消息,并使用rabbitmqctl list_queues ,我看到队列中的消息数为零 。 然后我改变了立即标志为假 ,再次尝试发送50,000条消息,然后使用rabbitmqctl list_queues,我看到总共有100,000条消息在队列中(到目前为止还没有消费者在场) 之后,我开始消费,它消耗了所有的10万条消息。有人可以帮助我了解即时位域和这种行为。 另外,我无法理解强制位域的概念。 提前感谢。 Gurpreet辛格。

RabbitMQ有Nodedown错误

在Windows 7企业机器上,我重新安装了Erlang 17.4和RabbitMQ 3.4.3 x64。 安装成功,顺利。 我还没有尝试创build我的第一个队列或交换,但我已经看到麻烦。 这个问题类似于另一个SOpost ,但是其他post似乎涉及到群集,这是我没有的。 而且,另一张海报可以通过重新启动RabbitMQ服务来避开他的问题; 这种方法不适合我。 我的“nodedown”问题在RabbitMQ命令提示符下显而易见: C:\ Program Files(x86)\ RabbitMQ Server \ rabbitmq_server-3.4.3 \ sbin> rabbitmqctl status状态节点rabbit @ TPAJ05421843 … 错误:无法连接到节点rabbit @ TPAJ05421843:nodedown 诊断 试图联系:[兔子@ TPAJ05421843] 兔@ TPAJ05421843: *连接到TPAJ05421843上的epmd(端口4369) * epmd报告:节点“兔子”根本没有运行 TPAJ05421843上的其他节点:['RabbitMQ'] *build议:启动节点 当前节点详情: – 节点名称:'rabbitmqctl-19884 @ TPAJ05421843' – 主目录:H:\ – cookie哈希值:PD4QQCYrf0TME9vIko3Xuw == 基于上述,我select了检查显式名为“RabbitMQ”的节点的状态。 我得到这个: C:\ Program Files(x86)\ RabbitMQ […]

RabbitMQ的例子:多个线程,通道和队列

我刚刚阅读了RabbitMQ的Java API文档 ,发现它非常翔实和直接。 如何设置一个简单的发布/消费Channel的例子很容易理解。 但这是一个非常简单/基本的例子,它给我留下了一个重要的问题: 我如何设置1 +多个Channels来发布/消费多个队列? 比方说,我有一个RabbitMQ服务器上有3个队列: logging , security_events和customer_orders 。 所以我们要么需要一个Channel才能够发布/使用所有3个队列,或者更有可能有3个独立的Channels ,每个Channels专用于一个队列。 最重要的是,RabbitMQ的最佳实践规定我们为每个消费者线程设置1个Channel 。 对于这个例子,假设security_events只有一个消费者线程,但是logging和customer_order都需要5个线程来处理这个卷。 所以,如果我理解正确,那是否意味着我们需要: 1个Channel和1个消费者线程,用于发布/消费security_events ; 和 5个Channels和5个消费者线程,用于发布/消耗logging ; 和 5个Channels和5个消费者线索用于发布/消费customer_orders ? 如果我的理解被误导了,请先纠正我。 无论哪种方式,一些厌倦了RabbitMQ的老手能帮助我用一个体面的代码示例“连接点”来设置符合我的要求的出版商/消费者吗? 提前致谢!

从ActiveMQ切换到RabbitMQ

我目前正在使用ActiveMQ来满足我的消息需求; 除了几个db失败之外,它运行良好。 不过,我至less考虑试用RabbitMQ。 但在此之前,我想了解以下内容: RabbitMQ与ActiveMQ有什么不同? RabbitMQ比ActiveMQ做得更好还是更差? 比较而言,RabbitMQconfiguration有多么简单/困难? RabbitMQ与Spring的整合程度如何? 使用ActiveMQ,我只需将一个连接工厂Bean连接到一个JmsTemplate然后使用DefaultMessageListener bean将队列连接到它们各自的处理程序。 我可以用RabbitMQ做同样的事吗?

“节点名称”“兔子”已经在运行“,而且”无法连接到节点'兔子'“

Rabbitmq服务器不启动,说它已经在运行: $: rabbitmq-server Activating RabbitMQ plugins … 0 plugins activated: node with name "rabbit" already running on "android-d1af002161676bee" diagnostics: – nodes and their ports on android-d1af002161676bee: [{rabbit,52176}, {rabbitmqprelaunch2254, 59205}] – current node: 'rabbitmqprelaunch2254@android-d1af002161676bee' – current node home dir: /Users/Jordan – current node cookie hash: ZSx3slRJURGK/nHXDTBRqQ== 但是 ,rabbitmqctl似乎是另有想法: rabbitmqctl -n rabbit status Status of node 'rabbit@android-d1af002161676bee' […]

rabbitmq中的连接池或通道之间是否存在性能差异?

如果这是明显的,我是一个Rabbitmq(和编程)的新手,所以提前抱歉。 我正在创build一个池,以便在队列上工作的线程之间共享,但我不确定是否应该在池中使用连接或通道。 我知道我需要通道去做实际的工作,但是每个连接有一个通道(从队列中获得更多的吞吐量)有什么性能好处? 还是我最好只使用一个连接,每个应用程序和池许多渠道? 注意:因为我正在汇集资源,所以初始成本并不是一个因素,因为我知道连接比渠道更昂贵。 我对吞吐量更感兴趣。

RabbitMQ:与话题交换的持久消息

我对RabbitMQ很新。 我已经build立了一个“话题”交stream。 消费者可以在出版商之后开始。 我希望消费者能够接收已经发送的消息,而这些消息尚未被消费。 交易所设置了以下参数: exchange_type => 'topic' durable => 1 auto_delete => 0 passive => 0 消息使用此参数发布: delivery_mode => 2 消费者使用get()从交换中检索消息。 不幸的是,任何客户端之前发布的消息都将丢失。 我使用了不同的组合。 我想我的问题是,交stream不举行消息。 也许我需要在发布者和队列之间有一个队列。 但是这似乎并不适用于通过密钥路由消息的“主题”交换。 任何想法我应该如何继续。 我使用Perl绑定Net :: RabbitMQ(不应该)和RabbitMQ 2.2.0。

RabbitMQ和MSMQ的比较

我能比较RabbitMQ和MSMQ吗? 这将有助于获得有关不同因素的性能信息。

如何重置rabbitmqpipe理的用户

使用rabbitmq,我们可以安装pipe理插件。 然后我们通过浏览器使用http://localhost:55672/使用guest:guest来访问。 问题是,我不能再login,因为我改变了密码,input空白的angular色。 有没有办法重置rabbitmqpipe理用户?