JTA 事务性资源实现示例

Question

我试图了解使远程/网络资源符合 JTA 的基本原则，但我对有关该主题的文档/博客/文章如此之少感到震惊。

假设我编写了自己的特殊类型的服务器，即“ IAmYourFaja ”服务器或“ IAYF ”。假设我编写/实现了我自己的基于 TCP 的网络协议，用于与该服务器进行交互，称为 IAYFCP（IAYF 通信协议）。最后，我编写了一个 Java 客户端库，用于通过 IAYFCP 访问和发送消息到远程 IAYF 服务器。还在我这儿？

现在我有一个用例，我需要执行以下分布式事务：

1. 在关系/JDBC 数据库中插入记录；然后
2. 向我的 IAYF 服务器发送消息；然后
3. 将消息推送到 JMS 代理

我需要所有这些进行交易，这样如果任何一个组件在任何时候出现故障，我都可以将它们全部回滚，并且这些网络资源中的状态不会发生任何改变。

最终目标是能够运行以下代码（此处为伪代码）：

// "JTA Example"
DistributedTransaction dTrans = getTransaction();
DataSource jdbcDataSource = getDataSource();
IayfClient iayfClient = getIayfClient();
JmsClient jmsClient = getJmsClient();
try {
    dTrans.begin();

    // 1. Insert a record in a relational/JDBC database
    insertRecord(jdbcDataSource, "INSERT INTO widgets ( fizz, buzz ) VALUES ( 35, true )");

    // 2. Fire a message to my IAYF server
    iayfClient.fireMessage(IayfMessages.LukeIamYourFaja, 12);

    // 3. Push a message to a JMS broker
    jmsClient.publishMessage("Noooooooooo! (then jumps off ledge and Vader goes off to the bar)");

    // If we get here then all 3 networked resources are ready/capable of committing, so do it, do it now!
    dTrans.commit();
} catch(Throwable t) {
    // Something went wrong, roll back all 3.
    dTrans.rollback();
}

所以我使用的 JDBC 驱动程序和 JMS 库已经是 JTA 兼容的。这意味着要使此代码成为可能，我需要使我的 IAYF 客户端库也与 JTA 兼容。问题是，我不明白我需要实现哪些 JTA 接口：

• UserTransaction; 或者
• XAResource

所以有几个问题：

1. 其界面做我需要实现（为什么）： ，XAResource，UserTransaction或两者兼而有之？
2. 这就是我遵守 JTA 并使我的 IAYF 客户端/服务具有交易性所需要做的全部吗？我还需要做什么才能使上面的“JTA 示例”代码按预期工作？
3. 对或错：Java EE 容器有自己的事务管理器，我可以使用接近零的配置来利用这些管理器，但是，如果我在非 Java EE/JTA 兼容容器中运行我的应用程序，那么我需要提供我自己的事务管理器，并且可以使用像Bitronix或Atomikos这样的东西来完成这个吗？

Answer 1

UserTransaction 接口是您在应用程序（上面的伪代码）中用于处理不同资源的接口。DistributedTransaction 将实现 UserTransaction 接口。DistributedTransaction 对象是您访问事务管理器的方式。

为了让事务管理器对您的 3 个不同资源执行分布式事务，每个资源都需要实现 XAResource 接口并以某种方式向事务管理器注册。如何向事务管理器注册的细节取决于实现。例如，请参阅 WebLogic 文档的这一部分：Registering an XAResource to Participate in Transactions

因此，您的客户端将实现 XAResource 并将 IAYFCP 与您的 IAYF 服务器对话。这也意味着您的 IAYFCP 协议将需要支持 2 阶段提交。

从第 3 部分开始，这个 JBossTS 文档也涵盖了 XAResource 接口。

是的，根据这篇关于 JTA 的维基百科文章，Bitronix、Atomikos 和 JBossTS 都被列为开源 JTA 实现。我建议选择一个，实现存根 XAResource，然后尝试向事务管理器注册您的“Hello, world”XAResource，以查看它会调用您的 start/prepare/commit/rollback 方法。