通过JMS MessageListener调用JPA事务时提交失败

Question

我有一个代码可以很好地工作，但当负载很高时失败。无法找到原因的路线。下面是我的用例概述

1. 我正在从JMS队列中读取消息
2. 使用接收到的消息调用一个REST APIendpoint
3. 在我的数据库中保存从#2收到的响应

下面是代码片段

 //Message Listener class which reads the messages from JMS Queue
 public class MyListener implements MessageListener {
        @Autowired
        MyDao myDao;

        @Override
        public void onMessage(Message message) {
             MyResponse resp = callRest(message);
             myDao.saveToDb(resp);
       }
    }

    //DAO class which updates my entity   
    @Component
    public class MyDao {
          @Autowired
          EntityManager entityManager;

          @Transactional
           public boolean saveToDb(MyResponse resp) {
             Query query = entityManager.createQuery("from MyTable mt where mt.id=:id");
             query.setParameter("id", myResp.getId());
             MyTable myTab = (MyTable) query.getSingleResult();
             myTab.setProcessFlag(true);
             entityManager.merge(myTab);
          }
     }

当我在调试模式下运行时，或者当消息不太频繁地进入队列时，这种方法很好。

但是当队列中的消息非常快时，我在saveToDb方法中得到异常

org.springframework.transaction.TransactionSystemException: Could not commit JPA transaction; nested exception is javax.persistence.RollbackException: Error while committing the transaction

当多个线程同时访问JMS和JPA事务时，我是不是做错了什么，或者JMS和JPA事务之间是否有一些混淆？

提前致谢。

Answer 1

当您调用也标记为@Transactional的嵌套方法/服务时，会发生此异常。

了解更多详情