using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; using System.Threading; using System.Diagnostics; using F.Studio.Common.Cfg; using System.Collections.Concurrent; namespace EC.UI { public class TCPMonitor:IDisposable { public String IP { get; set; } public int Port { get; set; } //7788 public ConcurrentQueue<String> CmdQueue { get; set; } public event EventHandler<ReceivedEventArgs> ReceivedData; private bool IsRuning = false; private bool Enabled = false; private bool disposed = false; public int _WaitSeconds = 3; public GatherDataInfo LastGatherData { get; private set; } public TCPMonitor(string ip, int port) { this.IP = ip; this.Port = port; LastGatherData = new GatherDataInfo() { Status = 0 }; CmdQueue = new ConcurrentQueue<string>(); } public void Start() { if (IsRuning) return; Enabled = true; IsRuning = true; ThreadPool.QueueUserWorkItem((o) => { _Start(); }); } public void SendCmd(string cmd) { CmdQueue.Enqueue(cmd); #region //if (!Enabled) return; //using (TcpClient tcpClient = new TcpClient()) //{ // NetworkStream stream = null; // try // { // tcpClient.Connect(IP, Port); // stream = tcpClient.GetStream(); // stream.ReadTimeout = 1000 * 30;//30秒读超时 // var cmdStr=cmd; // var cmdBytes = Encoding.UTF8.GetBytes(cmdStr); // stream.Write(cmdBytes, 0, cmdBytes.Length); // LogInfo("发送指令:" + cmdStr); // LogInfo(string.Format("开始{0}秒等待...",_WaitSeconds)); // Thread.Sleep(1000 * _WaitSeconds); // LogInfo("开始读返回数据，超时:30秒"); // Byte[] buffer = new byte[1024]; // StringBuilder sb = new StringBuilder(); // var len = 0; // try // { // len = stream.Read(buffer, 0, buffer.Length); // while (len > 0) // { // var strData = Encoding.UTF8.GetString(buffer, 0, len); // sb.Append(strData); // LogInfo("Data:" + strData.TrimEnd(" ".ToCharArray()) + " Len:" + len); // if (strData.IndexOf("Result:") > 0) // { // break; // } // len = stream.Read(buffer, 0, buffer.Length); // } // } // catch (Exception ex) { Console.WriteLine("读数据:" + ex.Message); } // #region 解析数据 // if (sb.Length>=10) // { // var strData = sb.ToString(); // var index=strData.IndexOf("Result:"); // if (strData.StartsWith("Check:", StringComparison.OrdinalIgnoreCase) && index> 0) // { // var data = strData.Substring(6,index-6); // var arr = data.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries); // if (arr.Length == 3) // { // var pass = arr[2].StartsWith("OK", StringComparison.OrdinalIgnoreCase); // if (ReceivedData != null && pass) // { // ReceivedData(this, new ReceivedEventArgs() { Cmd = -1, MNo = arr[0] }); // } // } // } // } // #endregion // } // catch (Exception ex) // { // LogErr(ex); // throw ex; // } // finally // { // IsRuning = false; // try { stream.Close(); } // catch { } // try { tcpClient.Close(); } // catch { } // LogInfo("完成本次通讯:" + Thread.CurrentThread.ManagedThreadId); // } //} #endregion } private void _Start() { // return;//目前不使用 LogInfo("进入工作线程:" + Thread.CurrentThread.ManagedThreadId); using (TcpClient tcpClient = new TcpClient()) { NetworkStream stream=null; try { tcpClient.Connect(IP, Port); SetKeepAlive(tcpClient.Client, 1000 * 30, 1000);//无数据传输后30秒发起心跳检测，每1秒进行一次，5次失败后streamRead将报错 stream = tcpClient.GetStream(); stream.ReadTimeout = 1000 * 30;//30秒读超时 #region 发送指令 让电子秤每秒发送一次 //var cmd = "CP 1P "; //var cmdBytes = Encoding.Default.GetBytes(cmd); //stream.Write(cmdBytes, 0, cmdBytes.Length); #endregion Byte[] buffer = new byte[1024]; int errCount = 0; StringBuilder sb = new StringBuilder(); #region 循环检测 DateTime lastSendTime = DateTime.Now; while (Enabled) { try { if ((DateTime.Now - lastSendTime).TotalSeconds > 30) { CmdQueue.Enqueue("$Ping$:" + DateTime.Now.Ticks + "$End$"); } #region 线发送指令 if (CmdQueue.Count > 0) { var cmdStr=""; if (CmdQueue.TryDequeue(out cmdStr)) { var cmdBytes = Encoding.UTF8.GetBytes(cmdStr); stream.Write(cmdBytes, 0, cmdBytes.Length); LogInfo("发送指令:" + cmdStr); lastSendTime = DateTime.Now; } } #endregion if (!tcpClient.Connected) { //完全没鸟用 throw new Exception("tcpClient.Connected==false链接断开了!"); } if (stream.DataAvailable) { var len = stream.Read(buffer, 0, buffer.Length); var rStr = Encoding.Default.GetString(buffer, 0, len); var checkIndex = rStr.IndexOf("Check:"); if (checkIndex > 0) { rStr = rStr.Substring(checkIndex); } sb.Append(rStr); LogInfo("Data:" + rStr.TrimEnd(" ".ToCharArray()) + " Len:" + len); #region 尝试解析数据 if (sb.Length >= 10) { var strData = sb.ToString(); if (strData.StartsWith("Check:", StringComparison.OrdinalIgnoreCase) ) { var index = strData.IndexOf("Result:"); if (index > 0) { var data = strData.Substring(6, index - 6); var arr = data.Split(",".ToCharArray(), StringSplitOptions.RemoveEmptyEntries); if (arr.Length == 3) { var pass = arr[2].StartsWith("OK", StringComparison.OrdinalIgnoreCase); sb.Clear();//清空缓存 if (ReceivedData != null && pass) { ReceivedData(this, new ReceivedEventArgs() { Cmd = -1, MNo = arr[0] }); } } else { sb.Clear(); } } } else { sb.Clear(); } } #endregion if (sb.Length > 1000) { sb = new StringBuilder(); } } Thread.Sleep(200); errCount = 0; } catch (Exception ex) { errCount++; if (errCount >= 3) { throw; } LogErr(ex); Thread.Sleep(1000 * 3); } } #endregion } catch (Exception ex) { LogErr(ex); // throw ex; } finally { try{stream.Close();} catch { } try { tcpClient.Close(); }catch { } IsRuning = false; if (Enabled) { IsRuning = true; ThreadPool.QueueUserWorkItem((o) => { _Start(); }); } LogInfo("退出工作线程:" + Thread.CurrentThread.ManagedThreadId); } } } private void LogErr(Exception ex) { //LogUtil.LogErr(new ElecScale_Log { Err = ex,Flag=IP,LogType="错误" }); if (!string.IsNullOrWhiteSpace(ex.Message)) { Console.WriteLine(ex.Message); } } private void LogInfo(string msg) { //LogUtil.LogInfo(new ElecScale_Log { Msg =msg,Flag=IP,LogType="消息" }); Console.WriteLine(msg); } public void Stop() { Enabled = false; } #region IDisposable Members /// <summary> /// Performs application-defined tasks associated with freeing, /// releasing, or resetting unmanaged resources. /// </summary> public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } /// <summary> /// Releases unmanaged and - optionally - managed resources /// </summary> /// <param name="disposing"><c>true</c> to release both managed /// and unmanaged resources; <c>false</c> /// to release only unmanaged resources. /// </param> protected virtual void Dispose(bool disposing) { if (!this.disposed) { if (disposing) { try { Stop(); } catch { } } disposed = true; } } #endregion #region Help Method /// <summary> /// 毫秒为单位 /// </summary> /// <param name="socket"></param> /// <param name="time"></param> /// <param name="interval"></param> private void SetKeepAlive(Socket socket, ulong time, ulong interval) { try { byte[] optionInValue = new byte[12]; ulong[] numArray = new ulong[3]; if (time == 0 || interval == 0) numArray[0] = 0; else numArray[0] = 1; numArray[1] = time; numArray[2] = interval; for (int i = 0; i < numArray.Length; i++) { optionInValue[i * 4 + 3] = (byte)(numArray[i] >> 0x18 & 0xff); optionInValue[i * 4 + 2] = (byte)(numArray[i] >> 0x10 & 0xff); optionInValue[i * 4 + 1] = (byte)(numArray[i] >> 8 & 0xff); optionInValue[i * 4] = (byte)(numArray[i] & 0xff); } byte[] bytes = BitConverter.GetBytes(0); socket.IOControl(IOControlCode.KeepAliveValues, optionInValue, bytes); } catch (Exception exception) { Console.WriteLine("设置KeepAlive错误：" + exception.Message); } } #endregion } #region Model /// <summary> /// 获取的有效桢信息 /// </summary> public class GatherDataInfo { public String GroupId { get; set; } public DateTime? AddTime { get; set; } /// <summary> /// 字节信息 /// </summary> public String RawStr { get; set; } /// <summary> /// 转化后的信息 /// </summary> public string StrValue { get; set; } /// <summary> /// 1,有效果 /// 0,无效 /// </summary> public int Status { get; set; } /// <summary> /// G:毛重,T=皮重,NET=净重 /// </summary> public String Legend { get; set; } } #endregion #region Log public class LogUtil { //public static void LogInfo(ElecScale_Log ent) //{ // if (!SimpleCfgMgr.GetV<bool>("LogInfo", false)) return; // Console.WriteLine(ent.Msg); // StackFrame sf = new StackFrame(1); // var methodInfo = sf.GetMethod(); // if (methodInfo.Name == "LogInfo") // { // methodInfo = new StackFrame(2).GetMethod(); // } // var fname = methodInfo.DeclaringType.FullName + "->" + methodInfo.Name; // Action act = () => // { // using (var ctx = DBCtx.GetCtx()) // { // try // { // var logEntry = new ElecScale_Log(); // logEntry.LogType = ent.LogType; // logEntry.AddTime = DateTime.Now; // logEntry.CodeSoure = fname; // logEntry.Msg = ent.Msg; // logEntry.Flag = ent.Flag; // ctx.ElecScale_Log.AddObject(logEntry); // ctx.SaveChanges(); // } // catch { } // } // }; // act.BeginInvoke(null, null); //} //public static void LogErr(ElecScale_Log ent) //{ // if (!SimpleCfgMgr.GetV<bool>("LogErr", false)) return; // Console.WriteLine(ent.Err.Message); // StackFrame sf = new StackFrame(1); // var methodInfo = sf.GetMethod(); // if (methodInfo.Name == "LogErr") // { // methodInfo = new StackFrame(2).GetMethod(); // } // var fname = methodInfo.DeclaringType.FullName + "->" + methodInfo.Name; // Action act = () => // { // using (var ctx = DBCtx.GetCtx()) // { // try // { // var logEntry = new ElecScale_Log(); // logEntry.LogType = "错误"; // logEntry.AddTime = DateTime.Now; // logEntry.CodeSoure = fname; // logEntry.Msg = ent.Err.ToString(); // logEntry.Flag = ent.Flag; // ctx.ElecScale_Log.AddObject(logEntry); // ctx.SaveChanges(); // } // catch { } // } // }; // act.BeginInvoke(null, null); //} } #endregion }
