ZLPlugin_MR/SocketClient.cs

using System;
using System.Net.Sockets;
using System.Net;
using System.Text;
using System.Threading;
using System.Security;

namespace ZLPlugin_MR.Domain.Units
{
    /// <summary>
    /// socket客户端
    /// </summary>
    public class SocketClient
    {
        public static string Message = null;//接收消息
        /// <summary>
        /// 客户端socket
        /// </summary>
        public Socket _ClientSocket = null;
        /// <summary>
        /// IP地址
        /// </summary>
        public string ipAddress = string.Empty;
        /// <summary>
        /// IP端口
        /// </summary>
        public int Port;
        /// <summary>
        /// 接收线程
        /// </summary>
        private Thread threadReceive;
        /// <summary>
        /// 是否运行
        /// </summary>
        private bool IsRun = false;
        /// <summary>
        /// 远端地址
        /// </summary>
        private string remoteEndPoint;
        /// <summary>
        /// 本端地址
        /// </summary>
        private string LocalEndPoint;
        /// <summary>
        /// 客户端
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="Port"></param>
        public SocketClient(string ip, int Port)
        {
            _ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            _ClientSocket.ReceiveTimeout = 2000;
            this.ipAddress = ip;
            this.Port = Port;
            Start();
        }
        /// <summary>
        /// 启动连接服务端
        /// </summary>
        public void Start()
        {
            try
            {
                _ClientSocket.Connect(new IPEndPoint(IPAddress.Parse(this.ipAddress), this.Port));//通过IP和端口号来定位一个所要连接的服务器端
                                                                                                  //客户端网络结点号  
                remoteEndPoint = _ClientSocket.RemoteEndPoint.ToString();
                LocalEndPoint = _ClientSocket.LocalEndPoint.ToString();
                Log.Info($"远端地址:{remoteEndPoint} 本端地址：{LocalEndPoint}");
                /* threadReceive = new Thread(Receive);
                 threadReceive.IsBackground = true;
                 threadReceive.Start();*/
                IsRun = true;
            }
            catch (Exception ex)
            {
                Log.Info("平台插件未运行！请启动插件。", true);
                Log.Info(ex.Message, true);
                Log.Info(ex.StackTrace, true);
            }

        }

        // <summary>
        /// 循环接收消息  直到有数据
        /// </summary>
        public void WhileReceive(int waittingdate)
        {
            byte[] buffer = new byte[1024 * 100];
            int receivedBytes = 0;
            var begintime = DateTime.Now.Ticks;
            TimeSpan timeSpan = new TimeSpan();
            bool flag = true;
            Log.Info("WhileReceive 开始接收消息》》");
            while (flag)
            {
                Log.Info("flag=" + flag);
                // 只循环 20 秒  
                timeSpan = new TimeSpan(DateTime.Now.Ticks - begintime);
                Log.Info("timeSpan=" + timeSpan);
                if (timeSpan.TotalSeconds > waittingdate)
                {

                    flag = false;
                    Log.Info("flag=" + flag);
                }

                while (flag)
                {
                    try
                    {
                        //传递一个byte数组，用于接收数据。length表示接收了多少字节的数据
                        receivedBytes = _ClientSocket.Receive(buffer);
                    }
                    catch (ArgumentNullException e)
                    {
                        Log.Info("获取数据超时 ArgumentNullException " + e.Message);
                        break;
                    }
                    catch (SocketException e)
                    {
                        Log.Info("获取数据超时 SocketException" + e.Message);
                        break;
                    }
                    catch (ObjectDisposedException e)
                    {
                        Log.Info("获取数据超时 ObjectDisposedException" + e.Message);
                        break;
                    }
                    catch (SecurityException e)
                    {
                        Log.Info("获取数据超时 SecurityException" + e.Message);
                        break;
                    }
                }
                Log.Info("receivedBytes " + receivedBytes);
                if (receivedBytes > 0)
                {
                    Message = Encoding.Default.GetString(buffer, 0, receivedBytes);//只将接收到的数据进行转化
                    Log.Info("WhileReceive 返回消息》》" + Message);
                    break;
                }
            }
        }

        /// <summary>
        /// 接收服务端发送过来的消息
        /// </summary>
        public void Receive()
        {
            //string message = "";
            try
            {
                byte[] TempData = new byte[1024 * 1000];
                while (IsRun)
                {
                    //传递一个byte数组，用于接收数据。length表示接收了多少字节的数据
                    int length = _ClientSocket.Receive(TempData);
                    if (length == 0)
                    {
                        IsRun = false;
                        //Console.WriteLine("服务器断开链接");
                        break;
                    }
                    else
                    {
                        Message = Encoding.Default.GetString(TempData, 0, length);//只将接收到的数据进行转化
                        //Console.WriteLine($"远端地址:{remoteEndPoint} 本端地址：{LocalEndPoint} 获取到的数据:{message}");
                        //Log.Info("出参：" + Message);
                    }
                }
            }
            catch (Exception ex)
            {
                //Log.Info("95478");
                Log.Info(ex.Message);
                //Log.Info(ex.StackTrace, true);
            }


        }
        /// <summary>
        /// 发送消息到服务端
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        public int Send(string data)
        {
            Message = null;
            return _ClientSocket.Send(Encoding.Default.GetBytes(data));
        }
        public void Close()
        {
            IsRun = false;

            if (threadReceive != null)
            {
                try
                {
                    threadReceive.Interrupt();
                    Thread.Sleep(200);
                }
                catch (Exception ex)
                {
                    Log.Info(ex.Message, true);
                    Log.Info(ex.StackTrace, true);
                }
                threadReceive = null;
            }
            if (_ClientSocket != null)
            {
                _ClientSocket.Close();
            }
        }

    }
}