feat(server): 添加基于 Aspire 的服务拓扑监控

实现新的服务发现监控机制：
- ServerComponentAgent 添加 WatchServiceTopology 方法
- 通过定时轮询构建服务拓扑快照
- 检测服务上线/下线事件并分发
- 添加 ServiceOnline/OfflineEventArgs 事件参数
- 新增 EventId.ServiceOnline/Offline 事件ID

Author: AlianBlank

GameFrameX.Apps/Common/Event/EventId.cs

@@ -1,4 +1,4 @@
-// ==========================================================================================
+// ==========================================================================================
 //  GameFrameX 组织及其衍生项目的版权、商标、专利及其他相关权利
 //  GameFrameX organization and its derivative projects' copyrights, trademarks, patents, and related rights
 //  均受中华人民共和国及相关国际法律法规保护。
@@ -84,6 +84,16 @@ public enum EventId
     /// 世界等级改变
     /// </summary>
     WorldLevelChange,
+
+    /// <summary>
+    /// 服务上线
+    /// </summary>
+    ServiceOnline,
+
+    /// <summary>
+    /// 服务下线
+    /// </summary>
+    ServiceOffline,
 
     #endregion
-}
+}

GameFrameX.Apps/Common/EventData/ServiceOfflineEventArgs.cs

@@ -0,0 +1,19 @@
+using GameFrameX.Core.Abstractions.Events;
+
+namespace GameFrameX.Apps.Common.EventData;
+
+public sealed class ServiceOfflineEventArgs : GameEventArgs
+{
+    public string ServiceName { get; }
+    public long InstanceId { get; }
+    public string Reason { get; }
+    public DateTime Timestamp { get; }
+
+    public ServiceOfflineEventArgs(string serviceName, long instanceId, string reason, DateTime timestamp)
+    {
+        ServiceName = serviceName;
+        InstanceId = instanceId;
+        Reason = reason;
+        Timestamp = timestamp;
+    }
+}

GameFrameX.Apps/Common/EventData/ServiceOnlineEventArgs.cs

@@ -0,0 +1,19 @@
+using GameFrameX.Core.Abstractions.Events;
+
+namespace GameFrameX.Apps.Common.EventData;
+
+public sealed class ServiceOnlineEventArgs : GameEventArgs
+{
+    public string ServiceName { get; }
+    public long InstanceId { get; }
+    public IReadOnlyList<string> Endpoints { get; }
+    public DateTime Timestamp { get; }
+
+    public ServiceOnlineEventArgs(string serviceName, long instanceId, DateTime timestamp, IReadOnlyList<string> endpoints = null)
+    {
+        ServiceName = serviceName;
+        InstanceId = instanceId;
+        Timestamp = timestamp;
+        Endpoints = endpoints ?? Array.Empty<string>();
+    }
+}

GameFrameX.Hotfix/Logic/Server/ServerComponentAgent.cs

@@ -1,4 +1,4 @@
-// ==========================================================================================
+// ==========================================================================================
 //  GameFrameX 组织及其衍生项目的版权、商标、专利及其他相关权利
 //  GameFrameX organization and its derivative projects' copyrights, trademarks, patents, and related rights
 //  均受中华人民共和国及相关国际法律法规保护。
@@ -31,23 +31,34 @@
 
 using GameFrameX.Apps.Server.Component;
 using GameFrameX.Apps.Server.Entity;
+using GameFrameX.Apps.Common.Event;
+using GameFrameX.Apps.Common.EventData;
 using GameFrameX.Core.Abstractions.Attribute;
 using GameFrameX.Core.Abstractions.Events;
+using GameFrameX.Core.Events;
 using GameFrameX.Core.Timer.Handler;
 using GameFrameX.Foundation.Utility;
 using GameFrameX.Hotfix.Logic.Player.Login;
