using System.Net;// DNS_靜態(tài)對(duì)象
using System.Net.Sockets;
 
// 字段位置
private Socket socket業(yè)務(wù);  //對(duì)象既可以當(dāng)服務(wù)器，又可以當(dāng)客戶端
TcpListener tcpListener;   //服務(wù)器對(duì)象
TcpClient tcpClient;       //客戶端對(duì)象

tcpClient客戶端 = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

 #region 連接
 
        /// <summary>
        /// 建立連接
        /// </summary>
        /// <param name="ip">IP地址</param>
        /// <param name="port">端口號(hào)</param>
        public void Connect(string ip, string port)
        {
            try
            {
                //實(shí)例化Socket
                tcpClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 
                //設(shè)置Socket屬性
                tcpClient.SendTimeout = this.SendTimeOut;
 
                tcpClient.ReceiveTimeout = this.ReceiveTimeOut;
 
                //封裝一個(gè)EndPoint對(duì)象
                IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(ip), int.Parse(port));
 
                //建立連接
                tcpClient.Connect(endPoint);
            }
            catch (Exception ex) { MessageBox.Show(ex.Message); }//顯示錯(cuò)誤
        }
 
        #endregion

  #region 讀取并接受
 
        /// <summary>
        /// 發(fā)送并接受
        /// </summary>
        /// <param name="SendByte"></param>
        /// <returns></returns>
        public byte[] SendAndReceive(byte[] SendByte)
        {
            try
            {
                if (tcpClient.Available >= 1)//   丟棄字節(jié)
                {
                    #region 加載
                    byte[] buffer = new byte[tcpClient.Available];//準(zhǔn)備加載
                    tcpClient.Receive(buffer, buffer.Length, SocketFlags.None);//開(kāi)始加載
                    #endregion
                }
                #region 計(jì)時(shí)
                //====現(xiàn)在時(shí)間======================================
                str_發(fā)送后記時(shí) = new StringBuilder(String.Format("{0,9}",
                    DateTime.Now.Second.ToString() + "s"
                    + DateTime.Now.Millisecond.ToString() + "ms:"));  //固定長(zhǎng)度9 右對(duì)齊
                #endregion
                tcpClient.Send(SendByte);// 發(fā)送
               
                #region 委托
                if (Help_ModBus.Wt_set != null)
                {
                    Help_ModBus.Wt_set(SendByte, str_發(fā)送后記時(shí).ToString());
                }
                #endregion
 
                return ReadMessage();
            }
            catch (Exception ex) { MessageBox.Show(ex.Message); }//顯示錯(cuò)誤
            finally
            {
                //InteractiveLock.Leave();
            }
            return null;
        }
 
 
        /// <summary>
        /// 讀取緩沖區(qū)值
        /// </summary>
        /// <returns></returns>
        private byte[] ReadMessage()
        {
            DateTime startTime = DateTime.Now;//記錄開(kāi)始時(shí)間
            do
            {
                if (tcpClient.Available >= 5 )//   字節(jié)
                {
                    #region 計(jì)時(shí)
                    //====現(xiàn)在時(shí)間======================================
                    str_發(fā)送后記時(shí) = new StringBuilder(String.Format("{0,9}",
                        DateTime.Now.Second.ToString() + "s"
                        + DateTime.Now.Millisecond.ToString() + "ms:"));  //固定長(zhǎng)度9 右對(duì)齊
                    #endregion
                    #region 加載
                    byte[] buffer = new byte[tcpClient.Available];//準(zhǔn)備加載
                    tcpClient.Receive(buffer, buffer.Length, SocketFlags.None);//開(kāi)始加載
                    #endregion
                    #region 委托
                    if (Help_ModBus.Wt_get != null)//委托呼叫ui
                    {
                        Help_ModBus.Wt_get(buffer, str_發(fā)送后記時(shí).ToString());// ui顯示
                    }
                    #endregion
                    return buffer;
                }
                #region 超時(shí)跳出
                if ((DateTime.Now - startTime).TotalMilliseconds > ReceiveTimeOut+500)// 超時(shí) 1.5s
                {
                    break;// 已經(jīng)超時(shí)
                }
                #endregion
 
            } while (true);
            return null; // 相當(dāng)失敗
 
 
 
            //Thread.Sleep(ReceiveTimeOut);// 延時(shí)15ms
            //int count = tcpClient.Available;  //  字節(jié)
            //if (count == 0)
            //{
            //    return null;
            //}
            //else
            //{
            //    byte[] buffer = new byte[count];
            //    tcpClient.Receive(buffer, count, SocketFlags.None);
            //    //byte[] buffer2 = Encoding.Default.GetBytes(str_發(fā)送后記時(shí).ToString());
            //    byte[] buffer3 = { buffer2 , buffer };
            //    //return buffer2;
            //    #region 計(jì)時(shí)
            //    //====現(xiàn)在時(shí)間======================================
            //    str_發(fā)送后記時(shí) = new StringBuilder(String.Format("{0,9}",
            //        DateTime.Now.Second.ToString() + "s"
            //        + DateTime.Now.Millisecond.ToString() + "ms:"));  //固定長(zhǎng)度9 右對(duì)齊
            //    #endregion
            //    if (Wt_get!=null)
            //    {
            //        Wt_get(buffer, str_發(fā)送后記時(shí).ToString());
            //    }
            //    return buffer;
            //}
 
            //==================================
            //int count = tcpClient.Available;
            //int cycletimer = 0;
            //while (count == 0)
            //{
            //    count = tcpClient.Available;
            //    cycletimer++;
            //    Thread.Sleep(20);
            //    if (cycletimer > MaxCycleTimer)
            //    {
            //        break;
            //    }
            //}
            //if (count == 0)
            //{
            //    return null;
            //}
            //else
            //{
            //    byte[] buffer = new byte[count];
            //    tcpClient.Receive(buffer, count, SocketFlags.None);
            //    return buffer;
            //}
        }
        #endregion

 #region 斷開(kāi)
        /// <summary>
        /// 斷開(kāi)連接
        /// </summary>
        public void DisConnect()
        {
            if (tcpClient != null)
            {
                tcpClient.Close();
            }
        }
 
        #endregion