首页 > 其他 > 详细

解决ActiveMQ队列消费时提示JMSException:ClassNotFoundException

时间:2021-01-13 21:05:58      阅读:34      评论:0      收藏:0      [点我收藏+]

需求开发完成提测,测试时发现activemq的listener在消费队列消息时,程序捕获到异常。见下面log。
异常信息很明显,com.cn.yft.ora.entity.TAccReviewRecord这个class不存在。一看这个ClassNotFoundException异常,我联想到以前用redis存储热数据的时候也出现过。

2021-01-12 20:14:14,734 [ERROR] [ListenCommonSyncMQService-1] [com.yft.busi.mq.CommonSyncMQService:40] [队列发送]同步落地服务公司充值信息发送失败
javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFoundException: com.cn.yft.ora.entity.TAccReviewRecord
    at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:36)
    at org.apache.activemq.command.ActiveMQObjectMessage.getObject(ActiveMQObjectMessage.java:193)
    at com.yft.busi.mq.CommonSyncMQService.onMessage(CommonSyncMQService.java:31)
    at org.springframework.jms.listener.adapter.MessageListenerAdapter.onMessage(MessageListenerAdapter.java:341)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:537)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:497)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:468)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1102)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1094)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:991)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: com.cn.yft.ora.entity.TAccReviewRecord
    at org.apache.catalina.loader.WebappClassLoaderBase.loadClass(WebappClassLoaderBase.java:1928)
    at org.apache.catalina.loader.WebappClassLoaderBase.loadClass(WebappClassLoaderBase.java:1771)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:348)
    at org.apache.activemq.util.ClassLoadingAwareObjectInputStream.load(ClassLoadingAwareObjectInputStream.java:95)
    at org.apache.activemq.util.ClassLoadingAwareObjectInputStream.resolveClass(ClassLoadingAwareObjectInputStream.java:43)
    at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1868)
    at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1751)
    at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2042)
    at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
    at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)
    at org.apache.activemq.command.ActiveMQObjectMessage.getObject(ActiveMQObjectMessage.java:191)
    ... 11 more

 

为什么会出现这样的异常呢?
通常发生在系统实体类调整的时候,或,系统程序结构发生变化的时候。

先说本案,原因正是后者。原先是在同一个应用服务里使用了ActiveMQ。就是说同一个应用既是消息生产者又是消息消费者。生产者放入队列的消息TAccReviewRecord对象。那么,显然,当同应用里的消费者MessageListener监听到消息后,获取message携带的数据依然是程序里的TAccReviewRecord对象。
之所以出现了这个异常,是因为在开发新需求时,消息生产者是在另一个服务。另一个服务的TAccReviewRecord的package与原先服务里TAccReviewRecord的package不同,从而导致了上文的ClassNotFoundException异常。

再说说之前redis存取热数据遇到的这个异常,其原因是前者。 情况是设置缓存调用了redis.set(String key, Object value)方法,即value直接指定的VO对象。后来,程序调整了VO的目录结构。那么,重新发布到服务器上,再读取指定key的值时,就出现了这个ClassNotFoundException。

 

【解决办法】
为了规避类似问题,经过评估,采用了牺牲性能保证可用的策略,即,不再直接存放数据对象,而是将数据对象序列化为json串,读取的时候同样也做反序列化。


【附】
activemq producer代码(服务A)

public int sendToQueue(String conFactory,String userName, String pwd, String tCPUrl,
        final Object message, String qMName) {
    。。。
    Message testmessage = session.createObjectMessage((Serializable) message);
    // 发送消息到目的地方
    producer.send(testmessage);
    session.commit();
    。。。
}

activemq consumer代码(服务B) ----异常就是在第10行objectMessage.getObject()抛出来的

 1 @Component("commonSyncMQService")
 2 public class CommonSyncMQService implements MessageListener {
 3     private final static Logger logger = LoggerFactory.getLogger(CommonSyncMQService.class);
 4 
 5     @Override
 6     public void onMessage(Message message) {
 7         if (message instanceof ObjectMessage) {
 8             final ObjectMessage objectMessage = (ObjectMessage) message;
 9             try {
10                 logger.info("同步落地服务公司充值信息接口消息队列接收参数[{}]",objectMessage.getObject());
11                 TAccReviewRecord reviewRecord = (TAccReviewRecord) objectMessage.getObject();
12                 。。。
13             } catch (final Exception e) {
14                 logger.error("[队列发送]同步落地服务公司充值信息发送失败", e);
15             }
16         }
17     }
18 }

 

activemq producer(服务A)存放json串后,activemq consumer(服务B) 改造后:

 1 @Component("commonSyncMQService")
 2 public class CommonSyncMQService implements MessageListener {
 3     private final static Logger logger = LoggerFactory.getLogger(CommonSyncMQService.class);
 4     @Autowired
 5     private SyncAccReviewRecordService syncAccReviewRecordService;
 6 
 7     @Override
 8     public void onMessage(Message message) {
 9         if (message instanceof ObjectMessage) {
10             final ObjectMessage objectMessage = (ObjectMessage) message;
11             try {
12                 logger.info("同步落地服务公司充值信息接口消息队列接收参数[{}]",objectMessage.getObject());
13                 TAccReviewRecord reviewRecord = JSONObject.parseObject(String.valueOf(objectMessage.getObject()),TAccReviewRecord.class);
14                 。。。
15             } catch (final Exception e) {
16                 logger.error("[队列发送]同步落地服务公司充值信息发送失败", e);
17             }
18         }
19     }
20 }

 

解决ActiveMQ队列消费时提示JMSException:ClassNotFoundException

原文:https://www.cnblogs.com/buguge/p/14273332.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!