+using System.Collections;
+using System.Security.Cryptography;
+using System.Text;
 
 namespace GameFrameX.Hotfix.Logic.Server;
 
 public class ServerComponentAgent : StateComponentAgent<ServerComponent, ServerState>
 {
+    private readonly Dictionary<string, HashSet<long>> _topologySnapshot = new(StringComparer.OrdinalIgnoreCase);
+    private readonly Dictionary<string, int> _offlineConfirmCounter = new(StringComparer.OrdinalIgnoreCase);
+    private static readonly string[] TopologyServiceNames = { GlobalConst.GameServiceName, GlobalConst.SocialServiceName, GlobalConst.GatewayServiceName };
+
     public override async Task<bool> Active()
     {
         var isContinue = await base.Active();
         if (isContinue)
         {
             // 跨天定时器
             WithCronExpression<CrossDayTimeHandler>("0 0 0 * * ? *");
+            Schedule<ServiceTopologyWatcherHandler>(TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(5));
             if (State.FirstStartTime == default)
             {
                 State.FirstStartTime = TimerHelper.UnixTimeSeconds();
@@ -57,6 +68,120 @@ public override async Task<bool> Active()
 
         return isContinue;
     }
+
+    private Task WatchServiceTopology()
+    {
+        var currentSnapshot = BuildCurrentTopologySnapshot();
+        foreach (var currentPair in currentSnapshot)
+        {
+            var serviceName = currentPair.Key;
+            var currentInstances = currentPair.Value;
+            _topologySnapshot.TryGetValue(serviceName, out var previousInstances);
+            previousInstances ??= new HashSet<long>();
+            foreach (var instance in currentInstances)
+            {
+                if (!previousInstances.Contains(instance.Key))
+                {
+                    EventDispatcher.Dispatch(ActorId, (int)EventId.ServiceOnline, new ServiceOnlineEventArgs(serviceName, instance.Key, DateTime.UtcNow, instance.Value));
+                }
+
+                _offlineConfirmCounter.Remove(GetOfflineKey(serviceName, instance.Key));
+            }
+
+            foreach (var instanceId in previousInstances)
+            {
+                if (currentInstances.ContainsKey(instanceId))
+                {
+                    continue;
+                }
+
+                var counterKey = GetOfflineKey(serviceName, instanceId);
+                _offlineConfirmCounter.TryGetValue(counterKey, out var counter);
+                counter++;
+                if (counter >= 2)
+                {
+                    EventDispatcher.Dispatch(ActorId, (int)EventId.ServiceOffline, new ServiceOfflineEventArgs(serviceName, instanceId, "Removed", DateTime.UtcNow));
+                    _offlineConfirmCounter.Remove(counterKey);
+                    continue;
+                }
+
+                _offlineConfirmCounter[counterKey] = counter;
+            }
+        }
+
+        _topologySnapshot.Clear();
+        foreach (var pair in currentSnapshot)
+        {
+            _topologySnapshot[pair.Key] = pair.Value.Keys.ToHashSet();
+        }
+
+        return Task.CompletedTask;
+    }
+
+    private static string GetOfflineKey(string serviceName, long instanceId)
+    {
+        return $"{serviceName}:{instanceId}";
+    }
+
+    private static Dictionary<string, Dictionary<long, IReadOnlyList<string>>> BuildCurrentTopologySnapshot()
+    {
+        var snapshot = new Dictionary<string, Dictionary<long, IReadOnlyList<string>>>(StringComparer.OrdinalIgnoreCase);
+        foreach (var serviceName in TopologyServiceNames)
+        {
+            snapshot[serviceName] = new Dictionary<long, IReadOnlyList<string>>();
+        }
+
+        var variables = Environment.GetEnvironmentVariables();
+        foreach (DictionaryEntry variable in variables)
+        {
+            if (variable.Key is not string rawKey || variable.Value is not string rawValue || string.IsNullOrWhiteSpace(rawValue))
+            {
+                continue;
+            }
+
+            var key = rawKey.Replace("__", ":", StringComparison.Ordinal).Trim();
+            if (!key.StartsWith("services:", StringComparison.OrdinalIgnoreCase))
+            {
+                continue;
+            }
+
+            var segments = key.Split(':', StringSplitOptions.RemoveEmptyEntries);
+            if (segments.Length < 3)
+            {
+                continue;
+            }
+
+            var serviceToken = segments[1];
+            var serviceName = TopologyServiceNames.FirstOrDefault(name => string.Equals(name, serviceToken, StringComparison.OrdinalIgnoreCase));
+            if (serviceName == null)
+            {
+                continue;
+            }
+
+            if (GlobalSettings.CurrentSetting != null && string.Equals(serviceName, GlobalSettings.CurrentSetting.ServerType, StringComparison.OrdinalIgnoreCase))
+            {
+                continue;
+            }
+
+            var instanceId = BuildInstanceId(serviceName, rawValue);
+            if (!snapshot[serviceName].TryGetValue(instanceId, out var endpoints))
+            {
+                endpoints = Array.Empty<string>();
+                snapshot[serviceName][instanceId] = endpoints;
+            }
+
+            snapshot[serviceName][instanceId] = endpoints.Concat(new[] { rawValue }).Distinct(StringComparer.OrdinalIgnoreCase).ToArray();
+        }
+
+        return snapshot;
+    }
+
+    private static long BuildInstanceId(string serviceName, string endpoint)
+    {
+        var payload = $"{serviceName}|{endpoint}";
+        var hash = SHA256.HashData(Encoding.UTF8.GetBytes(payload));
+        return Math.Abs(BitConverter.ToInt64(hash, 0));
+    }
 
     [Service]
     [Discard]
@@ -207,5 +332,13 @@ protected override async Task HandleTimer(ServerComponentAgent agent, GameEventA
             await ActorManager.CrossDay(1, GlobalConst.ActorTypeServer);
         }
     }
+
+    private class ServiceTopologyWatcherHandler : TimerHandler<ServerComponentAgent>
+    {
+        protected override Task HandleTimer(ServerComponentAgent agent, GameEventArgs gameEventArgs)
+        {
+            return agent.WatchServiceTopology();
+        }
+    }
     /*******************演示代码**************************/
-}
+}