namespace ET { public static class InnerMessageDispatcherHelper { public static async ETVoid HandleIActorResponse(Session session, IActorResponse iActorResponse) { ActorMessageSenderComponent.Instance.RunMessage(iActorResponse); } public static async ETVoid HandleIActorRequest(Session session, IActorRequest iActorRequest) { InstanceIdStruct instanceIdStruct = new InstanceIdStruct(iActorRequest.ActorId); int replyId = instanceIdStruct.Process; instanceIdStruct.Process = IdGenerater.Process; iActorRequest.ActorId = instanceIdStruct.ToLong(); string address = StartProcessConfigCategory.Instance.Get(replyId).InnerAddress; Session ss = NetInnerComponent.Instance.Get(address); Entity entity = Game.EventSystem.Get(iActorRequest.ActorId); if (entity == null) { Log.Warning($"not found actor: {MongoHelper.ToJson(iActorRequest)}"); ActorResponse response = new ActorResponse { Error = ErrorCode.ERR_NotFoundActor, RpcId = iActorRequest.RpcId, }; ss.Reply(response); return; } MailBoxComponent mailBoxComponent = entity.GetComponent(); if (mailBoxComponent == null) { ActorResponse response = new ActorResponse { Error = ErrorCode.ERR_ActorNoMailBoxComponent, RpcId = iActorRequest.RpcId, }; ss.Reply(response); Log.Error($"actor not add MailBoxComponent: {entity.GetType().Name} {iActorRequest}"); return; } await mailBoxComponent.Handle(ss, iActorRequest); } public static async ETVoid HandleIActorMessage(Session session, IActorMessage iActorMessage) { InstanceIdStruct instanceIdStruct = new InstanceIdStruct(iActorMessage.ActorId); int replyId = instanceIdStruct.Process; instanceIdStruct.Process = IdGenerater.Process; iActorMessage.ActorId = instanceIdStruct.ToLong(); Entity entity = Game.EventSystem.Get(iActorMessage.ActorId); if (entity == null) { Log.Error($"not found actor: {MongoHelper.ToJson(iActorMessage)}"); return; } MailBoxComponent mailBoxComponent = entity.GetComponent(); if (mailBoxComponent == null) { Log.Error($"actor not add MailBoxComponent: {entity.GetType().Name} {iActorMessage}"); return; } Session ss = NetInnerComponent.Instance.Get(replyId); await mailBoxComponent.Handle(ss, iActorMessage); } } }