Socket .net MVC 的配置 包括异常断开

解决问题: 1. Socket 的异常断开 

　　　　　2. 部署在IIS程序池上的程序回收导致 端口占用,对象资源却已经释放的BUG

　　　　

SocketHelper 类   inOptionValues .net框架中用于检测连接的客户端 检测时间(默认2小时)   或者自己写个心跳包(客户端和服务端用规定协议)   

        #region 变量

        //服务器监听socket 
        public static Socket listener = null;

        /// <summary>
        /// 连接列表
        /// </summary>
        public static List<Socket> socketList = new List<Socket>();

        public static Thread listenClientThread = null;

        private static byte[] inOptionValues = null;

        #endregion



        #region 开启监听 (接收数据)

        /// <summary>
        /// 开启监听
        /// </summary>
        public static void StartListening()
        {
            uint dummy = 0;
            inOptionValues = new byte[Marshal.SizeOf(dummy) * 3];
            BitConverter.GetBytes((uint)1).CopyTo(inOptionValues, 0); //是否启用Keep-Alive
            BitConverter.GetBytes((uint)30000).CopyTo(inOptionValues, Marshal.SizeOf(dummy)); //检测客户端时间周期
            BitConverter.GetBytes((uint)2000).CopyTo(inOptionValues, Marshal.SizeOf(dummy) * 2); //失败后连续探测时间

            byte[] bytes = new Byte[1024];
            //首先是构造一个socket对象
            IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
            IPAddress ip = null;
            foreach (var item in ipHostInfo.AddressList)
            {
                if (item.AddressFamily == AddressFamily.InterNetwork)
                {
                    ip = item;
                    break;
                }
            }
            IPAddress ipAddress = ipHostInfo.AddressList[0];
            //System.Web.HttpContext.Current.A
            IPEndPoint localEndPoint = new IPEndPoint(ip, int.Parse(System.Configuration.ConfigurationManager.AppSettings["Port"]));
            listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                listener.Bind(localEndPoint);
                listener.Listen(100);//开始监听

                while (true)
                {
                    // 接收请求连接，handler接收该连接，之后使用handler处理收发数据的问题
                    Socket handler = listener.Accept();
                    handler.IOControl(IOControlCode.KeepAliveValues, inOptionValues, null);

                    IPEndPoint clientipe = (IPEndPoint)handler.RemoteEndPoint;
                    //SetServerLog("*******" + handler.RemoteEndPoint + "已连接服务器,正在监听!********");
                    //SetConnectList(handler.RemoteEndPoint.ToString(), true);

                    Thread nowThread = new Thread(new ParameterizedThreadStart(ReceiveClientData));
                    nowThread.IsBackground = true;
                    nowThread.Name = handler.RemoteEndPoint.ToString();

                    Socket sk = new Socket();

                    //加入socket列表
                    socketList.Add(sk);

                    nowThread.Start(handler);
                }
            }
            catch (Exception e)
            {
                //释放资源  IIS回收  正常断开的异常
                if (e.Message != "一个封锁操作被对 WSACancelBlockingCall 的调用中断。")
                    throw e;
                else
                    throw e;
            }
        }

        //public delegate void CallBack();

        // 接受 客户端的信息
        private static void ReceiveClientData(object client)
        {
            Socket nowClient = (Socket)client;
            while (true)
            {
                try
                {
                    int res = 0;
                    byte[] bytes = new byte[1024];
                    // 不断的接受客户端发来的信息， 当客户端离线后，退出。
                    res = nowClient.Receive(bytes);

                    if (res <= 0)
                    {
                        throw new SocketException();
                    }

                    string str = Encoding.UTF8.GetString(bytes, 0, res);

                    //绑定ID  业务逻辑 
                    if (str.IndexOf("****:****") >= 0)
                    {
                        foreach (var item in socketList)
                        {
                            if (item.RemoteEndPoint == nowClient.RemoteEndPoint)
                            {
                                SendMsg(item.RemoteEndPoint,"SET:(1,2,3)");
                                break;
                            }
                        }
                    }
                }
                catch (SocketException se)
                {
                    socketList = (from si in socketList where si.RemoteEndPoint != nowClient.RemoteEndPoint select si).ToList();
                    nowClient.Close();
                    break;
                }
                catch (Exception ee)
                {
                    throw ee;
                }
            }
        }

        #endregion

        #region 发送数据

        /// <summary>
        /// 发送数据给客户端
        /// </summary>
        /// <param name="ep">ip和Port</param>
        /// <param name="msg">发送的消息</param>
        public static void SendMsg(EndPoint ep, string msg)
        {
            try
            {
                foreach (var item in socketList)
                {
                    if (item.listener.RemoteEndPoint == ep)
                    {
                        byte[] data = Encoding.UTF8.GetBytes(msg);
                        item.listener.Send(data);
                        break;
                    }
                }
            }
            catch (Exception ee)
            {
                throw ee;
            }
        }


        #endregion

Global 里设置    Application_End 函数中 释放资源

        protected void Application_Start()
        {

            if (SocketHelper.listenClientThread == null)
            {
                SocketHelper.listenClientThread = new Thread(new ThreadStart(SocketHelper.StartListening));
                SocketHelper.listenClientThread.IsBackground = true;
                SocketHelper.listenClientThread.Start();
            }

            AreaRegistration.RegisterAllAreas();
            RegisterGlobalFilters(GlobalFilters.Filters);
            RegisterRoutes(RouteTable.Routes);
        }

        protected void Application_End()
        {
            SocketHelper.listener.Close();
            SocketHelper.listener.Dispose();
            SocketHelper.listenClientThread = null;
        }

欢迎提出问题 谢谢~~