InitSceneStartEvent_InitGame.cs 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  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 = "abcdef", Password = "111111"});
  22. networkComponent.Remove(session.Id);
  23. // 连接Gate
  24. Entity gateSession = networkComponent.Get(s2CLogin.Address);
  25. await gateSession.GetComponent<MessageComponent>().Call<C2G_LoginGate, G2C_LoginGate>(new C2G_LoginGate(s2CLogin.Key));
  26. Log.Info("连接Gate验证成功!");
  27. }
  28. catch (RpcException e)
  29. {
  30. Log.Error(e.ToString());
  31. }
  32. catch (Exception e)
  33. {
  34. Log.Error(e.ToString());
  35. }
  36. }
  37. }
  38. }