一个封锁操作被对 WSACancelBlockingCall 的调用中断 about beetlex HOT 6 CLOSED

    private bool TaskIsRunning = true;
    static TCPCamera instance;
    public Action<string> ReceiveTCP;
    public Action<bool> TCPConnectStatus;
    public bool IsConnect = false;
    public static TCPCamera GetInstance()
    {
        if (instance == null)
        {
            instance = new TCPCamera();
        }
        return instance;
    }

    public void Connect()
    {
        Task.Run( () =>
        {
            RunClient();
        });
    }

    private  void RunClient()
    {
        string ClassName = System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name;
        string FuncName = System.Reflection.MethodBase.GetCurrentMethod().Name;
        string msg = "";

        string strmsg1 = $"0 { util.GetNow()} connectCamera ";
        App.Log.Info(strmsg1);

        string IP = Config.GetInstance().getConfig("CameraIP");
        int Port = Convert.ToInt32(Config.GetInstance().getConfig("CameraPort"));

        if (client == null)
        {
            client = SocketFactory.CreateClient<TcpClient>(IP, Port);
            client.TimeOut = 300000;
            client.Encoding = Encoding.GetEncoding(936);
        }

        while (TaskIsRunning)
        {
            try
            {                    
                var read = client.Receive();
                var str = read.ReadToEnd();

                msg = @$"
                            Class Name [{ClassName}]
                            Function   [{FuncName}]
                            RecvTime   [{util.GetNow()}]
                            Parameter
                            Message 接收Vision命令   [{str}]";
                App.Log.Info(msg);

                ReceiveTCP(str);
                TCPConnectStatus(client.IsConnected);
            }
            catch (Exception e)
            {
                TCPConnectStatus(false);
                msg = @$"
                            Class Name [{ClassName}]
                            Function   [{FuncName}]
                            RecvTime   [{util.GetNow()}]
                            Parameter
                            Message RunClient 视觉网络异常  : {e.Message}  HResult: {e.HResult} 
                         ";
                App.Log.Error(msg);
            }
        }
    }

    public void Send(string cmd)
    {
        try
        {
            TCPConnectStatus(client.IsConnected);
            if (client.IsConnected)
            {
                client.Stream.ToPipeStream().Write(cmd+"\r\n");
                client.Stream.Flush();

                string ClassName = System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name;
                string FuncName = System.Reflection.MethodBase.GetCurrentMethod().Name;
                string msg = @$"
                                Class Name [{ClassName}]
                                Function   [{FuncName}]
                                RecvTime   [{util.GetNow()}]
                                Parameter
                                Message 发送命令到视觉  [{cmd}]";
                App.Log.Info(msg);
            }
            else
            {
                string ClassName = System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name;
                string FuncName = System.Reflection.MethodBase.GetCurrentMethod().Name;
                string msg = @$"
                                Class Name [{ClassName}]
                                Function   [{FuncName}]
                                RecvTime   [{util.GetNow()}]
                                Parameter
                                Message  视觉网络未连接,命令发送失败  [{cmd}]
                                ";
                App.Log.Warn(msg);
            }
        }
        catch (Exception ex)
        {
            string ClassName = System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name;
            string FuncName = System.Reflection.MethodBase.GetCurrentMethod().Name;
            string msg = @$"
                                Class Name [{ClassName}]
                                Function   [{FuncName}]
                                RecvTime   [{util.GetNow()}]
                                Parameter
                                Message  视觉通讯出现异常  [{ex.Message}]";          
            App.Log.Error(msg);
        }
    }

    public void Dispose()
    {
        TaskIsRunning = false;
        client.DisConnect();
        client.Dispose();
        client = null;
    }
}