cn.weforward.data.counter.support

类 DbCounterFactory

java.lang.Object

cn.weforward.data.counter.support.AbstractCounterFactory

cn.weforward.data.counter.support.DbCounterFactory

所有已实现的接口:

cn.weforward.common.GcCleanable, CounterFactory, Iterable<Counter>

直接已知子类:

LabelCounterFactory

public abstract class DbCounterFactory
extends AbstractCounterFactory
implements CounterFactory, cn.weforward.common.GcCleanable

存储于数据库的计数器实现 以“计数器名_cnt”组织，多个服务器存储于同一记录下的不同字段，其相加值则为总计数值，由此支持最终一致的分布计数器 分布存储值的各字段名为：“v_服务器标识”

作者:

liangyi

字段概要

字段

限定符和类型	字段和说明
protected boolean	m_CopyOnFlush
protected int	m_Expire 计数器项重新加载间隔（秒）
protected Flusher	m_Flusher
protected int	m_MaxBatch 每次批量刷写的项数
protected int	m_NullTimeout NULL值重新加载间隔（秒）
protected String	m_ServerId

从接口继承的字段 cn.weforward.common.GcCleanable

POLICY_CRITICAL, POLICY_IDLE, POLICY_LOW, POLICY_MAINTAIN, POLICY_MASK, POLICY_OPTIMIZE

构造器概要

构造器

构造器和说明
DbCounterFactory(String serverId)

方法概要

限定符和类型	方法和说明
protected abstract CounterItem	doLoad(DbCounter counter, String id) 由数据库加载计数项
protected abstract void	doNew(DbCounter counter, CounterItem item) （可能是）新的计数项，用于及时把新项写入数据库，此实现可选择略过
protected abstract void	doUpdate(DbCounter counter, cn.weforward.common.util.LruCache.DirtyData<CounterItem> data) 更新计数项到数据库
int	getExpire()
Flusher	getFlusher()
int	getMaxBatch()
String	getServerId()
boolean	isCopyOnFlush()
void	onGcCleanup(int policy)
void	setCopyOnFlush(boolean enabled) 开启/关闭刷写时先复制待更新列表，用于在LabelSet.put慢速或直接写入的情况下使用
void	setExpire(int expire)
void	setFlusher(Flusher flusher)
void	setMaxBatch(int limit)
void	setNullTimeout(int seconds)

从类继承的方法 cn.weforward.data.counter.support.AbstractCounterFactory

createCounter, doCreateCounter, getCounter, iterator, openCounter

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

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

从接口继承的方法 cn.weforward.data.counter.CounterFactory

createCounter, getCounter, openCounter

从接口继承的方法 java.lang.Iterable

forEach, iterator, spliterator

字段详细资料

m_ServerId

protected String m_ServerId

m_Flusher

protected Flusher m_Flusher

m_CopyOnFlush

protected boolean m_CopyOnFlush

m_NullTimeout

protected int m_NullTimeout

NULL值重新加载间隔（秒）

m_MaxBatch

protected int m_MaxBatch

每次批量刷写的项数

m_Expire

protected int m_Expire

计数器项重新加载间隔（秒）

构造器详细资料

DbCounterFactory

public DbCounterFactory(String serverId)

方法详细资料

setFlusher

public void setFlusher(Flusher flusher)

getFlusher

public Flusher getFlusher()

getServerId

public String getServerId()

setCopyOnFlush

public void setCopyOnFlush(boolean enabled)

开启/关闭刷写时先复制待更新列表，用于在LabelSet.put慢速或直接写入的情况下使用

参数:

enabled - 是否开启

isCopyOnFlush

public boolean isCopyOnFlush()

setNullTimeout

public void setNullTimeout(int seconds)

setMaxBatch

public void setMaxBatch(int limit)

getMaxBatch

public int getMaxBatch()

setExpire

public void setExpire(int expire)

getExpire

public int getExpire()

onGcCleanup

public void onGcCleanup(int policy)

指定者:

onGcCleanup 在接口中 cn.weforward.common.GcCleanable

doLoad

protected abstract CounterItem doLoad(DbCounter counter,
                                      String id)

由数据库加载计数项

参数:

counter - 计数器

id - 计数项id

返回:

相应的项，没有则返回null

doUpdate

protected abstract void doUpdate(DbCounter counter,
                                 cn.weforward.common.util.LruCache.DirtyData<CounterItem> data)

更新计数项到数据库

参数:

counter - 计数器

data - 要更新的计数项列表

doNew

protected abstract void doNew(DbCounter counter,
                              CounterItem item)

（可能是）新的计数项，用于及时把新项写入数据库，此实现可选择略过

参数:

counter - 计数器

item - 新计数项