Files
oops-plugin-framework/assets/libs/ecs/entity/EntityIdManager.ts
dgflash 3a2db77647 1. 核心入口 — ECS.ts
ecs 命名空间:统一导出所有 API,业务只需 import { ecs } from './ECS'
核心类型别名:ecs.Entity / ecs.Comp / ecs.RootSystem / ecs.ComblockSystem
接口再导出:ecs.IComp / ecs.IMatcher / ecs.IEntityEnterSystem / ecs.IEntityRemoveSystem / ecs.ISystemFirstUpdate / ecs.ISystemUpdate
实体工厂:ecs.getEntity(ctor, world?) — 创建或从对象池获取实体
动态查询:ecs.query(matcher, world?) — 按匹配器查询实体
过滤器工厂:ecs.allOf() / ecs.anyOf() / ecs.onlyOf() / ecs.excludeOf() — 组合匹配规则
单例组件:ecs.getSingleton() / ecs.addSingleton() — 全局唯一组件访问
子模块门面:ecs.world / ecs.pool / ecs.system / ecs.storage / ecs.network / ecs.serialize / ecs.entityRef
2. 驱动器 — ECSDriver.ts
封装默认世界的 init / execute / destroy 生命周期
add(system) — 向默认世界添加业务系统
init() — 初始化 ECS(并入 @ecs.register 注册的系统、拓扑排序、init)
execute(dt) — 驱动默认世界一帧
destroy() — 清理所有子系统
3. 实体 — ECSEntity.ts
组件容器:位掩码 mask + 按 tid 索引的密集数组,get/has 为 O(1)
双重重载 add():
add(组件类) — 从对象池取实例或恢复软移除缓存
add(组件实例) — 挂载外部实例(如 cc.Component),设 canRecycle=false
remove(ctor, isRecycle?):
isRecycle=true(默认):reset + 回池/释放 SoA 槽位
isRecycle=false:软移除,数据暂存 compTid2Obj,下次 add 同 tid 恢复
父子层级:addChild / removeChild,带循环引用检测
destroy():断开父子 → 移除全部组件 → 清理软移除缓存 → 回收实体 + 释放 eid
forEachComponent(cb):遍历当前挂载的所有组件
4. 组件 — ECSComp.ts
抽象基类,子类须实现 reset() 方法
canRecycle — 是否可回收(外部创建的组件设 false)
ent — 拥有该组件的实体引用
变更检测:markDirty() / isChangedSince(sinceEpoch) / lastWriteEpoch — 基于 epoch 的帧级脏标记
5. 位掩码 — ECSMask.ts
基于 Uint32Array 的位运算,支持 set / has / delete / and / or / bitCount
对象池复用,clearPool() 清理
6. 注册系统 — ECSRegister.ts + ECSTypeRegistry.ts
@ecs.register('Name') 类装饰器:自动识别注册类型
组件:分配 tid,写入 compCtors 表
实体:记录 ctor → name 映射
系统:注册到全局表或指定世界
ECSTypeRegistry:全局类型注册表(跨世界共享),记录组件/实体/系统元数据
7. 查询 — ECSMatcher.ts + ECSGroup.ts
四种规则:AllOf / AnyOf / OnlyOf / ExcludeOf,规则间为"与"关系
flyweight 缓存:相同组合共享同一 Matcher 实例
小规则优化:tid 数 ≤ 4 时直接 mask.has,否则分配 ECSMask
ECSGroup:SparseSet 实现,O(1) 增删(swap-pop),稳定快照遍历
进入/离开追踪:watchEntityEnterAndRemove 供系统帧内查询变化
8. 系统 — ECSComblockSystem.ts + ECSRootSystem.ts
ComblockSystem:业务系统基类
生命周期:init → entityEnter → firstUpdate → update → entityRemove → onDestroy
filter() — 声明实体匹配规则
interval — 执行间隔(0=每帧,>0=固定间隔)
被动系统:isPassiveSystem() 返回 true 时不参与每帧 update
构造时探测子类钩子,选定 execute 变体(零开销分支)
RootSystem:根系统,一世界一个
init() — 并入 @ecs.register 系统 + 拓扑排序 + 绑定世界 + init
execute(dt) — 切换当前世界 → 递增 epoch → tick 各系统 → flush 命令缓冲
9. 系统调度 — SystemScheduler.ts
声明式执行顺序:@ecs.system.executeBefore / @ecs.system.executeAfter / @ecs.system.inSet
拓扑排序(Kahn 算法):无约束系统保持原始顺序,循环依赖抛 CycleDependencyError
集合机制:inSet('名') 把系统加入虚拟分组,其他系统用 executeAfter('set:名') 批量依赖
10. 世界 — ECSWorld.ts + ECSWorldManager.ts
ECSWorld:运行期数据容器
entities — 活动实体表(eid → 实体)
groups — 响应式查询分组
singletons — 单例组件表
refs — @entityRef 引用追踪
commands — 延迟结构变更命令队列
epoch — 世代号(每帧递增,变更检测用)
getEntity(ctor) — 创建/从池获取实体
assignEid(entity, eid) — 反序列化时保持 eid 一致
ECSWorldManager(ecs.world):多世界管理
get(name?) / default() / current — 获取/切换世界
use(world) — 切换当前世界,返回切换前的世界
inWorld(world, fn) — 在指定世界中执行,自动还原
createSystems(world, ...ctors) — 批量装配系统并 init
defer(fn) / flushCommands() — 延迟结构变更
11. 命令缓冲 — ECSCommandBuffer.ts
延迟结构变更队列,帧末由 RootSystem.execute 统一 flush
push(fn) 入队,flush() 先快照再执行(避免本帧新入队命令在本帧执行)
12. 对象池 — ECSPoolManager.ts + ECSDynamicPool.ts
ecs.pool:统一管理实体/组件动态对象池
getPool(name, factory) — 获取或创建池
clearAll() / clearPools() — 清空池缓存(不触碰存活数据)
getAllMetrics() — 获取各池统计信息(命中/未命中/缓存/创建数)
13. 实体引用 — ECSEntityRef.ts + ECSReferenceTracker.ts
@ecs.entityRef() 属性装饰器:标记组件属性为实体引用
目标实体销毁时自动置 null,避免悬空引用
组件回收时 clearComponentEntityRefs 清理所有引用
14. SoA 列存储 — StorageSoA.ts + StorageDecorators.ts
@ecs.storage.enableSoA 类装饰器:为组件启用 SoA 列存储(默认 AoS,opt-in)
字段装饰器:float64 / float32 / int32 / uint32 / int16 / uint16 / int8 / uint8
数值字段按列存入 TypedArray,按 eid 分配槽位
acquire 返回 Proxy 视图:SoA 字段读写直接落到 TypedArray,非 SoA 字段走后备实例
槽位超出容量时 2 倍扩容,释放时入空闲栈
自注册机制:模块加载时注册到核心,删除 storage/ 目录后基础 ECS 仍可运行
15. 网络同步 — NetworkSync.ts + SyncDecorators.ts + SyncCodec.ts + ByteBuffer.ts
@ecs.network.sync(类型) 字段装饰器:标记组件字段参与网络同步
ecs.network.net 门面:
encodeWorld(op?) — 编码当前世界为紧凑二进制(Full 全量 / Delta 增量)
applyToWorld(bytes, onMissing?) — 将二进制同步数据应用到世界
track(entity, markAll?) — 为实体初始化变更追踪器
clearDirty() — 清除所有脏标记
SyncCodec:实体/组件级编解码器
ByteWriter / ByteReader:二进制读写缓冲(变长整数等)
ChangeTracker:字段级脏标记追踪
16. 序列化 — Serialization.ts + Incremental.ts
@ecs.serialize() 字段装饰器:标记组件需要持久化的字段
全量序列化:
ecs.serialize.serializeWorld(pretty?) — 序列化当前世界为 JSON
ecs.serialize.deserializeWorld(json) — 从 JSON 反序列化到当前世界
增量序列化:
ecs.serialize.snapshot() — 对当前世界拍快照(基线)
ecs.serialize.computeDelta(base) — 计算相对基线的增量(added / removed / changed)
ecs.serialize.applyDelta(delta) — 将增量应用到当前世界
保留实体层级(parentEid),两阶段重建(先建实体+组件,再重建父子)
17. 监控日志 — ECSMonitorLogger.ts
零入侵监控模块,通过控制台命令触发
注册全局命令:
ecsLog() — 打印所有监控表格
ecsWorldSummary() — 各世界实体/系统/组件缓存统计
ecsSummary() — 总体统计(所有世界合计)
ecsEntityPools() — 实体池明细(命中/未命中/缓存)
ecsCompPools() — 组件池明细(按 M/B/V/VC 分类排序)
ecsEntityCaches() — 实体软移除组件缓存明细
ecsHelp() — 显示帮助信息
2026-06-12 21:52:47 +08:00

