20230201_145_upperpc/InSituLaboratory/Common/Client.cs

using System.Net.Sockets;
using System.Net;
using static InSituLaboratory.Common.Sockets;

namespace InSituLaboratory.Common
{
    /// <summary>
    /// 客户端通信类
    /// </summary>
    public class Client : SocketObject
    {
        public PushSockets pushSockets;

        bool IsClose = false;
        /// <summary>
        /// 当前管理对象
        /// </summary>
        Sockets sk;
        /// <summary>
        /// 客户端
        /// </summary>
        TcpClient client;
        /// <summary>
        /// 当前连接服务端地址
        /// </summary>
        IPAddress Ipaddress;
        /// <summary>
        /// 当前连接服务端端口号
        /// </summary>
        int Port;
        /// <summary>
        /// 服务端IP+端口
        /// </summary>
        IPEndPoint ip;
        /// <summary>
        /// 发送与接收使用的流
        /// </summary>
        NetworkStream nStream;

        /// <summary>
        /// 初始化Socket
        /// </summary>
        /// <param name="ipaddress"></param>
        /// <param name="port"></param>
        public override void InitSocket(IPAddress ipaddress, int port)
        {
            Ipaddress = ipaddress;
            Port = port;
            ip = new IPEndPoint(Ipaddress, Port);
            client = new TcpClient();
        }
        /// <summary>
        /// 初始化Socket
        /// </summary>
        /// <param name="ipaddress">ipd地址</param>
        /// <param name="port">端口</param>
        public override void InitSocket(string ipaddress, int port)
        {
            Ipaddress = IPAddress.Parse(ipaddress);
            Port = port;
            ip = new IPEndPoint(Ipaddress, Port);
            client = new TcpClient();
        }
        /// <summary>
        /// 重写Start方法,其实就是连接服务端
        /// </summary>
        public override void Start()
        {
            Connect();
        }
        /// <summary>
        /// 连接
        /// </summary>
        public bool Connect()
        {
            try
            {
                client.Connect(ip);
            }
            catch (Exception)
            {
                return false;
            }
            nStream = new NetworkStream(client.Client, true);
            sk = new Sockets(ip, client, nStream);
            sk.nStream.BeginRead(sk.RecBuffer, 0, sk.RecBuffer.Length, new AsyncCallback(EndReader), sk);
            return true;
        }
        /// <summary>
        /// 读取
        /// </summary>
        private void EndReader(IAsyncResult ir)
        {
            Sockets s = ir.AsyncState as Sockets;
            try
            {
                if (s != null)
                {
                    if (IsClose && client == null)
                    {
                        sk.nStream.Close();
                        sk.nStream.Dispose();
                        return;
                    }
                    s.Offset = s.nStream.EndRead(ir);
                    if (pushSockets != null)
                        pushSockets.Invoke(s);//推送至UI
                    sk.nStream.BeginRead(sk.RecBuffer, 0, sk.RecBuffer.Length, new AsyncCallback(EndReader), sk);
                }
            }
            catch (Exception skex)
            {
                Sockets sks = s;
                sks.ex = skex;
                sks.ClientDispose = true;
                if (pushSockets != null)
                    pushSockets.Invoke(sks);//推送至UI
            }
        }
        /// <summary>
        /// 停止
        /// </summary>
        public override void Stop()
        {
            Sockets sks = new Sockets();
            try
            {
                if (client != null)
                {
                    client.Client.Shutdown(SocketShutdown.Both);
                    Thread.Sleep(10);
                    client.Close();
                    IsClose = true;
                    client = null;
                }
                else
                {
                    sks.ex = new Exception("客户端没有初始化.!");
                }
                if (pushSockets != null)
                    pushSockets.Invoke(sks);//推送至UI
            }
            catch (Exception ex)
            {
                sks.ex = ex;
            }
        }
        /// <summary>
        /// 发送消息
        /// </summary>
        public void SendData(byte[] SendData)
        {
            try
            {
                if (client == null || !client.Connected)
                {
                    Sockets sks = new Sockets();
                    sks.ex = new Exception("客户端无连接..");
                    sks.ClientDispose = true;
                    if (pushSockets != null)
                        pushSockets.Invoke(sks);//推送至UI 
                }
                if (client.Connected) //如果连接则发送
                {
                    if (nStream == null)
                    {
                        nStream = client.GetStream();
                    }
                    nStream.Write(SendData, 0, SendData.Length);
                }
            }
            catch (Exception skex)
            {
                Sockets sks = new Sockets();
                sks.ex = skex;
                sks.ClientDispose = true;
                if (pushSockets != null)
                    pushSockets.Invoke(sks);//推送至UI
            }
        }

        public bool Is_Connected()
        {
            return client.Connected;
        }

        public bool IsOnline()
        {
            if (client == null)
                return false;
            return !(client.Client.Poll(1000, SelectMode.SelectRead) && client.Client.Available == 0 || !client.Client.Connected);
        }
    }
}