MessageHelper.cs 2.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. 
  2. using System.Collections.Generic;
  3. namespace ET.Server
  4. {
  5. public static class MessageHelper
  6. {
  7. public static void NoticeUnitAdd(Unit unit, Unit sendUnit)
  8. {
  9. M2C_CreateUnits createUnits = new M2C_CreateUnits();
  10. createUnits.Units.Add(UnitHelper.CreateUnitInfo(sendUnit));
  11. MessageHelper.SendToClient(unit, createUnits);
  12. }
  13. public static void NoticeUnitRemove(Unit unit, Unit sendUnit)
  14. {
  15. M2C_RemoveUnits removeUnits = new M2C_RemoveUnits();
  16. removeUnits.Units.Add(sendUnit.Id);
  17. MessageHelper.SendToClient(unit, removeUnits);
  18. }
  19. public static void Broadcast(Unit unit, IActorMessage message)
  20. {
  21. Dictionary<long, AOIEntity> dict = unit.GetBeSeePlayers();
  22. foreach (AOIEntity u in dict.Values)
  23. {
  24. SendToClient(u.Unit, message);
  25. }
  26. }
  27. public static void SendToClient(Unit unit, IActorMessage message)
  28. {
  29. SendActor(unit.GetComponent<UnitGateComponent>().GateSessionActorId, message);
  30. }
  31. /// <summary>
  32. /// 发送协议给ActorLocation
  33. /// </summary>
  34. /// <param name="id">注册Actor的Id</param>
  35. /// <param name="message"></param>
  36. public static void SendToLocationActor(long id, IActorLocationMessage message)
  37. {
  38. ActorLocationSenderComponent.Instance.Send(id, message);
  39. }
  40. /// <summary>
  41. /// 发送协议给Actor
  42. /// </summary>
  43. /// <param name="actorId">注册Actor的InstanceId</param>
  44. /// <param name="message"></param>
  45. public static void SendActor(long actorId, IActorMessage message)
  46. {
  47. ActorMessageSenderComponent.Instance.Send(actorId, message);
  48. }
  49. /// <summary>
  50. /// 发送RPC协议给Actor
  51. /// </summary>
  52. /// <param name="actorId">注册Actor的InstanceId</param>
  53. /// <param name="message"></param>
  54. /// <returns></returns>
  55. public static async ETTask<IActorResponse> CallActor(long actorId, IActorRequest message)
  56. {
  57. return await ActorMessageSenderComponent.Instance.Call(actorId, message);
  58. }
  59. /// <summary>
  60. /// 发送RPC协议给ActorLocation
  61. /// </summary>
  62. /// <param name="id">注册Actor的Id</param>
  63. /// <param name="message"></param>
  64. /// <returns></returns>
  65. public static async ETTask<IActorResponse> CallLocationActor(long id, IActorLocationRequest message)
  66. {
  67. return await ActorLocationSenderComponent.Instance.Call(id, message);
  68. }
  69. }
  70. }