| | |
| | | using System.Text.Json; |
| | | using System.IO; |
| | | using WIDESEAWCS_Model.Models; |
| | | using Serilog.Core; |
| | | |
| | | namespace WIDESEAWCS_Tasks.SocketServer |
| | | { |
| | |
| | | } |
| | | |
| | | // 按客户端去重:检查是否与该客户端上次消息相同 |
| | | lock (_syncRoot) |
| | | { |
| | | if (_clientLastMessage.TryGetValue(clientId, out var prev) && message == prev) |
| | | { |
| | | continue; |
| | | } |
| | | _clientLastMessage[clientId] = message; |
| | | } |
| | | //lock (_syncRoot) |
| | | //{ |
| | | // if (_clientLastMessage.TryGetValue(clientId, out var prev) && message == prev) |
| | | // { |
| | | // QuartzLogHelper.LogInfo(Logger.None, $"来自客户端 {clientId} 的重复消息,内容: {message}", clientId); |
| | | // continue; |
| | | // } |
| | | // _clientLastMessage[clientId] = message; |
| | | //} |
| | | |
| | | // 更新客户端状态 |
| | | UpdateClientStatus(clientId, message); |