程序包 com.sie.mbm.mom.framework.db.executeDme.service

类 DmeDistributedTransactionalExecuteImpl

java.lang.Object

com.sie.mbm.mom.framework.db.executeDme.service.DmeDistributedTransactionalExecuteImpl

所有已实现的接口:

DmeTransactionalExecute

@Component
public class DmeDistributedTransactionalExecuteImpl
extends Object
implements DmeTransactionalExecute

参考：http://docs.dme.com/pages/58712b

字段概要

字段

修饰符和类型	字段	说明
private DmeTransactionalExecuteImpl	dmeTransactionalExecuteImpl
private MbmTransactionalExecuteImpl	mbmTransactionalExecuteImpl
private TransactionalTaskNoDelegator	transactionalTaskNoDelegator

构造器概要

构造器

构造器	说明
DmeDistributedTransactionalExecuteImpl()

方法概要

修饰符和类型	方法	说明
boolean	beginTransactional(DmeTransactional dmeTransactional)	开启分布式事务
void	clearContext(DmeTransactional dmeTransactional)	清空事务的ThreadLocalContext 清空分布式事务的ThreadLocalContext
boolean	commitTransactional(DmeTransactional dmeTransactional)	提交分布式事务
cn.hutool.core.lang.Pair<String,Integer>	getAndIncreaseTransactionTaskId()	获取分布式事务任务信息, 没有则返回空指针; 自动对任务no + 1
private DmeTransactionalExecute	getExecuteInstance(DmeTransactional dmeTransactional)	获取执行器
private boolean	isCaller()	判定当前是否是事务的调用者
boolean	isDistributedTransactionContext()	判定当前是否是分布式事务上下文
private void	reloadTaskNo()	从分布式缓存更新taskNo到本地事务数据中
boolean	rollbackTransactional(DmeTransactional dmeTransactional, Exception exception)	回滚分布式事务

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

dmeTransactionalExecuteImpl

@Autowired
private DmeTransactionalExecuteImpl dmeTransactionalExecuteImpl

mbmTransactionalExecuteImpl

@Autowired
private MbmTransactionalExecuteImpl mbmTransactionalExecuteImpl

transactionalTaskNoDelegator

@Autowired
private TransactionalTaskNoDelegator transactionalTaskNoDelegator

构造器详细资料

DmeDistributedTransactionalExecuteImpl

public DmeDistributedTransactionalExecuteImpl()

方法详细资料

beginTransactional

public boolean beginTransactional(DmeTransactional dmeTransactional)

开启分布式事务

指定者:

beginTransactional 在接口中 DmeTransactionalExecute

commitTransactional

public boolean commitTransactional(DmeTransactional dmeTransactional)

提交分布式事务

指定者:

commitTransactional 在接口中 DmeTransactionalExecute

rollbackTransactional

public boolean rollbackTransactional(DmeTransactional dmeTransactional,
 Exception exception)

回滚分布式事务

指定者:

rollbackTransactional 在接口中 DmeTransactionalExecute

isDistributedTransactionContext

public boolean isDistributedTransactionContext()

判定当前是否是分布式事务上下文

getAndIncreaseTransactionTaskId

@Nullable
public cn.hutool.core.lang.Pair<String,Integer> getAndIncreaseTransactionTaskId()

获取分布式事务任务信息, 没有则返回空指针; 自动对任务no + 1

指定者:

getAndIncreaseTransactionTaskId 在接口中 DmeTransactionalExecute

返回:

任务id 和 任务号

clearContext

public void clearContext(DmeTransactional dmeTransactional)

清空事务的ThreadLocalContext 清空分布式事务的ThreadLocalContext

指定者:

clearContext 在接口中 DmeTransactionalExecute

isCaller

private boolean isCaller()

判定当前是否是事务的调用者

返回:

是: 事务的调用者 否: 不是

reloadTaskNo

private void reloadTaskNo()

从分布式缓存更新taskNo到本地事务数据中

getExecuteInstance

private DmeTransactionalExecute getExecuteInstance(DmeTransactional dmeTransactional)

获取执行器