2017-01-29 3 views
0

Я только что начал изучать кролик. Таким образом, в то время как просто делать некоторые основные вещи в RabbitMQ с Java клиентом подвожу по указанному ниже IssueНовое соединение не создается 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 сервер работает ,

Пожалуйста, помогите

+0

Есть ли блокирующий брандмауэр? Что делает telnet localhost 5672? Он входит? –

+0

Не уверен, что я понял, в код клиента вы подключаетесь к локальному экземпляру RabbitMQ. Что это за хост 0.0.22.40? Поддерживает ли telnet localhost 5672? –

+0

Я точно не знаю, что на самом деле это ... И я также проверил, брандмауэр выключен – Sharique

ответ

-3

cmd

набрав "NetStat/| найти "5672"" на ЦМД. , если этот порт прослушивания, изменить порт или перезапустить разъединить

+0

find: 5672: Нет такого файла или каталога Это ответ, который я получил, и я перезапустил сервер много раз ... и я blv это порт по умолчанию, ryt? – Sharique

0

Устанавливает виртуальный хост setVirtualHost как:

String uri = System.getenv("URL"); 
if (uri == null) uri = "amqp://guest:[email protected]"; 

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

Вы также можете установить setConnectionTimeout.

Смежные вопросы