现在手上有一个项目是通过mule的socket与外围系统进行通信。
问题是如何处理事务呢?
如:
public void methodA(){
socketA();//发送报文给A系统
socketB();//发送报文给B系统
updateDB();//更新本系统的状态
}
如果socketA/socketB成功了,updateDB失败了,怎么回滚A与B系统的事物?
系统使用的是典型SSH框架。
现在手上有一个项目是通过mule的socket与外围系统进行通信。
问题是如何处理事务呢?
如:
public void methodA(){
socketA();//发送报文给A系统
socketB();//发送报文给B系统
updateDB();//更新本系统的状态
}
如果socketA/socketB成功了,updateDB失败了,怎么回滚A与B系统的事物?
系统使用的是典型SSH框架。
socket没有事务源,实现两阶段事务比较麻烦,不过可以使用补偿式事务,即当
socketA();//成功
socketB();//成功
updateDB();//失败
时
调用
cancelSocketA();
cancelSocketB();
cancelSocketA,ancelSocketB为自己实现的补偿式操作.
如果无法补偿的情况下也可以使用以下方案:
先检查updateDB()是否存在业务失败的可能性,
然后socketA(), socketB();
当都成功了,通过启一个任务不断重试,直到updateDB成功为止(为防止系统异常导致updateDB失败,必须通过任务形式调)