using System; using System.Collections.Generic; namespace Model { [ObjectEvent] public class ActorMessageDispatherComponentEvent : ObjectEvent, IAwake, ILoad { public void Awake(AppType appType) { this.Get().Awake(appType); } public void Load() { this.Get().Load(); } } /// /// Actor消息分发组件 /// public class ActorMessageDispatherComponent : Component { private AppType AppType; private Dictionary handlers; public void Awake(AppType appType) { this.AppType = appType; this.Load(); } public void Load() { this.handlers = new Dictionary(); Type[] types = DllHelper.GetMonoTypes(); foreach (Type type in types) { object[] attrs = type.GetCustomAttributes(typeof(ActorMessageHandlerAttribute), false); if (attrs.Length == 0) { continue; } ActorMessageHandlerAttribute messageHandlerAttribute = (ActorMessageHandlerAttribute)attrs[0]; if (!messageHandlerAttribute.Type.Is(this.AppType)) { continue; } object obj = Activator.CreateInstance(type); IMActorHandler imHandler = obj as IMActorHandler; if (imHandler == null) { throw new Exception($"message handler not inherit AMEvent or AMRpcEvent abstract class: {obj.GetType().FullName}"); } Type messageType = imHandler.GetMessageType(); handlers.Add(messageType, imHandler); } } public IMActorHandler GetActorHandler(Type type) { this.handlers.TryGetValue(type, out IMActorHandler actorHandler); return actorHandler; } public void Handle(Session session, Entity entity, IActorMessage message) { if (!this.handlers.TryGetValue(message.GetType(), out IMActorHandler handler)) { Log.Error($"not found message handler: {message.GetType().FullName}"); return; } handler.Handle(session, entity, message); } public override void Dispose() { if (this.Id == 0) { return; } base.Dispose(); } } }