InitSceneStartEvent_InitGame.cs 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. using System;
  2. using Base;
  3. using Model;
  4. namespace Controller
  5. {
  6. /// <summary>
  7. /// 初始化游戏
  8. /// </summary>
  9. [Event(EventIdType.InitSceneStart)]
  10. public class InitSceneStartEvent_InitGame: IEvent
  11. {
  12. public async void Run()
  13. {
  14. Game.Scene.AddComponent<MessageDispatherComponent, string>("Client");
  15. NetworkComponent networkComponent = Game.Scene.AddComponent<NetworkComponent, NetworkProtocol>(NetworkProtocol.TCP);
  16. Entity session = networkComponent.Get("127.0.0.1:8888");
  17. try
  18. {
  19. // 订阅服务端日志, 服务端收到这个消息会将之后的日志转发给客户端
  20. await session.GetComponent<MessageComponent>().Call<C2R_SubscribeLog, R2C_SubscribeLog>(new C2R_SubscribeLog());
  21. R2C_Login s2CLogin = await session.GetComponent<MessageComponent>().Call<C2R_Login, R2C_Login>(new C2R_Login {Account = "111", Password = "111111"});
  22. // 连接Gate
  23. Entity gateSession = networkComponent.Get(s2CLogin.Address);
  24. await gateSession.GetComponent<MessageComponent>().Call<C2G_LoginGate, G2C_LoginGate>(new C2G_LoginGate(s2CLogin.Key));
  25. Log.Info("连接Gate验证成功!");
  26. }
  27. catch (RpcException e)
  28. {
  29. Log.Error(e.ToString());
  30. }
  31. catch (Exception e)
  32. {
  33. Log.Error(e.ToString());
  34. }
  35. }
  36. }
  37. }