2014-10-23 2 views
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) 

어떤 제안을 연결하십시오 ?

+0

는 로컬 호스트 및 실행에 RabbitMQ 서버인가? 또한 기본 게스트를 사용하는 것처럼 보입니다 : 금지 된 게스트 자격 증명 (질문은 다음과 유사합니다 : http://stackoverflow.com/questions/22850546/cant-access-rabbitmq-web-management-interface- 새로 설치 한 후 동일한 게스트 자격 증명 웹 관리 인터페이스로 액세스 할 수 있습니까?) – pinepain

답변

1

RabbitMQ 서버를 설치 했습니까?

또한 rabbitmq-client.jar 및 클래스 경로에 대한 종속성이 있습니까?

터미널에서이 작업을 실행 해보십시오 :

java -cp .:commons-io-1.2.jar:commons-cli-1.1.jar:rabbitmq-client.jar Send 
+1

시스템에 문제가 발생했지만 연결을 설정할 수 없습니다. 이제 괜찮아요, 명령 주셔서 감사합니다 :) –