InnerMessageDispatcher.cs 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. using System;
  2. using ETModel;
  3. namespace ETHotfix
  4. {
  5. public class InnerMessageDispatcher: IMessageDispatcher
  6. {
  7. public void Dispatch(Session session, ushort opcode, object message)
  8. {
  9. // 收到actor消息,放入actor队列
  10. if (message is IActorMessage iActorMessage)
  11. {
  12. Entity entity = (Entity)Game.EventSystem.Get(iActorMessage.ActorId);
  13. if (entity == null)
  14. {
  15. Log.Warning($"not found actor: {iActorMessage.ActorId}");
  16. ActorResponse response = new ActorResponse
  17. {
  18. Error = ErrorCode.ERR_NotFoundActor,
  19. RpcId = iActorMessage.RpcId
  20. };
  21. session.Reply(response);
  22. return;
  23. }
  24. MailBoxComponent mailBoxComponent = entity.GetComponent<MailBoxComponent>();
  25. if (mailBoxComponent == null)
  26. {
  27. ActorResponse response = new ActorResponse
  28. {
  29. Error = ErrorCode.ERR_ActorNoMailBoxComponent,
  30. RpcId = iActorMessage.RpcId
  31. };
  32. session.Reply(response);
  33. Log.Error($"actor没有挂载MailBoxComponent组件: {entity.GetType().Name} {entity.Id}");
  34. return;
  35. }
  36. mailBoxComponent.Add(new ActorMessageInfo() { Session = session, Message = iActorMessage });
  37. return;
  38. }
  39. Game.Scene.GetComponent<MessageDispatherComponent>().Handle(session, new MessageInfo(opcode, message));
  40. }
  41. }
  42. }