实际中碰到的一个异构系统之间数据交换的处理方式设计

情况描述:

两个不同的业务系统M系统与E系统,两者之间的数据交换采用ESB平台,从而可以保证ESB内部的数据传递流程可以具有一个全局的事务,一旦发生任何异常,都会回滚。

数据传递的方向为从M系统传递至E系统。

前期约定的内容,ESB获取M系统的数据,数据获取方式为从ESB与M系统约定的数据库中间表中获取(相当于M系统的前置机),调用E系统的WebService,将数据写入E系统,并且将调用是否成功的结果写回与M系统约定的中间表中(写回M系统中间表的工作由ESB负责完成),调用E系统的WS之后,除了回写与M系统的中间表,还会有一些其他的数据库更新等操作。

问题:

  1. 事务的问题可以交由ESB来处理,可以忽略。
  2. 调用WS如果数据未能写入E系统,WS不会抛出异常,而是会返回一个未能写入的代码,并返回原因。
  3. 调用WS成功,并且成功写入E系统,但是,在后续ESB处理其他事情的过程中发生异常,事务照样回滚。而E系统的WS,没有补偿机制,不会对数据是否已经存在进行判断,而且E系统的WS由于各种原因,调用时性能不佳

解决方案:

对于问题1。无需关注。

对于问题2。由于前期ESB与M系统约定,一旦发生ESB调用E系统的WS未能写入的情况,M系统会重新生成新的数据,而不是对原有数据进行修改。ESB只需将调用E系统的WS的结果返回写入中间表即可,不管任何一方发生异常,均由M系统重新生成数据,重新传递。这样ESB只需监控新增的数据,并按顺序执行相应操作即可。

对于问题3。就需要在调用E系统的WS之前,对E系统中是否存在相应数据进行判断,如果存在,并且同时最近一次调用时返回的结果为正常,则不再重复调用WS,而是直接执行后续操作;如果不存在或者调用时返回的结果不正常,甚至没有返回结果,则重新从头开始执行相应操作。

另外,如果没有与M系统关于调用E系统WS未能写入的情况的约定,则ESB需要根据E系统的WS的返回值进行判断,如果不正常,则可以直接抛出一个异常,从而回滚整个事务(当然,也可以暂时将异常数据暂存至另外的数据库表中或者其他什么位置,防止此问题数据重复出现),保证流程下次可以再次取得此数值。当然,这样也存在一个问题,就是回滚整个事务,与M系统约定的中间表中,就无法取到调用结果是否正常的信息,除非在ESB平台中有一个地方可以查看异常信息及数据,并且有专人来处理此类事情,否则,表面看起来就是ESB停在某条数据那里不动了,会对业务产生影响。

还有一种方案就是由于监控的增量数据都会记录在一个表中,如果发生调用E系统的WS未能写入数据的情况,则不允许ESB将监控到的增量数据删除,并不是抛出异常回滚整个事务,也就能够正常查看到产生错误的原因。

个人认为最后的解决方案是一个比较不错的思路,记录一下以飨自己。

原文地址:https://www.cnblogs.com/dyllove98/p/3174651.html