io.jboot.support.seata.tcc

类 TCCFenceHandler

java.lang.Object

io.jboot.support.seata.tcc.TCCFenceHandler

public class TCCFenceHandler
extends Object

TCC Fence Handler(idempotent, non_rollback, suspend)

作者:

kaka2code

嵌套类概要

嵌套类

限定符和类型	类和说明
private static class	TCCFenceHandler.FenceLogCleanRunnable clean fence log that has the final status runnable.
private static class	TCCFenceHandler.FenceLogIdentity

字段概要

字段

限定符和类型	字段和说明
private static DataSource	dataSource
private static TCCFenceHandler.FenceLogCleanRunnable	fenceLogCleanRunnable
private static LinkedBlockingQueue<TCCFenceHandler.FenceLogIdentity>	LOG_QUEUE
private static ExecutorService	logCleanExecutor
private static org.slf4j.Logger	LOGGER
private static int	MAX_QUEUE_SIZE
private static int	MAX_THREAD_CLEAN
private static io.seata.rm.tcc.store.TCCFenceStore	TCC_FENCE_DAO

构造器概要

构造器

限定符	构造器和说明
private	TCCFenceHandler()

方法概要

限定符和类型	方法和说明
private static void	addToLogCleanQueue(String xid, long branchId)
static boolean	commitFence(Method commitMethod, Object targetTCCBean, String xid, Long branchId, Object[] args) tcc commit method enhanced
static boolean	deleteFence(String xid, Long branchId) Delete TCC Fence
private static void	initLogCleanExecutor()
private static boolean	insertTCCFenceLog(Connection conn, String xid, Long branchId, String actionName, Integer status) Insert TCC fence log
static Object	prepareFence(String xid, Long branchId, String actionName) tcc prepare method enhanced
static boolean	rollbackFence(Method rollbackMethod, Object targetTCCBean, String xid, Long branchId, Object[] args, String actionName) tcc rollback method enhanced
private static boolean	updateStatusAndInvokeTargetMethod(Connection conn, Method method, Object targetTCCBean, String xid, Long branchId, int status, Object[] args) Update TCC Fence status and invoke target method

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

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

字段详细资料

LOGGER

private static final org.slf4j.Logger LOGGER

TCC_FENCE_DAO

private static final io.seata.rm.tcc.store.TCCFenceStore TCC_FENCE_DAO

dataSource

private static DataSource dataSource

MAX_THREAD_CLEAN

private static final int MAX_THREAD_CLEAN

另请参阅:

常量字段值

MAX_QUEUE_SIZE

private static final int MAX_QUEUE_SIZE

另请参阅:

常量字段值

LOG_QUEUE

private static final LinkedBlockingQueue<TCCFenceHandler.FenceLogIdentity> LOG_QUEUE

fenceLogCleanRunnable

private static TCCFenceHandler.FenceLogCleanRunnable fenceLogCleanRunnable

logCleanExecutor

private static ExecutorService logCleanExecutor

构造器详细资料

TCCFenceHandler

private TCCFenceHandler()

方法详细资料

prepareFence

public static Object prepareFence(String xid,
                                  Long branchId,
                                  String actionName)

tcc prepare method enhanced

参数:

xid - the global transaction id

branchId - the branch transaction id

actionName - the action name

返回:

the boolean

commitFence

public static boolean commitFence(Method commitMethod,
                                  Object targetTCCBean,
                                  String xid,
                                  Long branchId,
                                  Object[] args)

tcc commit method enhanced

参数:

commitMethod - commit method

targetTCCBean - target tcc bean

xid - the global transaction id

branchId - the branch transaction id

args - commit method's parameters

返回:

the boolean

rollbackFence

public static boolean rollbackFence(Method rollbackMethod,
                                    Object targetTCCBean,
                                    String xid,
                                    Long branchId,
                                    Object[] args,
                                    String actionName)

tcc rollback method enhanced

参数:

rollbackMethod - rollback method

targetTCCBean - target tcc bean

xid - the global transaction id

branchId - the branch transaction id

args - rollback method's parameters

actionName - the action name

返回:

the boolean

insertTCCFenceLog

private static boolean insertTCCFenceLog(Connection conn,
                                         String xid,
                                         Long branchId,
                                         String actionName,
                                         Integer status)

Insert TCC fence log

参数:

conn - the db connection

xid - the xid

branchId - the branchId

status - the status

返回:

the boolean

updateStatusAndInvokeTargetMethod

private static boolean updateStatusAndInvokeTargetMethod(Connection conn,
                                                         Method method,
                                                         Object targetTCCBean,
                                                         String xid,
                                                         Long branchId,
                                                         int status,
                                                         Object[] args)
                                                  throws Exception

Update TCC Fence status and invoke target method

参数:

method - target method

targetTCCBean - target bean

xid - the global transaction id

branchId - the branch transaction id

status - the tcc fence status

返回:

the boolean

抛出:

Exception

initLogCleanExecutor

private static void initLogCleanExecutor()

deleteFence

public static boolean deleteFence(String xid,
                                  Long branchId)

Delete TCC Fence

参数:

xid - the global transaction id

branchId - the branch transaction id

返回:

the boolean

addToLogCleanQueue

private static void addToLogCleanQueue(String xid,
                                       long branchId)