lanying56123 发表于 2018-9-20 13:26:39

GPS服务端(上)

  从第一次写GPS的服务端到现在,已经过去了八年时光。一直是用.net修修改改,从自己写的socket服务,到suppersocket,都是勉强在坚持着,没有真正的稳定过。
  最近一段时间,服务端又出了两个问题:
  1、UDP服务:System.Net.Sockets.SocketException (0x80004005): 当该操作在进行中,由于保持活动的操作检测到一个故障,该连接中断。

  2、数据库操作:System.Data.SqlClient.SqlException (0x80131904): 事务(进程>  第一点估计真的是.net socket框架的问题,尝试过网上搜索的解决方案都没有解决,同样的程序在另外一台服务器正常,唯独其中一台隔三差五的就出现这个问题 。以下是服务端部分代码:
  

    ///   
         /// 初始化监听
  
         ///
  
         private void InitServer()
  
         {
  
             server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  
             uint IOC_IN = 0x80000000;
  
             uint IOC_VENDOR = 0x18000000;
  
             uint SIO_UDP_CONNRESET = IOC_IN | IOC_VENDOR | 12;
  
             server.IOControl((int)SIO_UDP_CONNRESET, new Byte[] { Convert.ToByte(false) }, null);//不知道这句有没有用。
  
             string hostName = Dns.GetHostName();   //获取本机名
  
             IPHostEntry localhost = Dns.GetHostEntry(hostName);
  
             IPAddress[] ips = localhost.AddressList;
  
             IPAddress localaddr = null;
  
             foreach (IPAddress ip in ips)
  
             {
  
               if (ip.IsIPv6LinkLocal || ip.IsIPv6Teredo)
  
               {
  
                     continue;
  
               }
  
               localaddr = ip;
  
             }
  

  
             state = new State(server);
  
             server.Bind(new IPEndPoint(localaddr, _config.Port));
  
             server.BeginReceiveFrom(state.Buffer, 0, state.Buffer.Length, SocketFlags.None, ref state.RemoteEP, new AsyncCallback(ReceiveCallBack), state);
  
         }
  

  

   private void ReceiveCallBack(IAsyncResult ar)  

{  

try  
             {
  
               State _state = ar.AsyncState as State;

  
               int>  
               if (size > 0)
  
               {
  
                     byte[] data = new byte;

  
                     Array.Copy(_state.Buffer, 0, data, 0,>  
                     var session = AddClient(_state.RemoteEP, data);
  
                     if (session != null)
  
                     {
  
                         _state.Session = session;
  
                     }
  
                     OnReceived?.Invoke(_state.Session, data);
  
                     server.BeginReceiveFrom(_state.Buffer, 0, _state.Buffer.Length, 0, ref _state.RemoteEP, new AsyncCallback(ReceiveCallBack), _state);
  
               }
  
               else
  
               {
  
                     LogHelper.Error("size
页: [1]
查看完整版本: GPS服务端(上)