捕获消息驱动Bean(MDB)中的异常

Question

我该如何处理mdb中的异常？我有一种有趣的感觉,异常发生在try catch块之后,所以我无法捕获并记录它.Glassfish v3决定重复整个信息.它会运行到一个无限循环中,并在硬盘上写入很多日志文件.

我正在使用Glassfishv3.01 + Eclipselink 2.0.1

public class SaveAdMessageDrivenBean implements MessageListener {

    @PersistenceContext(unitName="QIS") 
    private EntityManager em;

    @Resource
    private MessageDrivenContext mdc;

    public void onMessage(Message message) {
        try {
            if (message instanceof ObjectMessage) {
                ObjectMessage obj = (ObjectMessage)message;
                AnalyzerResult alyzres = (AnalyzerResult)obj.getObject();
                save(alyzres);
            }
        } catch (Throwable e) { 
            mdc.setRollbackOnly();
            log.log(Level.SEVERE, e);
        }
    }

    @TransactionAttribute(TransactionAttributeType.REQUIRED)
    private void save(AnalyzerResult alyzres) throws PrdItemNotFoundException {

       Some s = em.find(Some.class, somepk);
       s.setSomeField("newvalue");

       // SQL Exception happens after leaving this method because of missing field for ex.
    }
}    

Answer 1

你有一个消息中毒的坏情况......

我看到的主要问题是:

• 你直接调用你的save()方法onMessage():这意味着容器无法在save方法周围注入正确的事务处理代理
• 在任何情况下该save()方法都应该具有 @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)以便在单独的事务中提交,否则它将加入onMessage事务(默认为REQUIRED)并绕过您的异常处理代码,在成功执行之后进行beign提交onMessage

我要做的是:

将save方法移动到新的无状态会话Bean:

@Stateless
public class AnalyzerResultSaver
{
    @PersistenceContext(unitName="QIS") 
    private EntityManager em;

    @TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
    private void save(AnalyzerResult alyzres) throws PrdItemNotFoundException {
        Some s = em.find(Some.class, somepk);
        s.setSomeField("newvalue");
        // SQL Exception happens after leaving this method
    }
}

在MDB中注入此bean:

public class SaveAdMessageDrivenBean implements MessageListener {

    @Inject  
    private AnalyzerResultSaver saver;

    @Resource
    private MessageDrivenContext mdc;

    public void onMessage(Message message) {
        try {
            if (message instanceof ObjectMessage) {
                ObjectMessage obj = (ObjectMessage)message;
                AnalyzerResult alyzres = (AnalyzerResult)obj.getObject();
                saver.save(alyzres);
            }
        } catch (Throwable e) { 
            mdc.setRollbackOnly();
            log.log(Level.SEVERE, e);
        }
    }
}

另一个提示:在此代码中,消息中毒仍然存在.现在它来自行调用mdc.setRollbackOnly();.

我建议在这里记录异常并将消息传送到毒性队列,从而阻止容器无限制地重新提交消息.

更新:

"毒性队列"或"错误队列"只是保证您的(希望可恢复的)丢弃的消息不会完全丢失的意思.它在集成场景中被大量使用,其中无法保证消息数据的正确性.

设置中毒队列意味着定义目标队列或主题,并将"错误"消息重新发送到此目标.

操作员应定期检查此队列(通过专用应用程序)并修改消息并重新提交到"正常"队列,或丢弃该消息并要求重新发送.