using ETModel; namespace ETHotfix { 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) { long replyId = IdGenerater.GetProcessId(iActorRequest.ActorId); iActorRequest.ActorId = iActorRequest.ActorId & IdGenerater.HeadMask | IdGenerater.Head; using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.Mailbox, iActorRequest.ActorId)) { string address = StartConfigComponent.Instance.GetProcessInnerAddress(replyId); 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 MailboxDispatcherComponent.Instance.Handle(entity, mailBoxComponent.MailboxType, ss, iActorRequest); } } public static async ETVoid HandleIActorMessage(Session session, IActorMessage iActorMessage) { long replyId = IdGenerater.GetProcessId(iActorMessage.ActorId); iActorMessage.ActorId = iActorMessage.ActorId & IdGenerater.HeadMask | IdGenerater.Head; using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.Mailbox, iActorMessage.ActorId)) { 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 MailboxDispatcherComponent.Instance.Handle(entity, mailBoxComponent.MailboxType, ss, iActorMessage); } } } }