| 1234567891011121314151617181920212223242526272829303132333435 |
- using System;
- namespace Model
- {
- public class ClientDispatcher: IMessageDispatcher
- {
- public void Dispatch(Session session, ushort opcode, int offset, byte[] messageBytes, AMessage message)
- {
- // 如果是帧同步消息,交给ClientFrameComponent处理
- FrameMessage frameMessage = message as FrameMessage;
- if (frameMessage != null)
- {
- Game.Scene.GetComponent<ClientFrameComponent>().Add(frameMessage);
- return;
- }
- // 普通消息或者是Rpc请求消息
- if (message is AMessage || message is ARequest)
- {
- MessageInfo messageInfo = new MessageInfo(opcode, message);
- if (opcode < 2000)
- {
- Game.Scene.GetComponent<EventComponent>().Run(EventIdType.MessageDeserializeFinish, messageInfo);
- }
- else
- {
- Game.Scene.GetComponent<MessageDispatherComponent>().Handle(messageInfo);
- }
- return;
- }
- throw new Exception($"message type error: {message.GetType().FullName}");
- }
- }
- }
|