com.codingapi.tx.netty.service.impl

类 MQTxManagerServiceImpl

java.lang.Object

com.codingapi.tx.netty.service.impl.MQTxManagerServiceImpl

所有已实现的接口:

MQTxManagerService

@Service
public class MQTxManagerServiceImpl
extends Object
implements MQTxManagerService

Created by lorne on 2017/6/30.

构造器概要

构造器

构造器和说明
MQTxManagerServiceImpl()

方法概要

限定符和类型	方法和说明
TxGroup	addTransactionGroup(String groupId, String taskId, boolean isGroup, String methodStr) 添加事务组子对象
int	checkTransactionInfo(String groupId, String taskId) 检查事务状态 通过netty管道
int	clearTransaction(String groupId, String waitTaskId, boolean isGroup) 检查并清理事务数据
int	closeTransactionGroup(String groupId, int state) 关闭事务组-进入事务提交第一阶段
TxGroup	createTransactionGroup() 创建事务组
int	getTransaction(String groupId, String waitTaskId) 检查事务状态 通过http请求
String	httpGetServer() 获取TM服务地址
void	sendCompensateMsg(String groupId, long time, TxTransactionInfo info) 记录补偿事务数据到tm
void	uploadModelInfo() 上传模块信息

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

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

构造器详细资料

MQTxManagerServiceImpl

public MQTxManagerServiceImpl()

方法详细资料

createTransactionGroup

public TxGroup createTransactionGroup()

从接口复制的说明: MQTxManagerService

创建事务组

指定者:

createTransactionGroup 在接口中 MQTxManagerService

返回:

事务组TxGroup

addTransactionGroup

public TxGroup addTransactionGroup(String groupId,
                                   String taskId,
                                   boolean isGroup,
                                   String methodStr)

从接口复制的说明: MQTxManagerService

添加事务组子对象

指定者:

addTransactionGroup 在接口中 MQTxManagerService

参数:

groupId - 事务组id

taskId - 任务Id

isGroup - 是否合并到事务组 true合并 false不合并

methodStr - 方法参数列表

返回:

事务组TxGroup

closeTransactionGroup

public int closeTransactionGroup(String groupId,
                                 int state)

从接口复制的说明: MQTxManagerService

关闭事务组-进入事务提交第一阶段

指定者:

closeTransactionGroup 在接口中 MQTxManagerService

参数:

groupId - 事务组id

state - 提交或者回滚 1提交0回滚

返回:

1 成功 0失败

uploadModelInfo

public void uploadModelInfo()

从接口复制的说明: MQTxManagerService

上传模块信息

指定者:

uploadModelInfo 在接口中 MQTxManagerService

checkTransactionInfo

public int checkTransactionInfo(String groupId,
                                String taskId)

从接口复制的说明: MQTxManagerService

检查事务状态 通过netty管道

指定者:

checkTransactionInfo 在接口中 MQTxManagerService

参数:

groupId - 事务组id

taskId - 任务id

返回:

事务状态

getTransaction

public int getTransaction(String groupId,
                          String waitTaskId)

从接口复制的说明: MQTxManagerService

检查事务状态 通过http请求

指定者:

getTransaction 在接口中 MQTxManagerService

参数:

groupId - 事务组id

waitTaskId - 任务id

返回:

事务状态

clearTransaction

public int clearTransaction(String groupId,
                            String waitTaskId,
                            boolean isGroup)

从接口复制的说明: MQTxManagerService

检查并清理事务数据

指定者:

clearTransaction 在接口中 MQTxManagerService

参数:

groupId - 事务组id

waitTaskId - 任务id

isGroup - 是否合并事务

返回:

事务状态

httpGetServer

public String httpGetServer()

从接口复制的说明: MQTxManagerService

获取TM服务地址

指定者:

httpGetServer 在接口中 MQTxManagerService

返回:

txServer

sendCompensateMsg

public void sendCompensateMsg(String groupId,
                              long time,
                              TxTransactionInfo info)

从接口复制的说明: MQTxManagerService

记录补偿事务数据到tm

指定者:

sendCompensateMsg 在接口中 MQTxManagerService

参数:

groupId - 事务组Id

time - 执行时间

info - 事务信息