调整EventDispatcher组织结构，以便热更新

Geek.Server.Hotfix/Common/Events/EventId.cs → Geek.Server.App/Common/Event/EventId.cs

@@ -4,6 +4,7 @@ public enum EventID
     {
         #region role event
         //玩家事件
+        SessionRemove = 1000,
         RoleLevelUp = 1001, //玩家等级提升
         RoleVipChange, //玩家vip改变
         OnRoleOnline, //玩家上线

Geek.Server.App/Logic/Server/ServerComp.cs

@@ -15,7 +15,10 @@ public class ServerState : CacheState
     [Comp(ActorType.Server)]
     public class ServerComp : StateComp<ServerState>
     {
-
+        /// <summary>
+        /// 存放在此处的数据不会回存到数据库
+        /// </summary>
+        public HashSet<long> OnlineSet = new();
     }
 
 }

Geek.Server.Core/Events/EventDispatcher.cs

@@ -0,0 +1,37 @@
+
+using NLog;
+
+namespace Geek.Server
+{
+    public static class EventDispatcher
+    {
+        public static void Dispatch(long id, int evtId, Param args = null)
+        {
+            var actor = ActorMgr.GetActor(id);
+            if (actor != null)
+            {
+                var evt = new Event
+                {
+                    EventId = evtId,
+                    Data = args
+                };
+
+                actor.Tell(async () =>
+                {
+                    // 事件需要在本actor内执行，不可多线程执行，所以不能使用Task.WhenAll来处理
+                    var listeners = HotfixMgr.FindListeners(actor.Type, evtId);
+                    if (listeners.IsNullOrEmpty())
+                    {
+                        // Log.Warn($"事件：{(EventID)evtId} 没有找到任何监听者");
+                        return;
+                    }
+                    foreach (var listener in listeners)
+                    {
+                        var comp = await actor.GetCompAgent(listener.AgentType);
+                        await listener.HandleEvent(comp, evt);
+                    }
+                });
+            }
+        }
+    }
+}

Geek.Server.Hotfix/Common/Events/EventDispatcher.cs → Geek.Server.Hotfix/Common/Events/EventDispatcherExtensions.cs

@@ -1,7 +1,8 @@
-
+using Server.Logic.Logic;
+
 namespace Geek.Server
 {
-    public static class EventDispatcher
+    public static class EventDispatcherExtensions
     {
 
         private static readonly Logger Log = LogManager.GetCurrentClassLogger();
@@ -20,9 +21,9 @@ public static void Dispatch(this ICompAgent agent, int evtId, Param args = null)
             if ((EventID)evtId > EventID.RoleSeparator && agent.OwnerType > ActorType.Separator)
             {
                 // 全局非玩家事件，抛给所有玩家
-                // agent.Tell(()
-                //     => ServerCompAgent.OnlineRoleForeach(role
-                //     => role.Dispatch(evtId, args)));
+                agent.Tell(()
+                    => ServerCompAgent.OnlineRoleForeach(role
+                    => role.Dispatch(evtId, args)));
             }
 
             static void SelfHandle(ICompAgent agent, int evtId, Event evt)

Geek.Server.Hotfix/Logic/Server/ServerCompAgent.cs

@@ -1,4 +1,5 @@
 
+using Geek.Server.Role;
 using Geek.Server.Server;
 
 namespace Server.Logic.Logic
@@ -29,6 +30,19 @@ public override void Active()
             Schedule<ScheduleTimer>(TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(3));
         }
 
+        public static async Task OnlineRoleForeach(Action<RoleCompAgent> func)
+        {
+            var serverComp = await ActorMgr.GetCompAgent<ServerCompAgent>();
+            serverComp.Tell(async () =>
+            {
+                foreach (var roleId in serverComp.Comp.OnlineSet)
+                {
+                    var roleComp = await ActorMgr.GetCompAgent<RoleCompAgent>(roleId);
+                    roleComp.Tell(() => func(roleComp));
+                }
+            });
+        }
+
         private Task TestDelayTimer()
         {
             LOGGER.Debug("ServerCompAgent.TestDelayTimer.延时2秒执行.执行一次");