-
rabbitmq+haproxy 集群搭建问题
2016-08-22 15:29补充一下,以免我的问题描述不是很清楚,我的问题和一下文章非常类似,望大神些指教
http://stackoverflow.com/questions/20501430/how-to-configure-rabbitmq-using-active-passive-high-availability-architecture -
rabbitmq+haproxy 集群搭建问题
2016-08-22 13:57@88250 见图
此时 msg18 节点是挂掉的没有及时同步到没有挂掉的 msg17 节点中来,会报下面类似错误
java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124)
at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:833)
at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:61)
at com.changhong.msg.common.rabbitmq.Sender.sendAndCreateQueue(Sender.java:329)
at com.changhong.msg.common.rabbitmq.Sender.(Sender.java:71)
at com.changhong.msg.common.rabbitmq.TestSender.main(TestSender.java:15)
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - home node 'rabbit@msg18' of durable queue 'authcode' in vhost '/' is down or inaccessible, class-id=50, method-id=10)
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
... 5 more