企业官网建设流程全解析

从单体到分布式：ET框架如何重构Unity游戏服务器架构

【免费下载链接】ETUnity3D Client And C# Server Framework项目地址: https://gitcode.com/GitHub_Trending/et/ET

ET框架（Entity-Thread Framework）是专为Unity游戏开发设计的C#服务器框架，它通过创新的单线程多进程架构和Actor模型，为游戏服务器开发提供了全新的解决方案。在传统游戏服务器架构面临分布式扩展瓶颈的今天，ET框架通过Entity级别的并发控制和细粒度消息通信机制，实现了高性能、可扩展的游戏服务端架构重构。

游戏服务器架构的演进困境与ET的解决方案

传统游戏服务器架构往往面临单体应用难以扩展、多线程并发控制复杂、分布式部署困难等挑战。当在线玩家数量从数百增长到数万时，传统的单进程架构会遇到性能瓶颈，而多进程架构又面临进程间通信的复杂性。

ET框架的核心理念是将游戏世界中的每个实体（Entity）都视为独立的执行单元，通过Actor模型实现细粒度的并发控制。这种设计思想来源于对Erlang和Akka等Actor模型的深入理解，但ET框架进行了针对游戏场景的优化重构。

表：不同游戏服务器架构对比分析

ET框架通过将Actor模型下沉到Entity级别，实现了游戏逻辑的自然映射。每个游戏实体（如玩家、NPC、道具）都可以成为一个独立的Actor，拥有自己的消息队列和状态管理，这种设计极大地简化了分布式系统的开发复杂度。

核心架构演进：从Entity到分布式Actor

Entity作为游戏世界的基石

在ET框架中，Entity是一切的基础。每个Entity都有一个唯一的InstanceId，这个ID在分布式系统中扮演着关键角色。Entity可以挂载各种Component，每个Component负责特定的功能模块，这种组件化设计使得系统具有极高的可扩展性。

// 创建玩家Entity Entity player = EntityFactory.Create<Player>(); player.AddComponent<MoveComponent>(); player.AddComponent<SkillComponent>(); player.AddComponent<MailboxComponent>(); // 使Entity成为Actor // 获取组件进行操作 var moveComponent = player.GetComponent<MoveComponent>(); moveComponent.MoveTo(targetPosition);

代码示例：ET框架中的Entity创建与组件管理

Actor消息通信机制的实现

ET框架的Actor通信机制基于MailboxComponent实现。任何挂载了MailboxComponent的Entity都可以接收和处理Actor消息。消息发送者只需要知道目标Entity的InstanceId，无需关心目标所在的物理进程。

// 发送Actor消息 public async ETTask SendActorMessage(long targetInstanceId, IActorMessage message) { // 获取ActorSenderComponent var actorSender = Game.Scene.GetComponent<ActorSenderComponent>(); // 获取消息发送器 var sender = actorSender.Get(targetInstanceId); // 发送消息 await sender.Call(message); } // 处理Actor消息 [ActorMessageHandler(AppType.Map)] public class Actor_MoveHandler : AMActorHandler<Unit, Actor_Move> { protected override async ETTask Run(Unit unit, Actor_Move message) { // 处理移动逻辑 await unit.GetComponent<MoveComponent>().MoveAsync(message.Position); } }

代码示例：ET框架中的Actor消息发送与处理

分布式定位难题与Actor Location机制

在分布式环境中，Entity可能在不同进程间迁移，导致InstanceId发生变化。ET框架通过Actor Location机制解决了这一难题，实现了基于Entity.Id的可靠消息通信。

Location Server的设计原理

Location Server作为分布式系统的"地址簿"，维护着Entity.Id到InstanceId的映射关系。当Entity迁移到新的进程时，会向Location Server注册新的位置信息。消息发送时，系统会先查询Location Server获取目标Entity的当前InstanceId。

// Actor Location消息定义 message Actor_LocationMessage : IActorLocationMessage { int64 ActorId = 93; // 发送者InstanceId int64 Id = 94; // 目标Entity.Id // 消息内容字段... }

代码示例：Actor Location消息的Protobuf定义

消息路由与重试机制

ET框架的Actor Location系统实现了智能的消息路由和重试机制。当消息发送失败时（例如目标Entity已迁移），系统会自动重新查询Location Server并重试发送，最多重试5次。

