170

src/linker.messenger.decenter/DecenterClientTransfer.cs

@@ -58,7 +58,7 @@ namespace linker.messenger.decenter
             }
             return Helper.EmptyArray;
         }
-        public Memory<byte> Sync(DecenterSyncInfo170 decenterSyncInfo)
+        public Memory<byte> Sync170(DecenterSyncInfo170 decenterSyncInfo)
         {
             IDecenter sync = syncs.FirstOrDefault(c => c.Name == decenterSyncInfo.Name);
             if (sync != null)

src/linker.messenger.decenter/messenger/DecenterMessenger.cs

@@ -141,27 +141,41 @@ namespace linker.messenger.decenter
             connection.Write(syncTreansfer.Sync(info));
         }
 
-        [MessengerId((ushort)DecenterMessengerIds.Sync170)]
+        [MessengerId((ushort)DecenterMessengerIds.Sync170)] 
         public async void Sync170(IConnection connection)
         {
-            DecenterSyncInfo170 info = serializer.Deserialize<DecenterSyncInfo170>(connection.ReceiveRequestWrap.Payload.Span);
-            Memory<byte> memory = syncTreansfer.Sync(info);
-
-            //群发来的，我就回复
-            if (string.IsNullOrWhiteSpace(info.ToMachineId))
+            try
             {
-                await sender.SendOnly(new MessageRequestWrap
+                DecenterSyncInfo170 info = serializer.Deserialize<DecenterSyncInfo170>(connection.ReceiveRequestWrap.Payload.Span);
+                Memory<byte> memory = syncTreansfer.Sync170(info);
+
+                //群发来的，我就回复
+                if (string.IsNullOrWhiteSpace(info.ToMachineId))
                 {
-                    Connection = signInClientState.Connection,
-                    MessengerId = (ushort)DecenterMessengerIds.SyncForward170,
-                    Payload = serializer.Serialize(new DecenterSyncInfo170
+                    await sender.SendOnly(new MessageRequestWrap
                     {
-                        Data = memory,
-                        FromMachineId = signInClientState.Connection.Id,
-                        ToMachineId = info.FromMachineId,
-                        Name = info.Name
-                    })
-                });
+                        Connection = signInClientState.Connection,
+                        MessengerId = (ushort)DecenterMessengerIds.SyncForward170,
+                        Payload = serializer.Serialize(new DecenterSyncInfo170
+                        {
+                            Data = memory,
+                            FromMachineId = signInClientState.Connection.Id,
+                            ToMachineId = info.FromMachineId,
+                            Name = info.Name
+                        })
+                    });
+                }
+            }
+            catch (Exception)
+            {
+                try
+                {
+                    DecenterSyncInfo info = serializer.Deserialize<DecenterSyncInfo>(connection.ReceiveRequestWrap.Payload.Span);
+                    LoggerHelper.Instance.Warning(info.Name);
+                }
+                catch (Exception)
+                {
+                }
             }
         }
     }

version.txt

@@ -1,5 +1,5 @@
 v1.7.0
-2025-03-18 14:28:31
+2025-03-18 15:47:09
 1. 优化linux下路由跟踪问题，提高启动速度
 2. 优化linux下获取本机IP问题，提升虚拟网卡稳定性
 3. 增加中继cdkey，使用cdkey解锁公开中继节点的带宽、流量、连接数限制