된 javax.jms.JMSException은 : 기존의 연결이 강제로 나는 <strong>아파치 낙타</strong>와 <strong>qpid</strong>을 통합하려고하는 초보자입니다 원격 호스트

Question

에 의해 폐쇄되었다. qpid을 사용하여 큐에서 읽고 쓰는 자바 코드를 작성해야합니다.

먼저 qpid 웹 사이트에서 JMS 예제를 다운로드했습니다. 내가 실행하려고하는 코드가 있습니다.

/* 
* 
* Licensed to the Apache Software Foundation (ASF) under one 
* or more contributor license agreements. See the NOTICE file 
* distributed with this work for additional information 
* regarding copyright ownership. The ASF licenses this file 
* to you under the Apache License, Version 2.0 (the 
* "License"); you may not use this file except in compliance 
* with the License. You may obtain a copy of the License at 
* 
* http://www.apache.org/licenses/LICENSE-2.0 
* 
* Unless required by applicable law or agreed to in writing, 
* software distributed under the License is distributed on an 
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 
* KIND, either express or implied. See the License for the 
* specific language governing permissions and limitations 
* under the License. 
* 
*/ 
package org.apache.qpid.jms.example; 

import javax.jms.Connection; 
import javax.jms.ConnectionFactory; 
import javax.jms.DeliveryMode; 
import javax.jms.Destination; 
import javax.jms.ExceptionListener; 
import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.MessageConsumer; 
import javax.jms.MessageProducer; 
import javax.jms.Session; 
import javax.jms.TextMessage; 
import javax.naming.Context; 
import javax.naming.InitialContext; 

public class HelloWorld { 
    public static void main(String[] args) throws Exception { 
     try { 
      // The configuration for the Qpid InitialContextFactory has been supplied in 
      // a jndi.properties file in the classpath, which results in it being picked 
      // up automatically by the InitialContext constructor. 
      Context context = new InitialContext(); 

      ConnectionFactory factory = (ConnectionFactory) context.lookup("myFactoryLookup"); 
      Destination queue = (Destination) context.lookup("myQueueLookup"); 

      Connection connection = factory.createConnection(System.getProperty("USER"), System.getProperty("PASSWORD")); 
      connection.setExceptionListener(new MyExceptionListener()); 
      connection.start(); 

      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 

      MessageProducer messageProducer = session.createProducer(queue); 
      MessageConsumer messageConsumer = session.createConsumer(queue); 

      TextMessage message = session.createTextMessage("Hello world!"); 
      messageProducer.send(message, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE); 
      TextMessage receivedMessage = (TextMessage) messageConsumer.receive(2000L); 

      if (receivedMessage != null) { 
       System.out.println(receivedMessage.getText()); 
      } else { 
       System.out.println("No message received within the given timeout!"); 
      } 

      connection.close(); 
     } catch (Exception exp) { 
      System.out.println("Caught exception, exiting."); 
      exp.printStackTrace(System.out); 
      System.exit(1); 
     } 
    } 

    private static class MyExceptionListener implements ExceptionListener { 
     @Override 
     public void onException(JMSException exception) { 
      System.out.println("Connection ExceptionListener fired, exiting."); 
      exception.printStackTrace(System.out); 
      System.exit(1); 
     } 
    } 
} 

이 파일 ::

# Set the InitialContextFactory class to use 
java.naming.factory.initial = org.apache.qpid.jms.jndi.JmsInitialContextFactory 
# Define the required ConnectionFactory instances 
# connectionfactory.<JNDI-lookup-name> = <URI> 
connectionfactory.myFactoryLookup = amqp://localhost:5672 

# Configure the necessary Queue and Topic objects 
# queue.<JNDI-lookup-name> = <queue-name> 
# topic.<JNDI-lookup-name> = <topic-name> 
queue.myQueueLookup = queue 
topic.myTopicLookup = topic 

이 지금은이 작업을 위해 중위, 나는 브로커 서비스로 알려져있는 뭔가가 필요 이해에 따라 달라집니다. 몇 가지 연구를하면서, 나는이 목적으로 RabbitMQ를 사용할 수 있다는 것을 알게되었습니다. 그래서 난 내 윈도우 머신에 다운로드 및 포트 localhost:5672

에 연결하려고하지만 내 코드를 실행할 때, 나는 ERROR :

이

2017-05-04 11:28:29,329 [main   ] - ERROR JmsConnection     - Failed to connect to remote at: amqp://localhost:5672 
Caught exception, exiting. 
javax.jms.JMSException: An existing connection was forcibly closed by the remote host 
    at org.apache.qpid.jms.exceptions.JmsExceptionSupport.create(JmsExceptionSupport.java:86) 
    at org.apache.qpid.jms.exceptions.JmsExceptionSupport.create(JmsExceptionSupport.java:108) 
    at org.apache.qpid.jms.JmsConnection.connect(JmsConnection.java:172) 
    at org.apache.qpid.jms.JmsConnectionFactory.createConnection(JmsConnectionFactory.java:204) 
    at org.apache.qpid.jms.example.HelloWorld.main(HelloWorld.java:48) 
Caused by: java.io.IOException: An existing connection was forcibly closed by the remote host 
    at sun.nio.ch.SocketDispatcher.read0(Native Method) 
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43) 
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) 
    at sun.nio.ch.IOUtil.read(IOUtil.java:192) 
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) 
    at io.netty.buffer.PooledUnsafeDirectByteBuf.setBytes(PooledUnsafeDirectByteBuf.java:288) 
    at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1100) 
    at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:372) 
    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:123) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:624) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:559) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:476) 
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:438) 
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) 
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) 
    at java.lang.Thread.run(Thread.java:745) 

왜이 오류가 발생 얻을? 이 항구는 내 로컬 컴퓨터에서 확실히 듣고 있습니다. 다시 나는 JMS를 가진 초보자이므로 어떠한 지침도 매우 높이 평가 될 것입니다.

Answer 1

Tim이 언급했듯이, 브리커 AMQP 1.0 플러그인이로드되었는지 확인해야 할 필요가 있습니다.

그러나이 경우 큰 차이가 없을 수 있습니다. 이전에 RabbitMQ에 대한 JMS 클라이언트 또는 다른 AMQP 1.0 클라이언트를 사용하여 소비자 및 제작자를 생성 할 때 트랙에서 멈추는 문제가 발생하여 많은 성공을 거두지 못했습니다. https://github.com/rabbitmq/rabbitmq-amqp1.0/issues/34

사용하기로 결정한 언급 된 조사 사항 RabbitMQ, 기존 서버 솔루션에 묶이지 않은 것처럼 들리십니까? 그렇다면 AMQP 1.0을 지원하고 JMS 클라이언트가 일상적으로 사용되는 다른 서버의 경우 ActiveMQ, ActiveMQ Artemis, Java 브로커 용 Qpid, Qpid C++ 브로커 또는 Qpid 발송 라우터를 사용할 수 있습니다 (Windows에서는 작동하지 않습니다. 언급하면서).

Answer 2

Qpid JMS AMQP v1.0 client은 RabbitMQ 용 실험용 AMQP 1.0 플러그인을 사용하지 않는 한 RabbitMQ에 연결할 수없는 것으로 보입니다.

실행중인 브로커와 호환되는 클라이언트를 사용하고 있는지 확인하십시오.