Posts tagged: java jms

配置嵌入式的Activemq服务

activemq提供了嵌入式的服务，即在一个JVM内部使用jms服务。我们用它来做异步发送消息。 JMS自身没有提供异步发送消息的机制，只能同步发送消息。这带来一个问题，比如外部（远端）的JMS服务器因为各种原因无法工作，那么发送消息的应用可能也连带的无法工作，这时消息会丢失。 可以使用activemq的嵌入式的服务，先同步发送消息到本地（嵌入式activemq服务），然后再用一个接收线程接收本地消息，发送到远端的JMS服务，这样即使远端JMS服务失效，消息也不会丢失，当远端服务器恢复后还能继续收到消息。    发送文章为PDF   

星期三 八月 25th, 2010 in , , , | No Comments »

使用BlockingQueue实现简明的JMS连接异常恢复

JMS连接有可能出现异常，对于同步处理（MessageProducer发送或者MessageConsumer调用receive方法）来说，因为是主动调用的，因此可以通过简单的定时重发来重新创建连接。如果是异步接收，即通过实现MessageListener，就比较麻烦，因为是别人回调你的代码。 这里当然需要使用ExceptionListener，来监听jms连接异常。并在异常发生后做一些事情，比如试图恢复连接，如果不能恢复，间隔一段时间再试图连接。 以前做法，是ExceptionListener监听到异常后，在onException方法中设置一个标志对象，另外有一个线程来定时监听这个标志对象，发现异常后做连接的恢复，并重建和注册MessageListener和ExceptionListener到连接。方法比较混乱和复杂。    发送文章为PDF   

星期三 八月 25th, 2010 in , , , | 1 Comment »