JBoss 7.0中如何编程创建并注册自定义XaResourceRecoveryHelper

1. 引入必要模块依赖 #

JBoss 7采用模块系统管理依赖，无需在pom.xml中直接添加Arjuna相关jar包，只需在项目的WEB-INF或META-INF目录下创建jboss-deployment-structure.xml，声明所需模块依赖：

<jboss-deployment-structure>
    <deployment>
        <dependencies>
            <!-- 引入Arjuna JTS核心模块 -->
            <module name="org.jboss.jts" export="true"/>
            <!-- 引入JBoss JCA事务处理模块 -->
            <module name="org.jboss.jca.core" export="true"/>
        </dependencies>
    </deployment>
</jboss-deployment-structure>

配置完成后，即可在代码中访问com.arjuna.ats.jts.recovery.XaResourceRecoveryHelper等目标类。

2. 实现自定义XaResourceRecoveryHelper #

编写自定义实现类，重写getXAResources方法，在方法内捕获异常并处理，避免测试场景下的javax.resource.ResourceException日志输出：

import com.arjuna.ats.jts.recovery.XaResourceRecoveryHelper;
import javax.transaction.xa.XAResource;

public class CustomXaResourceRecoveryHelper implements XaResourceRecoveryHelper {

    @Override
    public XAResource[] getXAResources() throws Exception {
        try {
            // 测试场景下可直接返回空数组，避免资源连接尝试
            return new XAResource[0];
            
            // 若需获取已有数据源的XAResource，可通过JNDI查找后返回
            // Context ctx = new InitialContext();
            // XADataSource xaDs = (XADataSource) ctx.lookup("java:jboss/datasources/YourTargetDS");
            // return new XAResource[]{xaDs.getXAConnection().getXAResource()};
        } catch (Exception e) {
            // 捕获异常并静默处理，不向外抛出以阻止日志输出
            return new XAResource[0];
        }
    }
}

3. 编程注册自定义Helper到恢复系统 #

通过Servlet上下文监听器，在应用启动时将自定义Helper注册到Arjuna的RecoveryManager：

import com.arjuna.ats.arjuna.recovery.RecoveryManager;
import com.arjuna.ats.jts.recovery.XaResourceRecoveryHelper;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class RecoveryHelperRegistrar implements ServletContextListener {

    @Override
    public void contextInitialized(ServletContextEvent sce) {
        // 获取Arjuna恢复管理器实例
        RecoveryManager recoveryManager = RecoveryManager.manager();
        // 创建并添加自定义Helper
        XaResourceRecoveryHelper customHelper = new CustomXaResourceRecoveryHelper();
        recoveryManager.addXAResourceRecoveryHelper(customHelper);
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
        // 可选：应用销毁时移除Helper
        RecoveryManager recoveryManager = RecoveryManager.manager();
        recoveryManager.removeXAResourceRecoveryHelper(new CustomXaResourceRecoveryHelper());
    }
}

在web.xml中注册该监听器：

<listener>
    <listener-class>com.your.package.RecoveryHelperRegistrar</listener-class>
</listener>

4. 替代方案：通过配置文件注册 #

若无需编程实现，可直接在standalone.xml的事务子系统中配置自定义Helper：
在<subsystem xmlns="urn:jboss:domain:transactions:1.1">节点下添加：

<recovery>
    <resource-recovery-helpers>
        <class-name>com.your.package.CustomXaResourceRecoveryHelper</class-name>
    </resource-recovery-helpers>
</recovery>

JBoss启动时会自动加载并实例化该Helper，无需额外代码。

内容的提问来源于stack exchange，提问作者Andrzej Więcławski