net.neoremind.fountain.support
类 ThreadHolder

java.lang.Object
  net.neoremind.fountain.support.ThreadHolder

public class ThreadHolder
extends Object

ThreadLocal线程保存辅助类

作者：

zhangxu

字段摘要

static ThreadLocal<SyncPoint>	SYNC_POINT_CACHE SyncPoint的内存缓存，缓存当producer中已经接收到的最后的SyncPoint，当数据源不可用并选择新的数据源时 直接使用该SyncPoint继续接收。
static ThreadLocal<TrxContext>	TRX_CONTEXT 事务上下文

构造方法摘要

ThreadHolder()

方法摘要

static void	cleanTrxContext() 清空线程上下文
static TrxContext	getTrxContext() 获取事务上下文
static void	setTrxContext(TrxContext trxContext) 初始化线程上下文

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

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

字段详细信息

SYNC_POINT_CACHE

public static final ThreadLocal<SyncPoint> SYNC_POINT_CACHE

SyncPoint的内存缓存，缓存当producer中已经接收到的最后的SyncPoint，当数据源不可用并选择新的数据源时 直接使用该SyncPoint继续接收。

当fountain-producer和fountain-consumer部署在同一进程中时，生产者接收的数据会放入一个内存mq， 消费者从该内存mq获取消息消费，消费完成后消费者记录当前已经消费的SyncPoint，此时生产者的SyncPoint远远大于 已经消费的SyncPoint， 如果重新选择数据源时从消费者记录的gtid恢复数据接收，则会出现大量重复数据,使用 本方法将避免如此问题。

TRX_CONTEXT

public static final ThreadLocal<TrxContext> TRX_CONTEXT

事务上下文

构造方法详细信息

ThreadHolder

public ThreadHolder()

方法详细信息

cleanTrxContext

public static final void cleanTrxContext()

清空线程上下文

setTrxContext

public static final void setTrxContext(TrxContext trxContext)

初始化线程上下文

getTrxContext

public static TrxContext getTrxContext()

获取事务上下文

返回：

TrxContext