This commit is contained in:
ioxygen 2021-08-05 09:32:19 +08:00
parent 59ab7e3db3
commit a759f6e2d0

View File

@ -59,43 +59,16 @@ namespace FastTunnel.Core.Listener
{ {
Message<JObject> msg; Message<JObject> msg;
if (token == null) if (token == null || string.IsNullOrEmpty(words))
{ {
_logger.LogError($"无效的token -> 【异常的指令】{words}"); _logger.LogError($"无效的token -> 【异常的指令】{words}");
return false; return false;
} }
IClientMessageHandler handler = null;
try try
{ {
msg = JsonConvert.DeserializeObject<Message<JObject>>(words); msg = JsonConvert.DeserializeObject<Message<JObject>>(words);
//if (msg == null)
// throw new Exception("指令为空!");
switch (msg.MessageType)
{
case MessageType.C_LogIn: // 登录
handler = _loginHandler;
break;
case MessageType.Heart: // 心跳
handler = _heartHandler;
break;
case MessageType.C_SwapMsg: // 交换数据
handler = _swapMsgHandler;
break;
default:
throw new Exception($"未知的通讯指令 {msg.MessageType}");
}
}
catch (Exception ex)
{
_logger.LogCritical(ex, $"【异常的指令】{words}");
token.Socket.Close();
return false;
}
try
{
IClientMessageHandler handler = null; IClientMessageHandler handler = null;
switch (msg.MessageType) switch (msg.MessageType)
{ {