// Actor Location消息处理 [ActorMessageHandler(AppType.Map)] public class Actor_LocationTestHandler : AMActorLocationHandler<Unit, Actor_LocationTest> { protected override async ETTask Run(Unit unit, Actor_LocationTest message) { // 处理Location消息 Log.Info($"收到Location消息: {message.Content}"); // 可以安全地访问unit的状态 unit.Position = message.NewPosition; } }

代码示例：Actor Location消息处理器实现

实战应用：构建可扩展的游戏服务架构

场景划分与进程管理

ET框架支持将游戏世界划分为多个场景（Scene），每个场景可以运行在独立的进程中。这种设计使得系统可以根据负载动态调整资源分配。

// 场景进程启动配置 public static class SceneFactory { public static async ETTask<Scene> CreateScene( int zone, string name, SceneType sceneType) { Scene scene = EntitySceneFactory.CreateScene( IdGenerater.GenerateId(), zone, sceneType, name); // 添加场景必要组件 scene.AddComponent<UnitComponent>(); scene.AddComponent<AOIManagerComponent>(); return scene; } }

代码示例：ET框架中的场景创建与管理

负载均衡与热迁移

通过Actor Location机制，ET框架实现了Entity的热迁移功能。当某个进程负载过高时，可以将部分Entity迁移到其他进程，实现动态负载均衡。

// Entity迁移逻辑 public async ETTask MigrateEntity(long entityId, int targetZone) { // 1. 锁定Location记录 await LocationProxyComponent.Instance.Lock(entityId); // 2. 暂停消息处理 var entity = GetEntity(entityId); entity.GetComponent<MailboxComponent>().Pause(); // 3. 序列化Entity状态 byte[] state = SerializeEntity(entity); // 4. 迁移到目标进程 await MigrateToZone(targetZone, state); // 5. 更新Location记录 await LocationProxyComponent.Instance.UnLockAndUpdate(entityId, newInstanceId); // 6. 恢复消息处理 entity.GetComponent<MailboxComponent>().Resume(); }

代码示例：Entity热迁移的实现逻辑

性能优化与最佳实践

消息合并与批量处理

在高并发场景下，频繁的小消息发送会导致性能问题。ET框架支持消息合并机制，将多个小消息合并为一个大消息发送，减少序列化和网络开销。

// 消息批量处理示例 public class BatchMessageProcessor : Component { private List<IActorMessage> _pendingMessages = new List<IActorMessage>(); private const int BatchSize = 100; public void AddMessage(IActorMessage message) { _pendingMessages.Add(message); if (_pendingMessages.Count >= BatchSize) { ProcessBatch(); } } private async void ProcessBatch() { var batchMessage = new Actor_BatchMessage { Messages = _pendingMessages.ToArray() }; await SendToTarget(batchMessage); _pendingMessages.Clear(); } }

代码示例：消息批量处理机制

内存管理与对象池

ET框架采用对象池技术管理Entity和Component的创建与销毁，避免频繁的GC（垃圾回收）对性能的影响。

// 使用对象池创建Entity public T CreateWithPool<T>() where T : Entity { T entity = ObjectPool.Instance.Fetch<T>(); entity.InstanceId = IdGenerater.GenerateId(); entity.IsFromPool = true; // 初始化Entity entity.Awake(); return entity; } // 回收Entity到对象池 public void Recycle(Entity entity) { if (entity.IsFromPool) { entity.Dispose(); ObjectPool.Instance.Recycle(entity); } }

代码示例：ET框架中的对象池使用

未来展望：ET框架的演进方向

随着游戏行业的快速发展，ET框架也在不断演进。未来的发展方向包括：

1. 云原生支持：更好地集成Kubernetes等容器编排平台，实现自动扩缩容
2. 边缘计算：支持边缘节点部署，降低网络延迟
3. AI集成：内置机器学习框架，支持智能NPC和游戏平衡调整
4. 多语言支持：除了C#，考虑支持其他语言的服务端开发

ET框架通过创新的架构设计，为Unity游戏服务器开发提供了一套完整的解决方案。其Actor模型和Entity系统不仅解决了分布式系统的通信难题，还为游戏开发提供了高度的灵活性和可扩展性。对于正在面临服务器架构重构挑战的开发团队，ET框架值得深入研究和实践应用。


ET框架支持的游戏服务器架构演进示意图

要深入了解ET框架的完整实现，可以参考项目中的详细文档：官方文档：Book/5.4Actor Model.md 和 Book/5.5Actor Location-ZH.md，这些文档提供了Actor模型和Location机制的完整实现细节。

【免费下载链接】ETUnity3D Client And C# Server Framework项目地址: https://gitcode.com/GitHub_Trending/et/ET