root/BITKit
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

1

Browse Source
This commit is contained in:
CortexCore
2024-06-14 16:16:13 +08:00
parent ca93bd2c56
commit dfa249677f
7 changed files with 40 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Src/Core/Kcp/KcpNetClient.cs
View File

@@ -242,7 +242,7 @@ namespace BITKit.Net
else
{
returnWriter.Write(false);
returnWriter.Write("未找到对应的Rpc方法");
returnWriter.Write($"未找到对应的Rpc方法:{path}");
}
}
else

16
Src/Core/Kcp/KcpNetServer.cs
View File

@@ -66,6 +66,10 @@ namespace BITKit.Net
if (server.IsActive() is false || ManualTick) return;
server.Tick();
}
catch (SocketException)
{
//丢失链接,有用户断开连接,通常是正常现象
}
catch (Exception exception)
{
BIT4Log.LogException(exception);
@@ -254,7 +258,7 @@ namespace BITKit.Net
}
else
{
throw new Exception("未找到对应的Rpc方法");
throw new Exception($"未找到对应的Rpc方法:{path}");
}
}
@@ -262,7 +266,8 @@ namespace BITKit.Net
{
var commandObj = BITBinary.Read(reader)
.As<object[]>()[0];
if (_rpc.TryGetValue(commandObj.GetType()!.FullName!, out var func))
var funcName = commandObj.GetType()!.FullName!;
if (_rpc.TryGetValue(funcName, out var func))
{
var value = await func.As<Func<object, UniTask<object>>>().Invoke(commandObj);
returnWriter.Write(true);
@@ -270,7 +275,7 @@ namespace BITKit.Net
}
else
{
throw new Exception("未找到对应的Rpc方法");
throw new Exception($"未找到对应的Rpc方法:{funcName}");
}
}
{
@@ -471,7 +476,10 @@ namespace BITKit.Net
.Write((byte)commandType)
.WriteObject(values)
.Build();
server.Send(id,bytes, KcpChannel.Reliable);
if (server.connections.ContainsKey(id))
{
server.Send(id,bytes, KcpChannel.Reliable);
}
}
}