MessageHelper.cs 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. 
  2. namespace ET
  3. {
  4. public static class MessageHelper
  5. {
  6. public static void Broadcast(Unit unit, IActorMessage message)
  7. {
  8. var units = unit.Domain.GetComponent<UnitComponent>().GetAll();
  9. if (units == null) return;
  10. foreach (Unit u in units)
  11. {
  12. UnitGateComponent unitGateComponent = u.GetComponent<UnitGateComponent>();
  13. SendActor(unitGateComponent.GateSessionActorId, message);
  14. }
  15. }
  16. /// <summary>
  17. /// 发送协议给ActorLocation
  18. /// </summary>
  19. /// <param name="id">注册Actor的Id</param>
  20. /// <param name="message"></param>
  21. public static void SendToLocationActor(long id, IActorLocationMessage message)
  22. {
  23. ActorLocationSenderComponent.Instance.Send(id, message);
  24. }
  25. /// <summary>
  26. /// 发送协议给Actor
  27. /// </summary>
  28. /// <param name="actorId">注册Actor的InstanceId</param>
  29. /// <param name="message"></param>
  30. public static void SendActor(long actorId, IActorMessage message)
  31. {
  32. ActorMessageSenderComponent.Instance.Send(actorId, message);
  33. }
  34. /// <summary>
  35. /// 发送RPC协议给Actor
  36. /// </summary>
  37. /// <param name="actorId">注册Actor的InstanceId</param>
  38. /// <param name="message"></param>
  39. /// <returns></returns>
  40. public static async ETTask<IActorResponse> CallActor(long actorId, IActorRequest message)
  41. {
  42. return await ActorMessageSenderComponent.Instance.Call(actorId, message);
  43. }
  44. /// <summary>
  45. /// 发送RPC协议给ActorLocation
  46. /// </summary>
  47. /// <param name="id">注册Actor的Id</param>
  48. /// <param name="message"></param>
  49. /// <returns></returns>
  50. public static async ETTask<IActorResponse> CallLocationActor(long id, IActorLocationRequest message)
  51. {
  52. return await ActorLocationSenderComponent.Instance.Call(id, message);
  53. }
  54. }
  55. }