L'exemple "Hello World" de RabbitMQ donne "Connection Refused"
II essaie de faire de l'application "hello world" à partir d'ici: RabbitMQ Bonjour Tout Le Monde
Voici le code de ma classe productrice:
package com.mdnaRabbit.producer;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.io.IOException;
public class App {
private final static String QUEUE_NAME = "hello";
public static void main( String[] argv) throws IOException{
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "Hello World!";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
System.out.println(" [x] Sent" + "'");
channel.close();
connection.close();
}
}
Et voici ce que j'obtiens quand mettre en œuvre cette:
Exception in thread "main" java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
at java.net.Socket.connect(Socket.java:579)
at com.rabbitmq.client.ConnectionFactory.createFrameHandler(ConnectionFactory.java:445)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:504)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)
at com.mdnaRabbit.producer.App.main(App.java:16)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)
Process finished with exit code 1
Quelle en est la cause?
J'ai trouvé la solution à mon problème ici Erreur dans la prise d'une connexion de socket
source d'informationauteur Nikitin Mikhail | 2013-03-15
Vous devez vous connecter pour publier un commentaire.
À traiter avec elle, j'ai installé le serveur RabbitMQ. Si rabbitmq-server n'est pas installé cette erreur sera levée.
J'ai eu cette "Connexion Refusée" erreur:
J'avais fait une erreur de paramétrage de l'adresse IP de l'intérieur
/etc/rabbitmq/rabbitmq-env.conf
à la mauvaise adresse ip:J'ai enlevé ce paramètre de configuration et que l'erreur disparaisse.
J'ai résolu ce problème simplement en exécutant:
Démarrer le Lapin MQ Server. Le fichier de commandes pour démarrer ce serveur est présent sous rabbitmq_server-3.6.0\sbin>rabbitmq-serveur.chauve-souris, elle fonctionne.
Dans mon cas, il m'a donné l'erreur suivante en essayant de démarrer le serveur
<Rabbit intall path>\rabbitmq_server-3.6.0\sbin>rabbitmq-server.bat start
ERROR: epmd error for host Protocol: inet_tcp: register/listen error: econnrefused: nxdomain (non-existing domain)
Ce que j'ai fait a été ajouter à mon
host
fichier la ligne suivante:127.0.0.1 localhost
Et puis le rabbitmq-serveur est démarré. Après cela, je n'ai pas le
connection refuse
erreur de plus. Espérons que cette aide.Vous devez commencer Rabbit MQ Serever
Dans windows nom de fichier: RabbitMQ de Service de commencer
Vous pouvez utiliser ce code:
application.fichier de propriétés: