6

我正在尝试了解使远程/网络资源与 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 接口：

所以有几个问题：

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

1 回答 1

5

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

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

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

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

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

于 2014-12-19T06:54:59.320 回答