| 1234567891011121314151617181920212223242526272829303132 |
- using System.Threading.Tasks;
- namespace Model
- {
- public interface IEntityActorHandler
- {
- Task<bool> Handle(Session session, Entity entity, ActorRequest message);
- }
- /// <summary>
- /// gate session 收到的消息直接转发给客户端
- /// </summary>
- public class GateSessionEntityActorHandler : IEntityActorHandler
- {
- public async Task<bool> Handle(Session session, Entity entity, ActorRequest message)
- {
- ((Session)entity).Send(message.AMessage);
- ActorResponse response = new ActorResponse();
- response.RpcId = message.RpcId;
- session.Reply(response);
- return true;
- }
- }
- public class CommonEntityActorHandler : IEntityActorHandler
- {
- public async Task<bool> Handle(Session session, Entity entity, ActorRequest message)
- {
- return await Game.Scene.GetComponent<ActorMessageDispatherComponent>().Handle(session, entity, message);
- }
- }
- }
|