Activiti 之 DataManager & EntityManager

by yan 20211223

阅读了Activiti 相关源码,记录下对DataManager & EntityManager的理解。

是一层相对底层的抽象，主要负责数据的持久化操作。
通过DbSqlSession实现数据库的CRUD，DbSqlSession 是Activiti里对底层session的一个封装。默认使用了Mybatis的SqlSession操作数据库。
Activiti 封装了几种session。如图

通过EntityCache实现数据的缓存操作。EntityCache是Activiti封装一个缓存机制。存储结构是一个Map, Map>，一个二层map使用类作为key，每个类对应有多个对象,类有继续关系，如果找不到父类的key，就找子类的key。如下代码

public class EntityCacheImpl implements EntityCache {

  protected Map, Map> cachedObjects = new HashMap, Map>();

  @Override
  public CachedEntity put(Entity entity, boolean storeState) {
    Map classCache = cachedObjects.get(entity.getClass());
    if (classCache == null) {
      classCache = new HashMap();
      cachedObjects.put(entity.getClass(), classCache);
    }
    CachedEntity cachedObject = new CachedEntity(entity, storeState);
    classCache.put(entity.getId(), cachedObject);
    return cachedObject;
  }
    @Override
  @SuppressWarnings("unchecked")
  public  T findInCache(Class entityClass, String id) {
    CachedEntity cachedObject = null;
    Map classCache = cachedObjects.get(entityClass);

    if (classCache == null) {
      classCache = findClassCacheByCheckingSubclasses(entityClass);
    }

    if (classCache != null) {
      cachedObject = classCache.get(id);
    }

    if (cachedObject != null) {
      return (T) cachedObject.getEntity();
    }

    return null;
  }

 protected Map findClassCacheByCheckingSubclasses(Class entityClass) {
    for (Class clazz : cachedObjects.keySet()) {
      if (entityClass.isAssignableFrom(clazz)) {
        return cachedObjects.get(clazz);
      }
    }
....
}

是相对DataManager 上层的一层封装。主要负责操作Entity实体的业务。通过调用DataManager实现数据持久化。

实体的承载。这块实体又做了很多接口和抽象。EntityManager和DataManager都依赖于它。

最后上总图：