2017-01-29 2 views
0

Je viens de commencer à étudier rabbitmq. Donc, tout simplement faire des trucs de base en rabbitmq avec le client java reçois le dessous de problèmeNouvelle connexion ne se crée pas client rabbitmq java

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) 

et ci-dessous est le code pour créer une connexion

ConnectionFactory factory = new ConnectionFactory(); 

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

Et une chose à savoir, serveur rabbitmq est en cours d'exécution .

S'il vous plaît aider

+0

Existe-t-il un pare-feu bloquant? Que fait telnet localhost 5672? Est-ce que ça entre? –

+0

Je ne suis pas sûr d'avoir compris, dans le code client que vous connectez à une instance locale de RabbitMQ. Quel est cet hôte 0.0.22.40? Est-ce que telnet localhost 5672 est connecté? –

+0

Je ne sais pas exactement ce que c'est réellement ... Et j'ai également vérifié, le pare-feu est éteint – Sharique

Répondre

-3

cmd

taper "netstat/an | trouver "5672"" sur cmd. si ce port est à l'écoute, changer le port ou redémarrez sever

+0

trouver: 5672: Aucun fichier ou répertoire C'est la réponse que j'ai eu et j'ai redémarré le serveur plusieurs fois ... et je blv c'est le port par défaut, ryt? – Sharique

0

Définir l'hôte virtuel setVirtualHost comme:

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(); 

Vous pouvez également définir setConnectionTimeout.