0
저는 RabbitMQ를 처음 사용하고 간단한 예를 시도하고 있습니다. 아래는 내 자바 소스 :연결이 거부되었습니다. RabbitMQ
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
public class Send {
private final static String QUEUE_NAME = "hello";
public static void main(String[] argv) throws Exception {
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 '" + message + "'");
channel.close();
connection.close();
}
}
그리고 오류가 아래에 무엇입니까 : 스레드에서
예외 "주요"java.net.ConnectException : 연결이 거부 됨 :
at java.net.DualStackPlainSocketImpl.connect0(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79)
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.PlainSocketImpl.connect(PlainSocketImpl.java:172)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:579)
at com.rabbitmq.client.impl.FrameHandlerFactory.create(FrameHandlerFactory.java:32)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:588)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:612)
at .Send.main(Send.java:15)
어떤 제안을 연결하십시오 ?
는 로컬 호스트 및 실행에 RabbitMQ 서버인가? 또한 기본 게스트를 사용하는 것처럼 보입니다 : 금지 된 게스트 자격 증명 (질문은 다음과 유사합니다 : http://stackoverflow.com/questions/22850546/cant-access-rabbitmq-web-management-interface- 새로 설치 한 후 동일한 게스트 자격 증명 웹 관리 인터페이스로 액세스 할 수 있습니까?) – pinepain