| 123456789101112131415161718192021222324252627282930313233 |
- using System;
- using Model;
- using MongoDB.Bson;
- namespace Controller
- {
- [Event(EventType.LogicRecvMessage, ServerType.All)]
- public class LogicRecvMessageEvent: IEventSync
- {
- public void Run(Env env)
- {
- byte[] message = env.Get<byte[]>(EnvKey.Message);
- int opcode = BitConverter.ToUInt16(message, 0);
- // 如果是客户端消息,转交给unit actor处理
- // 逻辑服收到客户端消息opcode(2) + id(12) + content
- if (MessageTypeHelper.IsClientMessage(opcode))
- {
- byte[] idBuffer = new byte[12];
- Array.Copy(message, 2, idBuffer, 0, 12);
- ObjectId unitId = new ObjectId(idBuffer);
- Unit unit = World.Instance.GetComponent<UnitComponent>().Get(unitId);
- if (unit != null)
- {
- unit.GetComponent<ActorComponent>().Add(env);
- }
- return;
- }
- World.Instance.GetComponent<EventComponent<MessageAttribute>>().RunAsync(opcode, env);
- }
- }
- }
|