IMEX.mes.plc/Curtain.Net.Sockets/PLC/Core/Session.cs


using System;
using System.Net;
using System.Net.Sockets;

namespace Curtain.Net.Sockets.PLC
{
    /// <summary>
    /// 服务端Session
    /// </summary>
    [Serializable]
    public class ServerSession
    {
        /// <summary>
        /// SessionID
        /// </summary>
        public string ID
        {
            get;
            private set;
        } = "S-" + Guid.NewGuid().ToString("N");

        [NonSerialized]
        private IPEndPoint _IPEndPoint = null;
        /// <summary>
        /// 此连接对象连接的远程客户端
        /// </summary>
        public IPEndPoint IPEndPoint
        {
            get
            {
                return _IPEndPoint;
            }
            internal set
            {
                _IPEndPoint = value;
            }
        }

        /// <summary>
        /// IP地址
        /// </summary>
        public IPAddress IPAddress
        {
            get
            {
                return _IPEndPoint?.Address;
            }
        }

        /// <summary>
        /// 服务端IP
        /// </summary>
        public string IP
        {
            get
            {
                return _IPEndPoint?.Address?.ToString();
            }
        }

        /// <summary>
        /// 服务端端口
        /// </summary>
        public int? Port
        {
            get
            {
                return _IPEndPoint?.Port;
            }
        }

        /// <summary>
        /// 挂起连接队列的最大长度
        /// </summary>
        public int Backlog
        {
            get;
            internal set;
        }

        [NonSerialized]
        private Socket _Socket = null;
        /// <summary>
        /// 传输数据的对象
        /// </summary>
        public Socket Socket
        {
            get
            {
                return _Socket;
            }
            internal set
            {
                _Socket = value;
            }
        }

        /// <summary>
        /// 清除Session
        /// </summary>
        public void Clear()
        {
            //IPAddress = null;
            Socket = null;
        }

        /// <summary>
        /// ToString
        /// </summary>
        /// <returns></returns>
        public override string ToString()
        {
            return $"[{_IPEndPoint}]:({ID})";
        }
    }

    /// <summary>
    /// 客户端Session
    /// </summary>
    [Serializable]
    public class ClientSession
    {
        /// <summary>
        /// SessionID
        /// </summary>
        public string ID
        {
            get;
            private set;
        } = "C-" + Guid.NewGuid().ToString("N");

        /// <summary>
        /// 服务端Session
        /// </summary>
        public ServerSession Server
        {
            get;
            internal set;
        }

        [NonSerialized]
        private Socket _socket = null;
        /// <summary>
        /// 传输数据的对象
        /// </summary>
        public Socket Socket
        {
            get
            {
                return _socket;
            }
            internal set
            {
                _socket = value;
            }
        }

        //internal SimpleHybirdLock HybirdLockSend
        //{
        //    get; set;
        //}

        [NonSerialized]
        private IPEndPoint _IPEndPoint = null;
        /// <summary>
        /// 此连接对象连接的远程客户端
        /// </summary>
        public IPEndPoint IPEndPoint
        {
            get
            {
                return _IPEndPoint;
            }
            internal set
            {
                _IPEndPoint = value;
            }
        }

        /// <summary>
        /// IP地址
        /// </summary>
        public IPAddress IPAddress
        {
            get
            {
                return _IPEndPoint?.Address;
            }
        }

        /// <summary>
        /// 客户端IP
        /// </summary>
        public string IP
        {
            get
            {
                return _IPEndPoint?.Address?.ToString();
            }
        }

        /// <summary>
        /// 客户端端口
        /// </summary>
        public int? Port
        {
            get
            {
                return _IPEndPoint?.Port;
            }
        }

        ///// <summary>
        ///// 远程对象的别名
        ///// </summary>
        //public string LoginAlias
        //{
        //    get; set;
        //}
        ///// <summary>
        ///// 心跳验证的时间点
        ///// </summary>
        //public DateTime HeartTime { get; set; } = DateTime.Now;
        ///// <summary>
        ///// 客户端的类型
        ///// </summary>
        //public string ClientType
        //{
        //    get; set;
        //}

        /// <summary>
        /// 清除Session
        /// </summary>
        public void Clear()
        {
            Server = null;
            Socket = null;
        }

        /// <summary>
        /// ToString
        /// </summary>
        /// <returns></returns>
        public override string ToString()
        {
            return $"[{_IPEndPoint}]:({ID})";
        }
    }

    /// <summary>
    /// 数据接收Session
    /// </summary>
    [Serializable]
    public class ReceiveSession
    {
        /// <summary>
        /// SessionID
        /// </summary>
        public string ID
        {
            get;
            private set;
        } = "R-" + Guid.NewGuid().ToString("N");

        /// <summary>
        /// 服务端Socket
        /// </summary>
        public SocketServer ServerSocket
        {
            get;
            internal set;
        }

        /// <summary>
        /// 客户端Session
        /// </summary>
        public ClientSession Client
        {
            get;
            internal set;
        }

        /// <summary>
        /// 响应报文-头
        /// </summary>
        public string Head
        {
            get;
            set;
        }

        /// <summary>
        /// 响应报文-文本
        /// </summary>
        public string Content
        {
            get;
            set;
        }

        /// <summary>
        /// 响应报文-头
        /// </summary>
        [NonSerialized]
        public byte[] HeadBytes;

        /// <summary>
        /// 响应报文-文本
        /// </summary>
        [NonSerialized]
        public byte[] ContentBytes;

        /// <summary>
        /// 报文命令
        /// </summary>
        public string Command
        {
            get;
            set;
        }

        /// <summary>
        /// 已接收数据长度
        /// </summary>
        public int Offset
        {
            get; set;
        }

        /// <summary>
        /// 总接收数据长度
        /// </summary>
        public int Size
        {
            get; set;
        }

        /// <summary>
        /// 清除Session
        /// </summary>
        public void Clear()
        {
        }

        /// <summary>
        /// 回复消息
        /// </summary>
        /// <param name="message"></param>
        public virtual void ReturnMessage(string message)
        {
            ServerSocket?.ReturnMessage(this, message);
        }

        /// <summary>
        /// ToString
        /// </summary>
        /// <returns></returns>
        public override string ToString()
        {
            return $"Command[{Command}]:Head[{Head}]:Content[{Content}]:Client[{Client}]";
        }
    }
}