Articles of 的RabbitMQ

Ubuntu 10.04:无法启动RabbitMQ服务器后安装

在Ubuntu 10.04上安装RabbitMQ后,我收到一条失败消息,说明该服务无法启动。 任何深入了解这个问题将不胜感激! 以下是startup_log和startup_err的内容。 Startup_log: {error_logger,{{2012,7,7},{15,50,31}},"Protocol: ~p: register error: ~p~n",["inet_tcp",{{badmatch,{error,etimedout}},[{inet_tcp_dist,listen,1},{net_kernel,start_protos,4},{net_kernel,start_protos,3},{net_kernel,init_node,2},{net_kernel,init,1},{gen_server,init_it,6},{proc_lib,init_p_do_apply,3}]}]} {error_logger,{{2012,7,7},{15,50,31}},crash_report,[[{initial_call,{net_kernel,init,['Argument__1']}},{pid,<0.20.0>},{registered_name,[]},{error_info,{exit,{error,badarg},[{gen_server,init_it,6},{proc_lib,init_p_do_apply,3}]}},{ancestors,[net_sup,kernel_sup,<0.9.0>]},{messages,[]},{links,[#Port<0.100>,<0.17.0>]},{dictionary,[{longnames,false}]},{trap_exit,true},{status,running},{heap_size,987},{stack_size,24},{reductions,512}],[]]} {error_logger,{{2012,7,7},{15,50,31}},supervisor_report,[{supervisor,{local,net_sup}},{errorContext,start_error},{reason,{'EXIT',nodistribution}},{offender,[{pid,undefined},{name,net_kernel},{mfa,{net_kernel,start_link,[[rabbitmqprelaunch877,shortnames]]}},{restart_type,permanent},{shutdown,2000},{child_type,worker}]}]} {error_logger,{{2012,7,7},{15,50,31}},supervisor_report,[{supervisor,{local,kernel_sup}},{errorContext,start_error},{reason,shutdown},{offender,[{pid,undefined},{name,net_sup},{mfa,{erl_distribution,start_link,[]}},{restart_type,permanent},{shutdown,infinity},{child_type,supervisor}]}]} {error_logger,{{2012,7,7},{15,50,31}},std_info,[{application,kernel},{exited,{shutdown,{kernel,start,[normal,[]]}}},{type,permanent}]} {"Kernel pid terminated",application_controller,"{application_start_failure,kernel,{shutdown,{kernel,start,[normal,[]]}}}"} Startup_err: Crash dump was written to: erl_crash.dump Kernel pid terminated (application_controller) ({application_start_failure,kernel,{shutdown,{kernel,start,[normal,[]]}}})

RabbitMQ – 群集节点失败后意外的空的​​和未同步的队列

我已经下载并安装在Windows上的群集中的RabbitMQ: 在两台服务器(例如Alpha和Bravo)上下载并安装ERLANG和RABBITMQ, 安装pipe理插件,设置自定义的tcp_listener端口(增加安全性),并添加自定义的pipe理员login,而不是默认的访客:来宾login 在两台机器上设置相同的cookie(在C:\ Windows \和C:\ Users \用户名) 安装RabbitMQ作为Windows服务 将Bravo节点joinAlpha节点进行集群 添加策略来镜像所有队列(Pattern =“”,Definition =“ha-mode:all”) 我创build了持久的镜像队列并向其发布消息 – 它在两个节点之间同步(它可以正常工作) 但后来我试图testing如果closures一个节点会发生什么: 我closures节点布拉沃 我添加消息到Alpha节点 我在节点布拉沃回头 丢失的消息已同步到Bravo节点,但在pipe理控制台中,此节点被标记为“未同步” 这个队列有什么问题? 但还有其他问题。 例如: 我closures节点布拉沃 我添加消息到Alpha节点 我在Bravo节点上回头,等待消息同步 我closures了Alpha节点 我给Bravo节点添加了消息 我重新打开Alpha节点 队列中所有添加的消息神奇消失 这真是太奇怪了 有人知道发生了什么? 还有第三个testing用例: 我已经closuresAlpha节点,将消息添加到Bravo并closuresBravo节点 然后我打开Alpha节点,并收到消息“timeout_waiting_for_tables”。 我尝试了更多次。 它开始工作,只有当我也转身Alpha节点 也许我只是没有得到如何在RabbitMQ集群工作。 任何人都可以帮助我,并告诉发生了什么事?

RabbitMQ和联邦。 跨数据中心虚拟队列?

我正在使用现场/备用模型构build一个位于两个数据中心的弹性系统。 系统需要一个消息队列来传递消息供系统后端处理。 我现在的devise要求将消息队列(和交换等)作为一个虚拟队列在两个数据中心之间共享。 这样,可以通过closures站点A中的队列消费者并在站点B中启动它们来实现故障转移 – 消费者只需订阅其本地代理并绑定到单个全局交换并开始接收在那里发送的消息,包括那些在故障转移发生时排队。 我过去曾经使用过RabbitMQ,并且知道它可以进行群集,并且群集不适合广域网连接 – 这是非常不能容忍丢包/networking分区的。 我已经阅读了rMQ联邦插件,这似乎意味着两个联邦经纪人可以允许他们的交易所被相互连接的客户绑定。 我不确定是否可以使用它来实现我所需要的,似乎我需要每个DC代理来定义一个交换,联合两个代理,然后每个站点上的客户需要绑定到两个由本地经纪商托pipe的交易所以及托pipe在远程经纪商的交易所。 每个交易所对某个特定的经纪商而言仍然是本地的。 我理解正确吗? 第二个问题 – 大概联邦插件与单独的rMQ集群一起工作? 如果我在A地点有一个rMQ经纪人集群,B地点有类似的集群,我可以把他们联合起来吗?

RabbitMQ将消息保存在内存中(内存溢出)

我在集群中有RabbitMQ服务器(2个节点)。 所有的队列都是持久的,镜像的,所有的消息都被设置为持久的。 我编写了应用程序来同步RabbitMQ队列上的数据库更改。 在大多数情况下,队列是空的,因为消费者可以像生产者一样快地读取变化。 不幸的是,在初始同步时(当所有表中的所有行都被传输时),队列中有很多消息(例如10GB)正在等待消耗,因为从数据库中读取数据在大多数情况下比写入更快。 我以为这些消息将被保存到磁盘,但似乎所有的消息也存储在RAM中。 所以在使用所有RAM之后(无论我有多less),它开始阻止发布者。 有谁知道为什么RabbitMQ将所有持久和持久的消息也保存在RAM中? 这是“devise”function吗? 我试图使用不同的消息大小(从512kB到5MB)。 结果是一样的。 也有消费者连接/没有连接或设置不同的QOS,没有任何区别。 版本:RabbitMQ 3.1.0,Erlang R14B04

NGINX是否允许在不丢失请求的情况下将负载切换到另一台服务器?

NGINX是否允许从一台服务器切换到另一台服务器而不丢失请求? 我有一个SOAP API,NGINX将请求转发到三个服务器之一,每个服务器将其转发到队列,然后等待来自队列的响应,然后客户端等待来自API的响应。 如果客户端没有得到响应,请求仍然通过,只有客户端不知道他执行的操作成功完成。 因此,如果我需要升级其中一个SOAP前端,我需要将负载切换到其他两个前端之一,但是不会丢弃任何现有的连接,这对NGINX来说是可能的吗?

RabbitMQ启动失败

我正在尝试启动RabbitMQ服务器。 而任何我这样做的方式,我得到这个错误: Starting rabbitmq-server: FAILED – check /var/log/rabbitmq/startup_{log, _err} rabbitmq-server. invoke-rc.d: initscript rabbitmq-server, action "start" failed. dpkg: error processing rabbitmq-server (–configure): subprocess installed post-installation script returned error exit status 1 Errors were encountered while processing: rabbitmq-server sE: Sub-process /usr/bin/dpkg returned an error code (1) 我试图修复破碎的软件包: $ sudo apt-get update –fix-missing $ sudo dpkg –configure -a […]

如何公开访问RabbitMq

我已经在Centos远程服务器上安装并设置了Rabbitmq。 后来我创build了一个文件“rabbitmq.config”并添加了这一行 [{rabbit,[{loopback_users,[]}]}] 然后重新启动rabbitmq服务器。 再次试图从我的本地机器使用来宾凭证loginrabbitmqpipe理Web界面,但得到 login失败 错误消息。清空Centos中的Rabbitmq环回用户设置的正确方法是什么?

RabbitMQ服务器随机,神秘停止

我按照他们网站上的RPM安装说明在我的EC2盒子上安装了RabbitMQ。 我的操作系统是CentOS。 rabbitMQ服务器偶尔停止运行,在rabbitmq shutdown_err日志中什么也没有显示出来,并且没有任何关于rabbitmq的其他日志显示出来。 我不确定哪些信息有助于debugging,因此无论您需要什么,只要问一下,我都会提供。

Docker不会启动MONGODB,并且在启动其他服务时不会出现IPAddress

我一直在试图从Fedorabuild立一个操作系统映像,但是没有成功启动以下内容: Systemd SSHD 的RabbitMQ MongoDB的 我可以得到前3(Systemd,SSHD和RabbitMQ-Server)的工作。 我也可以让MongoDB在容器中工作。 但是,我无法让MongoDB与其他3个服务一起工作。 另外,当我尝试“dockerize”MongoDB时,IP地址不显示。 我在Dockerfile中丢失了什么? 这是我的dockerfile: FROM fedora:20 MAINTAINER “Ashfaque” <[email protected]> ENV container docker RUN yum -y update; yum clean all RUN yum -y install systemd; yum clean all; \ (cd /lib/systemd/system/sysinit.target.wants/; for i in *; do [ $i == systemd-tmpfiles-setup.service ] || rm -f $i; done); \ rm -f […]

RabbitMQ限于一个奴隶

在AWS上部署时,我遇到了一个与rabbitmq有关的奇怪问题。 当我旋转一个主人,连接一个奴隶,一切顺利,我有两个服务器群集。 当我去添加第二个奴隶的主人,只是挂在join_cluster,并会无限期地等待,而不会引发任何错误。 一旦我停止第一个奴隶,第二个将立即join。 我找不到任何其他人有这个问题或限制奴隶的数量的任何设置。 这是我添加一个条目到主机文件指向一个IP主要在两个从服务器上运行的步骤 rabbitmqctl stop_app rabbitmqctl reset rabbitmqctl join_cluster rabbit@master rabbitmqctl start_app 这是我的rabbitmq.config文件。 [ {rabbit, [ {tcp_listeners, [{{ rabbitmq_amqp_port }}]}, %% SSL listeners are configured in the same fashion as TCP listeners, %% including the option to control the choice of interface. %% %% {ssl_listeners, [5671]}, %% Maximum time for AMQP 0-8/0-9/0-9-1 […]