128 lines
5.1 KiB
TypeScript
Raw Permalink Blame History

This file contains ambiguous Unicode characters
This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.
/**
* 实体唯一编号eid统一管理器 —— 世代式数字句柄
*
* 设计目标(在不改变"实体是对象"这一对外模型的前提下,拿到数字句柄的核心能力):
* - eid 仍是一个普通的正整数CCEntity/CCView 及所有现有以 eid 为 Map key 的逻辑childs/eid2Entity/SoA零改动。
* - eid 内部编码"索引(index) + 世代号(generation)":实体回收后世代号 +1旧 eid 自然失效,
* 从而支持"悬空引用检测"{@link EntityIdManager.isValid})。
* - 索引可循环复用,避免编号无限增长。
*
* 编码方式(避免 32 位有符号位移溢出,改用乘加,结果始终是 < 2^53 的安全整数):
* eid = generation * INDEX_CAPACITY + index
* index = eid % INDEX_CAPACITY
* generation = Math.floor(eid / INDEX_CAPACITY)
*
* 其中 index 取值范围为 [1, INDEX_CAPACITY)0 保留为"无效"。
* generation=0 且 index=1 时 eid=1与历史从 1 开始自增的编号自然衔接。
*/
export class EntityIdManager {
/** 索引位宽2^21 ≈ 209 万并发实体上限,足够绝大多数项目) */
private static readonly INDEX_BITS = 21;
/** 索引容量(= 2^INDEX_BITS同时作为 generation 的进位基数 */
private static readonly INDEX_CAPACITY = 1 << EntityIdManager.INDEX_BITS;
/** index -> 当前世代号(数组下标即 index */
private generations: number[] = [0];
/** 可复用的空闲索引栈 */
private freeIndices: number[] = [];
/** 下一个从未分配过的索引0 保留无效,从 1 开始) */
private nextIndex = 1;
/** 当前存活的 eid 数量 */
private aliveCount = 0;
/** 从 eid 中解出索引部分 */
static indexOf(eid: number): number {
return eid % EntityIdManager.INDEX_CAPACITY;
}
/** 从 eid 中解出世代号部分 */
static generationOf(eid: number): number {
return Math.floor(eid / EntityIdManager.INDEX_CAPACITY);
}
/** 将索引与世代号编码为 eid */
private static pack(index: number, generation: number): number {
return generation * EntityIdManager.INDEX_CAPACITY + index;
}
/**
* 分配一个新的 eid优先复用空闲索引复用时沿用该索引已递增的世代号
* @returns 编码后的唯一 eid正整数
*/
allocate(): number {
let index = this.freeIndices.pop();
if (index === undefined) {
index = this.nextIndex++;
this.generations[index] = 0;
}
this.aliveCount++;
return EntityIdManager.pack(index, this.generations[index]);
}
/**
* 释放一个 eid递增其索引的世代号使旧 eid 立即失效,并将索引回收复用
* @param eid 要释放的 eid
* @returns 是否成功释放(传入的是过期/无效 eid 时返回 false
*/
release(eid: number): boolean {
const index = EntityIdManager.indexOf(eid);
if (index <= 0 || index >= this.nextIndex) return false;
if (this.generations[index] !== EntityIdManager.generationOf(eid)) return false;
this.generations[index]++;
this.freeIndices.push(index);
this.aliveCount--;
return true;
}
/**
* 校验 eid 是否仍指向当前存活的实体(悬空引用检测核心)
* @param eid 待校验的 eid
* @returns 仍有效返回 true已被回收/从未分配返回 false
*/
isValid(eid: number): boolean {
if (eid <= 0) return false;
const index = EntityIdManager.indexOf(eid);
if (index <= 0 || index >= this.nextIndex) return false;
return this.generations[index] === EntityIdManager.generationOf(eid);
}
/**
* 预留/占用一个指定的 eid用于反序列化、联机状态恢复时保持编号一致
* 会同步 nextIndex、世代号并从空闲栈中移除该索引避免后续 allocate 冲突。
* @param eid 要占用的 eid
*/
reserve(eid: number): void {
const index = EntityIdManager.indexOf(eid);
const generation = EntityIdManager.generationOf(eid);
if (index <= 0) return;
if (index >= this.nextIndex) {
// 补齐中间从未分配的索引并放入空闲栈,待后续 allocate 复用
for (let i = this.nextIndex; i < index; i++) {
this.generations[i] = 0;
this.freeIndices.push(i);
}
this.nextIndex = index + 1;
}
else {
// 该索引此前可能在空闲栈中,移除避免重复分配
const pos = this.freeIndices.indexOf(index);
if (pos !== -1) this.freeIndices.splice(pos, 1);
}
this.generations[index] = generation;
}
/** 当前存活的 eid 数量 */
get size(): number {
return this.aliveCount;
}
/** 重置管理器(清空所有索引与世代记录),用于 ecs.world.clear */
reset(): void {
this.generations = [0];
this.freeIndices.length = 0;
this.nextIndex = 1;
this.aliveCount = 0;
}
}