0

我刚开始学习rabbitmq。因此，虽然只是使用 java 客户端在 rabbitmq 中做一些基本的事情，但我遇到了以下问题

Exception in thread "main" java.util.concurrent.TimeoutException
    at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:76)
    at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:110)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:372)
    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:298)
    at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:58)
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:103)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:877)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:839)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:797)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:930)
    at com.sharique.jobs.HelloWorldProducer.produce(HelloWorldProducer.java:32)

下面是创建连接的代码

ConnectionFactory factory = new ConnectionFactory();

                factory.setUsername("guest");
                factory.setPassword("guest");
                factory.setHost("localhost");
                factory.setPort(5672);
Connection connection = factory.newConnection();

还有一件事，即rabbitmq 服务器正在运行。

请帮忙

4

2 回答 2

0

将虚拟主机设置为setVirtualHost：

String uri = System.getenv("URL");
if (uri == null) uri = "amqp://guest:guest@localhost";

ConnectionFactory factory = new ConnectionFactory();
factory.setUri(uri);
.
.
factory.setVirtualHost("/");
Connection connection = factory.newConnection();

你也可以设置setConnectionTimeout.

于 2017-02-08T13:58:31.000 回答
-3

命令

在 cmd 上键入“ netstat /an | find "5672" "。如果该端口正在侦听，请更改端口或重新启动服务器

于 2017-01-29T16:07:40.193 回答