背景
我有一个 Spring 客户端应用程序,它使用 RMI 为两个服务器提供服务。在客户端中,我将一个实体保存到数据库中(简单),并使用实体的详细信息对两个服务器进行 rmi 调用。我在服务器上使用 Spring 3.0.2,客户端是一个简单的 Spring-mvc 站点。
要求
我的要求是,如果对服务器的任何 rmi 调用失败,整个事务将回滚,即实体不会保存在客户端上,如果任何一个 rmi 调用成功,这也会回滚。
我对分布式事务比较陌生,但我想我想要一个使用 RMI 调用的类似 XA 的事务。
我确实找到了关于这个主题的一个很好的链接 here但它没有提到对不同服务器调用两个远程方法调用时的模式。我很想在推荐阅读方面听到更多关于这个主题的信息,以及关于如何使用 spring 实现这一点的任何指示。为此可能使用事务管理器吗?
谢谢。
最佳答案
这是理论上如何处理这种情况的方法。首先你需要在每个节点上有几个 JTA 分布式事务管理器。一个充当主人,另一个充当奴隶。 master 协调分布式事务到 slaves 的提交/回滚。存在独立的 JTA 实现,例如JOTM .
Vanilla RMI 不支持传播上下文信息,例如操作的事务 ID。但我认为 RMI 有钩子(Hook),因此它可以扩展以支持它。你可以看看Carol .
您将需要使用 XAResource将参与者包装在事务中,以便他们可以参与分布式事务。 master 需要向 slaves 发送提交/回滚消息,这需要使用 XATerminator采取相应行动。
JTA 规范只是一个分布式事务管理器,事务日志中的操作记录需要由服务器来完成。存在用于事务日志管理的库,例如HOWL .
我不认为可以使用 Spring —— 即使使用分布式事务管理器 —— 来轻松地做到这一点。我试过一次使用 RMI 和分布式事务控制从一个独立的客户端和几个奴隶。这是一个 blog post关于它。这相当复杂。
如果您使用带有 IIOP 的 Java EE 应用程序服务器,则可以免费获得所有这些。 IIOP 支持分布式事务传播。客户端可以是 application client container ,您可以使用 UserTransaction 控制交易.这实际上是一种罕见的情况,我认为在这种情况下使用应用服务器确实是合理的。
不过话说回来,分布式事务是个复杂的东西,会导致启发式失败,一个节点挂掉就会超时,恢复过程也很复杂。
我最后的建议是:如果可能的话,尽量找一个不涉及分布式事务的设计。这会让你喜欢的更容易。
您或许可以从 BPEL 中汲取灵感 compensation mechanism .可能还有其他用于错误处理和稳健性的设计方法可以避免使用分布式事务。
关于java - Spring分布式事务涉及RMI调用可能吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/3148090/
我试图获取一个长度在1到10之间的字符串,并输出将字符串分解为大小为1、2或3的连续子字符串的所有可能方式。例如:输入:123456将整数分割成单个字符,然后继续查找组合。该代码将返回以下所有数组。[1,2,3,4,5,6][12,3,4,5,6][1,23,4,5,6][1,2,34,5,6][1,2,3,45,6][1,2,3,4,56][12,34,5,6][12,3,45,6][12,3,4,56][1,23,45,6][1,2,34,56][1,23,4,56][12,34,56][123,4,5,6][1,234,5,6][1,2,345,6][1,2,3,456][123
我发现ActiveRecord::Base.transaction在复杂方法中非常有效。我想知道是否可以在如下事务中从AWSS3上传/删除文件:S3Object.transactiondo#writeintofiles#raiseanexceptionend引发异常后,每个操作都应在S3上回滚。S3Object这可能吗?? 最佳答案 虽然S3API具有批量删除功能,但它不支持事务,因为每个删除操作都可以独立于其他操作成功/失败。该API不提供任何批量上传功能(通过PUT或POST),因此每个上传操作都是通过一个独立的API调用完成的
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么? 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设? 关于java-等价于Java中的RubyHash,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/22737685/
我正在使用Ruby2.1.1和Rails4.1.0.rc1。当执行railsc时,它被锁定了。使用Ctrl-C停止,我得到以下错误日志:~/.rvm/gems/ruby-2.1.1/gems/spring-1.1.2/lib/spring/client/run.rb:47:in`gets':Interruptfrom~/.rvm/gems/ruby-2.1.1/gems/spring-1.1.2/lib/spring/client/run.rb:47:in`verify_server_version'from~/.rvm/gems/ruby-2.1.1/gems/spring-1.1.
我正在尝试编写一个将文件上传到AWS并公开该文件的Ruby脚本。我做了以下事情:s3=Aws::S3::Resource.new(credentials:Aws::Credentials.new(KEY,SECRET),region:'us-west-2')obj=s3.bucket('stg-db').object('key')obj.upload_file(filename)这似乎工作正常,除了该文件不是公开可用的,而且我无法获得它的公共(public)URL。但是当我登录到S3时,我可以正常查看我的文件。为了使其公开可用,我将最后一行更改为obj.upload_file(file
如何在ruby中调用C#dll? 最佳答案 我能想到几种可能性:为您的DLL编写(或找人编写)一个COM包装器,如果它还没有,则使用Ruby的WIN32OLE库来调用它;看看RubyCLR,其中一位作者是JohnLam,他继续在Microsoft从事IronRuby方面的工作。(估计不会再维护了,可能不支持.Net2.0以上的版本);正如其他地方已经提到的,看看使用IronRuby,如果这是您的技术选择。有一个主题是here.请注意,最后一篇文章实际上来自JohnLam(看起来像是2009年3月),他似乎很自在地断言RubyCL
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java,并成功地将它与另一个Java包一起使用,但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我需要一些关于TDD概念的帮助。假设我有以下代码defexecute(command)casecommandwhen"c"create_new_characterwhen"i"display_inventoryendenddefcreate_new_character#dostufftocreatenewcharacterenddefdisplay_inventory#dostufftodisplayinventoryend现在我不确定要为什么编写单元测试。如果我为execute方法编写单元测试,那不是几乎涵盖了我对create_new_character和display_invent
我有一个涉及多台机器、消息队列和事务的问题。因此,例如用户点击网页,点击将消息发送到另一台机器,该机器将付款添加到用户的帐户。每秒可能有数千次点击。事务的所有方面都应该是容错的。我以前从未遇到过这样的事情,但一些阅读表明这是一个众所周知的问题。所以我的问题。我假设安全的方法是使用两阶段提交,但协议(protocol)是阻塞的,所以我不会获得所需的性能,我是否正确?我通常写Ruby,但似乎Redis之类的数据库和Rescue、RabbitMQ等消息队列系统对我的帮助不大——即使我实现某种两阶段提交,如果Redis崩溃,数据也会丢失,因为它本质上只是内存。所有这些让我开始关注erlang和
我只想对我一直在思考的这个问题有其他意见,例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我