using ETModel; namespace ETHotfix { public class InnerMessageDispatcher: IMessageDispatcher { public void Dispatch(Session session, ushort opcode, object message) { // 收到actor消息,放入actor队列 switch (message) { case IActorRequest iActorRequest: { Entity entity = (Entity)Game.EventSystem.Get(iActorRequest.ActorId); if (entity == null) { Log.Warning($"not found actor: {iActorRequest.ActorId}"); ActorResponse response = new ActorResponse { Error = ErrorCode.ERR_NotFoundActor, RpcId = iActorRequest.RpcId }; session.Reply(response); return; } MailBoxComponent mailBoxComponent = entity.GetComponent(); if (mailBoxComponent == null) { ActorResponse response = new ActorResponse { Error = ErrorCode.ERR_ActorNoMailBoxComponent, RpcId = iActorRequest.RpcId }; session.Reply(response); Log.Error($"actor没有挂载MailBoxComponent组件: {entity.GetType().Name} {entity.Id}"); return; } mailBoxComponent.Add(new ActorMessageInfo() { Session = session, Message = iActorRequest }); return; } case IActorMessage iactorMessage: { Entity entity = (Entity)Game.EventSystem.Get(iactorMessage.ActorId); if (entity == null) { Log.Error($"not found actor: {iactorMessage.ActorId}"); return; } MailBoxComponent mailBoxComponent = entity.GetComponent(); if (mailBoxComponent == null) { Log.Error($"actor not add MailBoxComponent: {iactorMessage.ActorId}"); return; } mailBoxComponent.Add(new ActorMessageInfo() { Session = session, Message = iactorMessage }); return; } default: { Game.Scene.GetComponent().Handle(session, new MessageInfo(opcode, message)); break; } } } } }