RabbitMq权限问题

单节点不存在该问题。

异常：

Exception in thread "main" 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.AMQConnection.start(AMQConnection.java:378)

at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:678)

at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:722)

at upsmart.zhsen.ServerProducer.main(ServerProducer.java:33)

Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; protocol method: #method<connection.close>(reply-code=530, reply-text=NOT_ALLOWED - access to vhost '/' refused for user 'mq', class-id=10, method-id=40)

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:361)

at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:226)

at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)

... 4 more

原因：

用户‘mq’没有权限访问‘/’

sudo rabbitmqctl list_users

列出用户权限

Listing users ...

mq [administrator]

guest [administrator]

sudo rabbitmqctl set_permissions -p / mq '.*' '.*' '.*'

该命令使用户mq具有‘/’这个virtual host中所有资源的配置、写、读权限以便管理其中的资源