GateRecvClientMessageEvent.cs 951 B

1234567891011121314151617181920212223242526
  1. using System;
  2. using Common.Network;
  3. using Model;
  4. namespace Controller
  5. {
  6. [Event(EventType.GateRecvClientMessage, ServerType.Gate)]
  7. public class GateRecvClientMessageEvent : IEventSync
  8. {
  9. public void Run(Env env)
  10. {
  11. byte[] message = env.Get<byte[]>(EnvKey.Message);
  12. AChannel channel = env.Get<AChannel>(EnvKey.Channel);
  13. // 进行消息分发
  14. ChannelUnitInfoComponent channelUnitInfoComponent = channel.GetComponent<ChannelUnitInfoComponent>();
  15. byte[] idBuffer = channelUnitInfoComponent.UnitId.ToByteArray();
  16. byte[] buffer = new byte[message.Length + 12];
  17. Array.Copy(message, 0, buffer, 0, 4);
  18. Array.Copy(idBuffer, 0, buffer, 4, idBuffer.Length);
  19. Array.Copy(message, 4, buffer, 4 + 12, message.Length - 4);
  20. string address = AddressHelper.GetAddressByServerName(channelUnitInfoComponent.ServerName);
  21. World.Instance.GetComponent<NetworkComponent>().SendAsync(address, buffer);
  22. }
  23. }
  24. }