准备提供可访问的接口获取所有对方连接

Author: lindexi

src/dotnetCampus.Ipc/Internals/PeerManager.cs

@@ -8,7 +8,26 @@
 
 namespace dotnetCampus.Ipc.Internals
 {
-    class PeerManager : IDisposable
+    internal interface IPeerManager
+    {
+        /// <summary>
+        /// 和 <see cref="IpcProvider"/> 不同的是，无论是主动连接还是被动连过来的，都会触发此事件
+        /// </summary>
+        event EventHandler<PeerConnectedArgs>? PeerConnected;
+
+        /// <summary>
+        /// 当前连接的数量。此属性仅有记日志的作用。由于 IPC 将会不断多进程连接和断开，所以这个数量是不断变化的。可能获取的一刻，实际情况就和此不相同
+        /// </summary>
+        int CurrentConnectedPeerProxyCount { get; }
+
+        /// <summary>
+        /// 获取当前连接到的 <see cref="PeerProxy"/> 列表。仅表示获取时的状态，由于 IPC 将会不断多进程连接和断开，所以这个列表是不断变化的。可能获取的一刻，实际情况就和此不相同
+        /// </summary>
+        /// <returns></returns>
+        IReadOnlyList <PeerProxy> GetCurrentConnectedPeerProxyList();
+    }
+
+    class PeerManager : IPeerManager, IDisposable
     {
         public PeerManager(IpcProvider ipcProvider)
         {
@@ -19,12 +38,12 @@ public bool TryAdd(PeerProxy peerProxy)
         {
             peerProxy.PeerConnectionBroken += PeerProxy_PeerConnectionBroken;
             OnAdd(peerProxy);
-            return ConnectedServerManagerDictionary.TryAdd(peerProxy.PeerName, peerProxy);
+            return ConnectedPeerProxyDictionary.TryAdd(peerProxy.PeerName, peerProxy);
         }
 
         public bool TryGetValue(string key, [NotNullWhen(true)] out PeerProxy? peer)
         {
-            return ConnectedServerManagerDictionary.TryGetValue(key, out peer);
+            return ConnectedPeerProxyDictionary.TryGetValue(key, out peer);
         }
 
         /// <summary>
@@ -38,7 +57,7 @@ public void RemovePeerProxy(PeerProxy peerProxy)
                 throw new ArgumentException($"Must remove the Broken peer. PeerName={peerProxy.PeerName}");
             }
 
-            ConnectedServerManagerDictionary.TryRemove(peerProxy.PeerName, out var value);
+            ConnectedPeerProxyDictionary.TryRemove(peerProxy.PeerName, out var value);
 
             if (ReferenceEquals(peerProxy, value) || value is null)
             {
@@ -55,7 +74,7 @@ public void RemovePeerProxy(PeerProxy peerProxy)
                         $"Peer 断开之后，从已有列表删除时发现列表里面记录的 Peer 和当前的不是相同的一个。仅调试下抛出。PeerName={peerProxy.PeerName}");
                 }
 
-                ConnectedServerManagerDictionary.TryAdd(value.PeerName, value);
+                ConnectedPeerProxyDictionary.TryAdd(value.PeerName, value);
             }
         }
 
@@ -70,7 +89,7 @@ public async Task WaitForPeerConnectFinishedAsync(PeerProxy peerProxy)
 
             OnAdd(peerProxy);
             // 更新或注册，用于解决之前注册的实际上是断开的连接
-            ConnectedServerManagerDictionary.AddOrUpdate(peerProxy.PeerName, peerProxy, (s, proxy) => proxy);
+            ConnectedPeerProxyDictionary.AddOrUpdate(peerProxy.PeerName, peerProxy, (s, proxy) => proxy);
         }
 
         private void OnAdd(PeerProxy peerProxy)
@@ -82,6 +101,25 @@ private void OnAdd(PeerProxy peerProxy)
                 peerProxy.PeerReConnector.ReconnectFail -= PeerReConnector_ReconnectFail;
                 peerProxy.PeerReConnector.ReconnectFail += PeerReConnector_ReconnectFail;
             }
+
+            if (!ConnectedPeerProxyDictionary.ContainsKey(peerProxy.PeerName))
+            {
+                // 没有从字典找到，证明是首次连接到的。或曾经断开过的，此后再连接的
+                PeerConnected?.Invoke(this, new PeerConnectedArgs(peerProxy));
+            }
+        }
+
+        /// <inheritdoc />
+        public event EventHandler<PeerConnectedArgs>? PeerConnected;
+
+        /// <inheritdoc />
+        public int CurrentConnectedPeerProxyCount => ConnectedPeerProxyDictionary.Count;
+
+        /// <inheritdoc />
+        public IReadOnlyList<PeerProxy> GetCurrentConnectedPeerProxyList()
+        {
+            // 这里是线程安全的，但只会返回当前的状态
+            return ConnectedPeerProxyDictionary.Values.ToList();
         }
 
         private void PeerReConnector_ReconnectFail(object? sender, ReconnectFailEventArgs e)
@@ -95,7 +133,7 @@ private void PeerReConnector_ReconnectFail(object? sender, ReconnectFailEventArg
 
         public void Dispose()
         {
-            foreach (var pair in ConnectedServerManagerDictionary)
+            foreach (var pair in ConnectedPeerProxyDictionary)
             {
                 var peer = pair.Value;
                 // 为什么 PeerProxy 不加上 IDisposable 方法
@@ -104,7 +142,7 @@ public void Dispose()
             }
         }
 
-        private ConcurrentDictionary<string/*PeerName*/, PeerProxy> ConnectedServerManagerDictionary { get; } =
+        private ConcurrentDictionary<string/*PeerName*/, PeerProxy> ConnectedPeerProxyDictionary { get; } =
             new ConcurrentDictionary<string, PeerProxy>();
         private readonly IpcProvider _ipcProvider;
 

src/dotnetCampus.Ipc/Pipes/IpcServerService.cs

@@ -85,7 +85,7 @@ private void PipeServerMessage_PeerConnectBroke(object? sender, IpcPipeServerMes
         }
 
         /// <summary>
-        /// 当收到消息时触发
+        /// 当收到消息时触发。无论是哪个 Peer 收到消息，都会引发此事件
         /// </summary>
         public event EventHandler<PeerMessageArgs>? MessageReceived;
 
@@ -94,6 +94,11 @@ private void PipeServerMessage_PeerConnectBroke(object? sender, IpcPipeServerMes
         /// </summary>
         internal event EventHandler<IpcInternalPeerConnectedArgs>? PeerConnected;
 
+        /// <summary>
+        /// 当接收到消息时触发。无论是哪个 Peer 收到消息，都会引发此事件
+        /// </summary>
+        /// <param name="sender"></param>
+        /// <param name="e"></param>
         internal void OnMessageReceived(object? sender, PeerStreamMessageArgs e)
         {
             string? debugMessageBody = null;