xyz.noark.orm.write

类 AbstractAsyncWriteService

java.lang.Object

xyz.noark.orm.write.AbstractAsyncWriteService

所有已实现的接口:

AsyncWriteService

直接已知子类:

AsyncWriteServiceByPlayerIdImpl, DefaultAsyncWriteServiceImpl

public abstract class AbstractAsyncWriteService
extends java.lang.Object
implements AsyncWriteService

抽象的异步回写中心.

从以下版本开始:

3.4

作者:

小流氓[176543888@qq.com]

字段概要

字段

限定符和类型	字段和说明
protected int	batchOperateNum 批量存档数量
protected DataAccessor	dataAccessor
protected int	saveInterval 定时存档间隔，单位：秒
protected java.util.concurrent.ScheduledExecutorService	scheduledExecutorService 这个定时任务，有空就处理一下数据保存和缓存清理功能

构造器概要

构造器

构造器和说明
AbstractAsyncWriteService()

方法概要

限定符和类型	方法和说明
protected abstract <T> java.io.Serializable	analysisGroupIdByEntity(EntityMapping<T> em, T entity) 智能分析这个实体类的角色Id是多少.
void	asyncFlushByGroupId(java.io.Serializable groupId)
<T> void	delete(EntityMapping<T> em, T entity) 删除一个实体对象.
<T> void	deleteAll(EntityMapping<T> em, java.util.List<T> result) 删除一批实体对象.
void	init() 初始化存储系统
<T> void	insert(EntityMapping<T> em, T entity) 插入一个实体对象.
protected <T> void	operation(EntityMapping<T> em, T entity, OperateType type) 实体类对象的操作.
void	shutdown() 停机存档，停机前应该保证所有数据都存档完成.
void	syncFlushAll()
<T> void	update(EntityMapping<T> em, T entity) 更新一个实体对象.

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

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

字段详细资料

dataAccessor

@Autowired
protected DataAccessor dataAccessor

saveInterval

@Value(value="data.save.interval")
protected int saveInterval

定时存档间隔，单位：秒

batchOperateNum

@Value(value="data.batch.num")
protected int batchOperateNum

批量存档数量

scheduledExecutorService

protected java.util.concurrent.ScheduledExecutorService scheduledExecutorService

这个定时任务，有空就处理一下数据保存和缓存清理功能

构造器详细资料

AbstractAsyncWriteService

public AbstractAsyncWriteService()

方法详细资料

init

public void init()

从接口复制的说明: AsyncWriteService

初始化存储系统

指定者:

init 在接口中 AsyncWriteService

insert

public <T> void insert(EntityMapping<T> em,
                       T entity)

从接口复制的说明: AsyncWriteService

插入一个实体对象.

指定者:

insert 在接口中 AsyncWriteService

类型参数:

T - 实体对象类型

参数:

em - 实体映射对象

entity - 实体对象

delete

public <T> void delete(EntityMapping<T> em,
                       T entity)

从接口复制的说明: AsyncWriteService

删除一个实体对象.

指定者:

delete 在接口中 AsyncWriteService

类型参数:

T - 实体对象类型

参数:

em - 实体映射对象

entity - 实体对象

deleteAll

public <T> void deleteAll(EntityMapping<T> em,
                          java.util.List<T> result)

从接口复制的说明: AsyncWriteService

删除一批实体对象.

指定者:

deleteAll 在接口中 AsyncWriteService

类型参数:

T - 实体对象类型

参数:

em - 实体映射对象

result - 实体对象列表

update

public <T> void update(EntityMapping<T> em,
                       T entity)

从接口复制的说明: AsyncWriteService

更新一个实体对象.

指定者:

update 在接口中 AsyncWriteService

类型参数:

T - 实体对象类型

参数:

em - 实体映射对象

entity - 实体对象

operation

protected <T> void operation(EntityMapping<T> em,
                             T entity,
                             OperateType type)

实体类对象的操作.

类型参数:

T - 实体类

参数:

em - 实体对象描述类

entity - 实体类对象

type - 操作类型

analysisGroupIdByEntity

protected abstract <T> java.io.Serializable analysisGroupIdByEntity(EntityMapping<T> em,
                                                                    T entity)

智能分析这个实体类的角色Id是多少.

类型参数:

T - 实体类型

参数:

em - 实体类的描述对象.

entity - 实体对象.

返回:

如果这个实体对象中有@PlayerId则返回此属性的值，否则返回默认的（系统）角色ID

shutdown

public void shutdown()

从接口复制的说明: AsyncWriteService

停机存档，停机前应该保证所有数据都存档完成.

指定者:

shutdown 在接口中 AsyncWriteService

syncFlushAll

public void syncFlushAll()

asyncFlushByGroupId

public void asyncFlushByGroupId(java.io.Serializable groupId)