| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- using System;
- using ETModel;
- namespace ETHotfix
- {
- public class InnerMessageDispatcher: IMessageDispatcher
- {
- public void Dispatch(Session session, ushort opcode, object message)
- {
- // 收到actor消息,放入actor队列
- if (message is IActorMessage iActorMessage)
- {
- Entity entity = (Entity)Game.EventSystem.Get(iActorMessage.ActorId);
- if (entity == null)
- {
- Log.Warning($"not found actor: {iActorMessage.ActorId}");
- ActorResponse response = new ActorResponse
- {
- Error = ErrorCode.ERR_NotFoundActor,
- RpcId = iActorMessage.RpcId
- };
- session.Reply(response);
- return;
- }
-
- MailBoxComponent mailBoxComponent = entity.GetComponent<MailBoxComponent>();
- if (mailBoxComponent == null)
- {
- ActorResponse response = new ActorResponse
- {
- Error = ErrorCode.ERR_ActorNoMailBoxComponent,
- RpcId = iActorMessage.RpcId
- };
- session.Reply(response);
- Log.Error($"actor没有挂载MailBoxComponent组件: {entity.GetType().Name} {entity.Id}");
- return;
- }
-
- mailBoxComponent.Add(new ActorMessageInfo() { Session = session, Message = iActorMessage });
- return;
- }
-
- Game.Scene.GetComponent<MessageDispatherComponent>().Handle(session, new MessageInfo(opcode, message));
- }
- }
- }
|