|
|
|
|
@ -67,8 +67,9 @@ namespace Admin.Core.Socket
|
|
|
|
|
client.Logger.Info($"{client.IP}:{client.Port} 客户端正在连接...");
|
|
|
|
|
return EasyTask.CompletedTask;
|
|
|
|
|
};//有客户端正在连接
|
|
|
|
|
service.Connected = (client, e) => { client.Logger.Info($"{client.IP}:{client.Port} 客户端连接成功！目前客户端连接数{service.Count}");
|
|
|
|
|
log.Info($"{client.IP}:{client.Port} 客户端连接成功！目前客户端连接数{service.Count}");
|
|
|
|
|
service.Connected = (client, e) => {
|
|
|
|
|
client.Logger.Info($"{client.IP}:{client.Port} 客户端连接成功！目前客户端连接数{service.Count}");
|
|
|
|
|
|
|
|
|
|
SetProdStoreClientId(client);
|
|
|
|
|
|
|
|
|
|
return EasyTask.CompletedTask;
|
|
|
|
|
@ -89,7 +90,7 @@ namespace Admin.Core.Socket
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
var mes = Encoding.UTF8.GetString(e.ByteBlock.Buffer, 0, e.ByteBlock.Len);//注意：数据长度是byteBlock.Len
|
|
|
|
|
log.Info("原始报文:"+mes);
|
|
|
|
|
|
|
|
|
|
//心跳包
|
|
|
|
|
if (mes.Contains("heartbeat"))
|
|
|
|
|
{
|
|
|
|
|
@ -107,16 +108,14 @@ namespace Admin.Core.Socket
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
log.Info("条码报文:" + mes);
|
|
|
|
|
ReceiveCodeDelegateEvent?.Invoke(client.IP,mes);
|
|
|
|
|
client.Logger.Info($"已从{client.IP}:{client.Port}》接收到信息：{mes}");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
{
|
|
|
|
|
client.Logger.Error($"异常：{ex.Message}");
|
|
|
|
|
log.Error($"异常：{ex.Message}");
|
|
|
|
|
}
|
|
|
|
|
return EasyTask.CompletedTask;
|
|
|
|
|
};
|
|
|
|
|
|
liulb@mesnac.com
10 months ago