在 rabbitmq 中使用 factory.setUri() 连接到 /vhost

Question

我有连接码：

ConnectionFactory factory = new ConnectionFactory();
factory.setUri(System.getenv("CLOUDAMQP_URL"));

但我得到一个错误：

23:16:24 web.1    | started with pid 3098
23:16:27 web.1    | Exception in thread "main" java.io.IOException
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:378)
23:16:27 web.1    |     at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:621)
23:16:27 web.1    |     at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:648)
23:16:27 web.1    |     at Main.run(Main.java:212)
23:16:27 web.1    |     at Main.main(Main.java:239)
23:16:27 web.1    | Caused by: com.rabbitmq.client.ShutdownSignalException: connection error
23:16:27 web.1    |     at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
23:16:27 web.1    |     at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:361)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:226)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
23:16:27 web.1    |     ... 5 more
23:16:27 web.1    | Caused by: java.net.SocketException: Connection reset
23:16:27 web.1    |     at java.net.SocketInputStream.read(SocketInputStream.java:196)
23:16:27 web.1    |     at java.net.SocketInputStream.read(SocketInputStream.java:122)
23:16:27 web.1    |     at java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
23:16:27 web.1    |     at java.io.BufferedInputStream.read(BufferedInputStream.java:254)
23:16:27 web.1    |     at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)
23:16:27 web.1    |     at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)
23:16:27 web.1    |     at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139)
23:16:27 web.1    |     at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:536)
23:16:27 web.1    |     at java.lang.Thread.run(Thread.java:745)
23:16:27 web.1    | exited with code 1
23:16:27 system   | sending SIGTERM to all processes

我的兔子日志显示连接被拒绝

=ERROR REPORT==== 21-Jul-2015::23:16:27 ===
closing AMQP connection <0.9858.0> (127.0.0.1:38856 -> 127.0.0.1:5672):
{handshake_error,opening,0,
                 {amqp_error,access_refused,
                             "access to vhost '' refused for user 'guest'",
                             'connection.open'}}

如何使用 setUri 连接到默认虚拟主机 (/)？ last time 这个问题被问到，提问者的解决方案是不使用setUri。 uri方式是什么？

烦人的是，相同的 URI 可用于 pika；这两个实现（python 和 java）解析 URI 的方式有区别吗？

编辑：我使用的 URL 是

CLOUDAMQP_URL=amqp://guest:guest@localhost:5672/

Answer 1

看起来这与 the source. In particular, the URI is split on /s then URLdecoded; this means that my URI (amqp://guest:guest@localhost:5672/) returns the empty string for the vhost (instead of the default / like python does). 中 URI 的解析方式不同我通过使用

解决了这个问题

factory.setUri(System.getenv("CLOUDAMQP_URL"));
factory.setVirtualHost("/");

覆盖推断的错误值，但这是不好的解决方案。另一个可行的解决方案是更改 URL:

CLOUDAMQP_URL=amqp://guest:guest@localhost:5672/%2F

注意 URL 编码 / 通过 %2F。我会用库开一个issue/PR，因为python的解法看起来更直观。

编辑：我与库维护人员进行了交谈。他们指出，他们是权威实施，而 pika 在 the spec 之外做一些事情（见附录 A）。不幸的是，stock rabbit 实现（虚拟主机为“/”）与 stock java rabbit mq 客户端对默认 URI 的解释不兼容，但事实确实如此。使用 %2F 修复。

在 rabbitmq 中使用 factory.setUri() 连接到 /vhost

Connecting to / vhost with factory.setUri() in rabbitmq

java

rabbitmq

amqp