ET9_WebGL_Base/CSharp/Game/Controller/Event/GateMessageEvent.cs

using System;
using Common.Network;
using Model;

namespace Controller
{
	[Event(EventType.GateMessage, ServerType.Gate)]
	public class GateMessageEvent : IEventSync
	{
		public void Run(Env env)
		{
			byte[] message = env.Get<byte[]>(EnvKey.Message);
			AChannel channel = env.Get<AChannel>(EnvKey.Channel);

			// 进行消息分发
			int opcode = BitConverter.ToUInt16(message, 0);
			if (!MessageTypeHelper.IsClientMessage(opcode))
			{
				return;
			}

			ChannelUnitInfoComponent channelUnitInfoComponent = channel.GetComponent<ChannelUnitInfoComponent>();
			byte[] idBuffer = channelUnitInfoComponent.PlayerId.ToByteArray();
			byte[] buffer = new byte[message.Length + 12];
			Array.Copy(message, 0, buffer, 0, 4);
			Array.Copy(idBuffer, 0, buffer, 4, idBuffer.Length);
			Array.Copy(message, 4, buffer, 4 + 12, message.Length - 4);
			string address = AddressHelper.GetAddressByServerName(channelUnitInfoComponent.ServerName);
			World.Instance.GetComponent<NetworkComponent>().SendAsync(address, buffer);
		}
	}
}