using System; namespace ET.Server { [EnableClass] public abstract class AMActorHandler: IMActorHandler where E : Entity where Message : class, IActorMessage { protected abstract ETTask Run(E entity, Message message); public async ETTask Handle(Entity entity, object actorMessage, Action reply) { Message msg = actorMessage as Message; if (msg == null) { Log.Error($"消息类型转换错误: {actorMessage.GetType().FullName} to {typeof (Message).Name}"); return; } E e = entity as E; if (e == null) { Log.Error($"Actor类型转换错误: {entity.GetType().Name} to {typeof (E).Name} --{typeof (Message).Name}"); return; } await this.Run(e, msg); } public Type GetRequestType() { if (typeof (IActorLocationMessage).IsAssignableFrom(typeof (Message))) { Log.Error($"message is IActorLocationMessage but handler is AMActorHandler: {typeof (Message)}"); } return typeof (Message); } public Type GetResponseType() { return null; } } }