20240301_JSEQ_upperpc/JiangsuEarthquakeJM/JiangsuEarthquake/Common/Client.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using static JiangsuEarthquake.Common.Sockets;

namespace JiangsuEarthquake.Common
{
    public class Client : SocketObject
    {
        public PushSockets pushSockets;


        /// <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 bool Start()
        {
            return Connect();
        }


        /// <summary>
        /// 连接
        /// </summary>
        public bool Connect()
        {
            try
            {
                client.Connect(ip);
                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);
            }
            catch (Exception)
            {
                return false;
            }
            return true;
        }


        /// <summary>
        /// 读取
        /// </summary>
        private void EndReader(IAsyncResult ir)
        {
            Sockets s = ir.AsyncState as Sockets;
            try
            {
                if (s != null)
                {
                    if (client == null)
                    {
                        sk.nStream.Close();
                        sk.nStream.Dispose();
                        return;
                    }
                    s.Offset = s.nStream.EndRead(ir);
                    if (pushSockets != null)
                        pushSockets.Invoke(s);//推送至UI

                    if (IsOnline())
                    {
                        //Thread.Sleep(100);
                        sk.nStream.BeginRead(sk.RecBuffer, 0, sk.RecBuffer.Length, new AsyncCallback(EndReader), sk);
                    }
                    else
                    {
                        if (Ipaddress.ToString().Equals(Tools.GetAppSetting("SYZ_Client_IP1")))
                        {
                            //Tools.Logging("站点1目前系统由于卫通/下位机原因链接断开，IP:" + Ipaddress + "端口号:" + Port);
                        }
                        else if (Ipaddress.ToString().Equals(Tools.GetAppSetting("SYZ_Client_IP2")))
                        {
                            //Tools.Logging("站点2目前系统由于卫通/下位机原因链接断开，IP:" + Ipaddress + "端口号:" + Port);
                        }
                    }
                }
            }
            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();
                    client = null;
                }
                else
                {
                    sks.ex = new Exception("客户端没有初始化.!");
                }
                if (pushSockets != null)
                    pushSockets.Invoke(sks);//推送至UI
            }
            catch (Exception ex)
            {
                sks.ex = ex;
            }
        }


        /// <summary>
        /// 发送消息
        /// </summary>
        public bool 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 != null && client.Connected) //如果连接则发送
                {
                    if (nStream == null)
                    {
                        nStream = client.GetStream();
                    }
                    nStream.Write(SendData, 0, SendData.Length);

                    return true;
                }

                return false;
            }
            catch (Exception skex)
            {
                Sockets sks = new Sockets();
                sks.ex = skex;
                sks.ClientDispose = true;
                if (pushSockets != null)
                    pushSockets.Invoke(sks);//推送至UI

                return false;
            }
        }

        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);
        }
    }
}