- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
我下面的应用程序作为 JBoss 7.2.0 系统上的客户端与 JBoss 4.2.1 系统上的接收器 JNDI/JMS 通信。它创建一个发送队列和一个接收队列。使用这种配置,我们已经连续运行了 2 个月;双方均未作任何改动。本地客户端应用安装了 4.2.1 jbossall-client.jar 和 jnp-client.jars。
正常 Activity 后,我们开始收到 org.jboss.mq.SpyJMSException: Exiting on IOE; - 嵌套 throwable: (java.io.EOFException) at org.jboss.mq.SpyJMSException.getAsJMSException(SpyJMSException.java:72)
异常。
我们重新启动了 JBoss 7.2.0 而不做任何更改,当我们建立接收队列时,我们现在收到 org.jboss.mq.SpyJMSException: Cannot subscribe to this Destination: ; {...} 原因:java.io.EOFException
我们的代码在 QueueReceiver receiver = session.createReceiver(queue);
处抛出异常。在应用程序运行良好数天后,我们也会开始抛出同样的异常,但在多天的时间内没有任何 Activity 。
我们重新启动了 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 本身存在问题,或者这可能是超时问题?如何检查或延长超时长度;这在客户端是可行的吗?即使超时,我在 start()
的其余部分重新连接之前调用了 stop()
方法,我仍然得到异常;在这种情况下,它不会是超时问题,因为超时会重置。
上下文值:
connectionFactoryName=ConnectionFactory
contextFactoryName=org.jnp.interfaces.NamingContextFactory
packagePrefixes=org.jboss.naming:org.jnp.interfaces
providerUrl=MYSERVER:1099
Java 代码:
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)
正常 Activity 后的异常跟踪:
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。升级已解决该问题,客户端现在可以正常工作,但不幸的是,此解决方案无法解释问题。
关于java - 为什么将客户端 JBoss 连接回收到远程队列后仍然抛出 SpyJMSExceptions?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27870398/
每次我尝试构建(执行完整的 Clean,然后构建)时,我都会在 Eclipse 的问题部分下弹出此错误消息。项目本身旁边还显示一个错误。 我已经尝试了同一问题的其他解决方案中包含的所有内容: 删除项目
我收到以下错误(注意:我使用的是 Netbeans): java.sql.SQLException: No suitable driver found for jdbc:derby://localho
例如 //somewhere struct IFace; struct Base { Base(IFace* iface): f(iface) { //wi
我试图通过 stringstream 将 double 变成字符串,但它不起作用。 std::string MatlabPlotter::getTimeVector( unsigned int xve
我正在尝试使用 AudioKit 框架中的音序器播放音频文件。 AudioKit.output = sampler AudioKit.start() sampler.enableMID
昨天我问了一个关于插入 Heroku 的问题。它不工作,然后突然开始工作。我什么都没改变。现在在一个新的应用程序上,我遇到了完全相同的问题。我决定包含我的整个 Gemfile,希望我可以继续没有这种令
我知道,这个topic已经是discussed许多times,所以直截了当。 这是ItemsSource的TabControl: Tabs = new ObservableCollection {
我有一个更新对象的函数,问题是当我从更新表单字段返回到详细 View 时,它初始化旧对象而不是更新后的对象。 我想在 CarService 而不是 app.js 中填充汽车列表 这是我的汽车服务:
在 resolution comments错误报告 12266 (“套接字连接错误导致资源泄漏”),Robert Ehteshamzadeh 写道 TClientSocket is deprecate
我最初发布了一个问题 here 我发现 JTextField 仅在 JScrollPane 存在时才调整大小。换句话说,我可以根据需要最小化和最大化它,直到出现滚动条(因为文本太多,无法放入窗口)。之
我读过关于 postion:absolute 的问题并尝试了几乎所有可能的解决方案。包括相对定位 div,将它们包装在相对定位的父级中等等,但它没有帮助。 我正在绘制一个表格,然后我将 div 放入其
我在这里发起了一个话题document.getElementById not working但看起来即使提出的建议都是有效的,我仍然有问题。 我有几个复选框。当我在这里查看页面源代码时,有。 docu
我正在做一些阅读,试图更好地理解按位运算符,然后偶然发现了 a helpful old blog post from 2012 ,其中指出 - 在随机正整数 x 的奇数测试中 - 在作者的计算机上评估
我正在尝试在 Eclipse Neon 中使用 aspectj 创建一个示例 maven 项目。然而,方面并没有编织/工作(参见下面的输出)。我尝试寻找很多原因和解决方案,但没有一个有效(请参阅下面的
无论我如何配置我的 appsettings.json 和 appsettings.Development.json,除非我手动添加 ConfigureLogging,否则我无法在信息消息下方记录任何内
我正在尝试使用 JQuery .get() 方法和 JavaScript for 循环来处理来自外部文件的一些数据。我已经在 stackoverflow 上阅读了有关闭包和回调返回值的内容几个小时,但
我正在使用 PHP 5.6 并且要打印一些东西,我必须编辑 php.ini 并包含 php_printer.dll 文件。但是 PHP 5.6 没有.dll 文件。 我要解决的问题: 我想将凭证打印机
我目前正在调试一个包含内存泄漏的大(非常大!)C# 应用程序。它主要使用 Winforms 作为 GUI,尽管一些控件是在 WPF 中制作的,并由 ElementHost 托管。直到现在,我发现许多内
[已解决] 看来 PHP MYADMIN 变量成功了。我将 wait_timeout 设置为 30 ,并将 Lock_wait_timeout 设置为 50 花了将近 6 个小时才恢复稳定,包括几次重
我读过几个关于该主题的讨论,有人说 qmake < 3.0 不正确支持该指令。我刚刚为 g++-64 重新安装了 Qt 5.9.1,但问题仍然存在。此外,我尝试过各种 mkspecs/xxx/xxx.
我是一名优秀的程序员,十分优秀!