반응형
원격 큐에 대한 클라이언트 JBoss 연결을 재활용 한 후에도 SpyJMSExceptions가 계속 발생하는 이유는 무엇입니까?
아래 내 응용 프로그램은 JBoss 7.2.0 시스템의 클라이언트로 JBoss 4.2.1 시스템의 수신기 JNDI / JMS와 통신합니다. 송신 큐와 수신 큐를 생성합니다. 우리는이 구성으로 2 개월 동안 잘 실행되었습니다. 어느 쪽도 변경되지 않았습니다. 로컬 클라이언트 앱에는 4.2.1 jbossall-client.jar 및 jnp-client.jars가 설치되어 있습니다.
정상적인 활동이 끝나면 org.jboss.mq.SpyJMSException: Exiting on IOE; - nested throwable: (java.io.EOFException) at org.jboss.mq.SpyJMSException.getAsJMSException(SpyJMSException.java:72)예외를 받기 시작합니다 .
아무것도 변경하지 않고 JBoss 7.2.0을 다시 시작했으며 수신 대기열을 설정할 때 .NET org.jboss.mq.SpyJMSException: Cannot subscribe to this Destination: ; {...} Caused by: java.io.EOFException코드에서 예외가 발생했습니다 QueueReceiver receiver = session.createReceiver(queue);. 또한 앱이 며칠 동안 정상적으로 실행되었지만 며칠 동안 활동이없는 후에도 동일한 예외가 발생하기 시작합니다.
문제인지 확인하기 위해 4.2.1 시스템을 다시 시작했지만 아무것도 해결되지 않았습니다. 실제로 두 시스템을 정상적으로 연결 한 다음 4.2.1 시스템을 재활용하여이 오류 시나리오를 복제 할 수 있습니다. 4.2.1 시스템이 다운되면 오류가 발생하기 시작하고, 7.2.0 시스템은 4.2.1 시스템이 완전히 설정되면 연결을 다시 설정하는 데 계속 실패합니다 (할 수 있어야하는 경우에도 해당).
JBoss에서 앱을 중지했다가 시작해도 문제가 해결되지 않습니다. JBoss를 다시 시작하면이 문제를 해결할 확률이 20 %입니다 (위에 언급 된 강제 실패 시나리오의 경우 100 % 확률). 배포를 해제 한 다음 응용 프로그램을 다시 배포하면 일반적으로이 문제가 해결됩니다.
원인은 무엇입니까?
이 동일한 war 파일은 동일한 JBoss 설정이있는 테스트 시스템에서 잘 작동합니다. 동일한 코드를 사용하는 명령 프롬프트에서 테스트 앱을 통해 대상 JBoss 시스템과의 통신이 정상적으로 작동합니다.
JBoss 7.2.0 자체에 문제가있는 것 같습니다. 아니면 시간 초과 문제 일 가능성이 있습니까? 제한 시간 길이를 확인하거나 연장하려면 어떻게합니까? 클라이언트 측에서 할 수있는 일입니까? 시간이 초과 된 경우에도 stop()나머지 start()다시 연결 하기 전에 메서드를 호출하고 여전히 예외가 발생합니다. 이 시나리오에서는 시간 초과가 재설정되었으므로 시간 초과 문제가 아닙니다.
컨텍스트 값 :
connectionFactoryName=ConnectionFactory
contextFactoryName=org.jnp.interfaces.NamingContextFactory
packagePrefixes=org.jboss.naming:org.jnp.interfaces
providerUrl=MYSERVER:1099
자바 코드 :
private ContextContainer contextContainer = null;
private QueueConnection connection = null;
private QueueReceiver receiver = null;
private Queue sendQueue = null;
private Queue receiveQueue = null;
private String sendQueueName = null;
private String receiveQueueName = null;
private MessageHandler messageHandler = null;
protected synchronized void start() throws Exception {
// NOTE: This position also has delay code (for pending multiple
// consecutive recycling requests), with an external method to
// reset the delay. It was removed for code clarity and has no
// effect on the issue being discussed.
// Clear prior Connection
stop();
logger.info("Regenerating JMS for : " + this.getClass().getName());
Context context = this.contextContainer.getContext();
logger.info("Looking up factory : " + contextContainer.getConnectionFactoryName());
QueueConnectionFactory connectionFactory = (QueueConnectionFactory)context.lookup(contextContainer.getConnectionFactoryName());
// ESTABLISH SEND MESSAGE QUEUE
logger.info("Looking up send queue : " + sendQueueName);
sendQueue = (Queue)context.lookup(sendQueueName);
logger.info("Send Queue string : " + sendQueue);
logger.info("Send Queue name : " + sendQueue.getQueueName());
logger.info("Creating Queue Connection");
connection = connectionFactory.createQueueConnection();
logger.info("Setting Exception Listener");
connection.setExceptionListener(new ExceptionListener() {
public void onException(JMSException ex) {
logger.error("JMS Exception received on QueueConnection", ex);
start();
}
});
// ESTABLISH RECEIVE MESSAGE QUEUE
logger.info("Looking up receive queue : " + receiveQueueName);
receiveQueue = (Queue)context.lookup(receiveQueueName);
logger.info("Receive Queue string : " + receiveQueue);
logger.info("Receive Queue name : " + receiveQueue.getQueueName());
logger.info("Creating JMS Session for Receiving");
QueueSession session = connection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
logger.info("Created Session " + session);
logger.info("Creating JMS Receiver for Queue \"" + receiveQueue.getQueueName() + "\"");
// THIS IS THE LINE WHERE THE EXCEPTION IS THROWN!!!
receiver = session.createReceiver(receiveQueue);
logger.info("Setting Message Listener");
receiver.setMessageListener(new MessageListener() {
public void onMessage(Message message) {
try {
if (message instanceof ObjectMessage) {
Object obj = ((ObjectMessage) message).getObject();
// UNRELATED METHOD FOR HANDLING THE MESSAGE
handleMessage(obj);
} else {
throw new Exception("Received message of unexpected type " + message.getJMSType() + ", was expecting ObjectMessage");
}
} catch (Exception ex) {
logger.error("Error processing incoming message.", ex);
} finally {
try {
message.acknowledge();
logger.info("Acknowledged message.");
} catch (Exception ex) {
logger.error("Unable to acknowledge message.", ex);
}
}
}
});
logger.info("Starting Queue Connection");
connection.start();
logger.info("Started Queue Connection");
}
/**
* Extinguish the existing connection.
*/
public synchronized void stop() {
if (receiver != null) {
try {
logger.info("Nullifying Receiver Listener");
receiver.setMessageListener(null);
logger.info("Nullified Receiver Listener");
} catch(Exception ex) {
logger.warn("Exception nullifying Receiver Listener", ex);
}
try {
logger.info("Closing Receiver");
receiver.close();
logger.info("Closed Receiver");
} catch(Exception ex) {
logger.warn("Exception closing Receiver", ex);
} finally {
receiver = null;
}
}
if (connection != null) {
try {
logger.info("Nullifying Exception Listener");
connection.setExceptionListener(null);
logger.info("Nullified Exception Listener");
} catch (Exception ex) {
logger.warn("Exception nullifying Exception Listener", ex);
}
try {
logger.info("Stopping Queue Connection");
connection.stop();
logger.info("Stopped Queue Connection");
} catch (Exception ex) {
logger.warn("Exception stopping Queue Connection", ex);
}
try {
logger.info("Closing Queue Connection");
connection.close();
logger.info("Closed Queue Connection");
} catch (Exception ex) {
logger.warn("Exception closing Queue Connection", ex);
} finally {
connection = null;
}
}
}
로그 출력 :
Setting Context Factory Class: org.jnp.interfaces.NamingContextFactory
Setting Package Prefixes: org.jboss.naming:org.jnp.interfaces
Setting Provider URL: MYSERVER:1099
Generating JMS for : MYPACKAGE.ConnectionHandler
Looking up factory : ConnectionFactory
Looking up send queue : queue/sendQueue
Send Queue string : QUEUE.sendQueue
Send Queue name : sendQueue
Creating Queue Connection
Setting Exception Listener
Looking up receive queue : queue/receiveQueue
Receive Queue string : QUEUE.receiveQueue
Receive Queue name : receiveQueue
Creating JMS Session for Receiving
Created Session SpySession@1903462020[tx=false ack=CLIENT txid=null RUNNING connection=Connection@1963631553[token=ConnectionToken:ID:273725/9966a9625bb094d33a37f72db71b3bb9 rcvstate=STOPPED]]
Creating JMS Receiver for Queue "receiveQueue"
Exception caught during initialization.
org.jboss.mq.SpyJMSException: Cannot subscribe to this Destination: ; - nested throwable: (java.io.EOFException)
정상 활동 후 예외 추적 :
JMS Exception received on QueueConnection
org.jboss.mq.SpyJMSException: Exiting on IOE; - nested throwable: (java.io.EOFException)
at org.jboss.mq.SpyJMSException.getAsJMSException(SpyJMSException.java:72)
at org.jboss.mq.Connection.asynchFailure(Connection.java:423)
at org.jboss.mq.il.uil2.UILClientILService.asynchFailure(UILClientILService.java:174)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.handleStop(SocketManager.java:439)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:371)
at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.EOFException
at java.io.ObjectInputStream$BlockDataInputStream.readByte(ObjectInputStream.java:2766)
at java.io.ObjectInputStream.readByte(ObjectInputStream.java:916)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:316)
... 1 more
다시 시작 후 예외 추적 :
org.jboss.mq.SpyJMSException: Cannot subscribe to this Destination: ; - nested throwable: (java.io.EOFException)
at org.jboss.mq.SpyJMSException.getAsJMSException(SpyJMSException.java:72)
at org.jboss.mq.SpyJMSException.rethrowAsJMSException(SpyJMSException.java:57)
at org.jboss.mq.Connection.addConsumer(Connection.java:800)
at org.jboss.mq.SpySession.addConsumer(SpySession.java:947)
at org.jboss.mq.SpySession.createReceiver(SpySession.java:658)
at org.jboss.mq.SpyQueueSession.createReceiver(SpyQueueSession.java)
at org.jboss.mq.SpySession.createReceiver(SpySession.java:647)
at org.jboss.mq.SpyQueueSession.createReceiver(SpyQueueSession.java)
at MYPACKAGE.ConnectionHandler.start(ConnectionHandler.java:144)
at MYPACKAGE.ConnectionHandler.initialize(ConnectionHandler.java:60)
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:606)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1414)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1375)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1335)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:473)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409)
at java.security.AccessController.doPrivileged(Native Method)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:380)
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:264)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:429)
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:728)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:380)
at org.springframework.web.context.ContextLoader.createWebApplicationContext(ContextLoader.java:255)
at org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:199)
at org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:45)
at org.apache.catalina.core.StandardContext.contextListenerStart(StandardContext.java:3339)
at org.apache.catalina.core.StandardContext.start(StandardContext.java:3777)
at org.jboss.as.web.deployment.WebDeploymentService.doStart(WebDeploymentService.java:156)
at org.jboss.as.web.deployment.WebDeploymentService.access$000(WebDeploymentService.java:60)
at org.jboss.as.web.deployment.WebDeploymentService$1.run(WebDeploymentService.java:93)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
at org.jboss.threads.JBossThread.run(JBossThread.java:122)
Caused by: java.io.EOFException
at java.io.ObjectInputStream$BlockDataInputStream.readByte(ObjectInputStream.java:2766)
at java.io.ObjectInputStream.readByte(ObjectInputStream.java:916)
at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:316)
at java.lang.Thread.run(Thread.java:744)
질문에서 언급했듯이 JBoss 4.2.1 서버가 7.1.1 Final으로 업그레이드되었습니다. 업그레이드를 통해 문제가 해결되었으며 이제 클라이언트가 예상대로 작동하지만 안타깝게도이 솔루션은 문제를 설명하지 않습니다.
ReferenceURL : https://stackoverflow.com/questions/27870398/why-are-spyjmsexceptions-still-thrown-after-recycling-the-client-jboss-connectio
반응형
'your programing' 카테고리의 다른 글
| 페이징 라이브러리-페이지 및 크기를 가져 오는 API가있는 네트워크 + db에 대한 경계 콜백 (0) | 2020.12.31 |
|---|---|
| WCF ExceptionShielding 오류 ID가 처리기에 전달 된 handlingInstanceId와 일치하지 않습니다. (0) | 2020.12.31 |
| dev.hold, dev.flush 및 창 크기 조정 (0) | 2020.12.31 |
| R에서 표준 소프트웨어 디자인 패턴 구현 (MVC에 중점) (0) | 2020.12.31 |
| 웹 애플리케이션없이 Amazon Elastic Beanstalk로 .NET Windows 서비스 배포 (0) | 2020.12.31 |