Program.cs 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. using System;
  2. using System.Threading;
  3. using Model;
  4. using NLog;
  5. namespace App
  6. {
  7. internal static class Program
  8. {
  9. private static void Main(string[] args)
  10. {
  11. // 异步方法全部会回掉到主线程
  12. SynchronizationContext.SetSynchronizationContext(new OneThreadSynchronizationContext());
  13. try
  14. {
  15. ObjectEvents.Instance.Register("Model", typeof(Game).Assembly);
  16. ObjectEvents.Instance.Register("Hotfix", DllHelper.GetHotfixAssembly());
  17. Options options = Game.Scene.AddComponent<OptionComponent, string[]>(args).Options;
  18. StartConfig startConfig = Game.Scene.AddComponent<StartConfigComponent, string, int>(options.Config, options.AppId).StartConfig;
  19. IdGenerater.AppId = options.AppId;
  20. LogManager.Configuration.Variables["appType"] = startConfig.AppType.ToString();
  21. LogManager.Configuration.Variables["appId"] = startConfig.AppId.ToString();
  22. Log.Info("server start........................");
  23. Game.Scene.AddComponent<OpcodeTypeComponent>();
  24. Game.Scene.AddComponent<MessageDispatherComponent, AppType>(startConfig.AppType);
  25. // 根据不同的AppType添加不同的组件
  26. OuterConfig outerConfig = startConfig.GetComponent<OuterConfig>();
  27. InnerConfig innerConfig = startConfig.GetComponent<InnerConfig>();
  28. ClientConfig clientConfig = startConfig.GetComponent<ClientConfig>();
  29. switch (startConfig.AppType)
  30. {
  31. case AppType.Manager:
  32. Game.Scene.AddComponent<NetInnerComponent, string, int>(innerConfig.Host, innerConfig.Port);
  33. Game.Scene.AddComponent<NetOuterComponent, string, int>(outerConfig.Host, outerConfig.Port);
  34. Game.Scene.AddComponent<AppManagerComponent>();
  35. break;
  36. case AppType.Realm:
  37. Game.Scene.AddComponent<ActorMessageDispatherComponent>();
  38. Game.Scene.AddComponent<ActorManagerComponent>();
  39. Game.Scene.AddComponent<ActorComponent>();
  40. Game.Scene.AddComponent<NetInnerComponent, string, int>(innerConfig.Host, innerConfig.Port);
  41. Game.Scene.AddComponent<NetOuterComponent, string, int>(outerConfig.Host, outerConfig.Port);
  42. Game.Scene.AddComponent<RealmGateAddressComponent>();
  43. break;
  44. case AppType.Gate:
  45. Game.Scene.AddComponent<ActorMessageDispatherComponent>();
  46. Game.Scene.AddComponent<ActorManagerComponent>();
  47. Game.Scene.AddComponent<ActorComponent>();
  48. Game.Scene.AddComponent<NetInnerComponent, string, int>(innerConfig.Host, innerConfig.Port);
  49. Game.Scene.AddComponent<NetOuterComponent, string, int>(outerConfig.Host, outerConfig.Port);
  50. Game.Scene.AddComponent<GateSessionKeyComponent>();
  51. break;
  52. case AppType.Location:
  53. Game.Scene.AddComponent<NetInnerComponent, string, int>(innerConfig.Host, innerConfig.Port);
  54. Game.Scene.AddComponent<LocationComponent>();
  55. break;
  56. case AppType.AllServer:
  57. Game.Scene.AddComponent<LocationComponent>();
  58. Game.Scene.AddComponent<ActorMessageDispatherComponent>();
  59. Game.Scene.AddComponent<NetInnerComponent, string, int>(innerConfig.Host, innerConfig.Port);
  60. Game.Scene.AddComponent<NetOuterComponent, string, int>(outerConfig.Host, outerConfig.Port);
  61. Game.Scene.AddComponent<AppManagerComponent>();
  62. Game.Scene.AddComponent<LocationProxyComponent>();
  63. Game.Scene.AddComponent<ActorManagerComponent>();
  64. Game.Scene.AddComponent<ActorComponent>();
  65. Game.Scene.AddComponent<RealmGateAddressComponent>();
  66. Game.Scene.AddComponent<GateSessionKeyComponent>();
  67. break;
  68. case AppType.Benchmark:
  69. Game.Scene.AddComponent<NetOuterComponent>();
  70. Game.Scene.AddComponent<BenchmarkComponent, string>(clientConfig.Address);
  71. break;
  72. default:
  73. throw new Exception($"命令行参数没有设置正确的AppType: {startConfig.AppType}");
  74. }
  75. while (true)
  76. {
  77. try
  78. {
  79. Thread.Sleep(1);
  80. Game.Poller.Update();
  81. ObjectEvents.Instance.Update();
  82. }
  83. catch (Exception e)
  84. {
  85. Log.Error(e.ToString());
  86. }
  87. }
  88. }
  89. catch (Exception e)
  90. {
  91. Log.Error(e.ToString());
  92. }
  93. }
  94. }
  95. }