论坛 › .Net › 建立TCP服务端

张国伟 发表于 2022-9-17 08:36:03

建立TCP服务端

利用Socket建立TCP服务端。
项目要求：建立一个TCP服务端，接收机器人发送过来的实时数据。机器人会一直尝试连接一个IP地址端口号，连接上之后就会将数据报文发送过来。服务端要根据报文格式对数据进行解析。当发送过来的数据报文不符合格式的时候，断开Socket连接。
主要代码：
      public Robot_Method(Robot_Device _Device)
      {
            Device = _Device;
      }
      private Robot_Device Device;//设备实体类
      private Socket Socket = null;//服务端Socket。
      private Socket ClientSocket = null;//客户端Socket
      Thread th;//接收数据线程
      //接收数据事件
      public Action<string> recvMessageEvent = null;
      
      public void Connect()
      {
            Socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPAddress Localhost = IPAddress.Any;
            int LocalPort = Device.Device_Port;
            IPEndPoint endPoint = new IPEndPoint(Localhost, LocalPort);//服务端需要开启的网络终结点。客户端链接这个IP地址和端口号。
            Socket.Bind(endPoint);//绑定网络终结点
            Socket.Listen(1);
            Thread th = new Thread(ListenClientConnect);//开启线程来等待客户端连接。
            th.IsBackground = true;
            th.Start();
      }
      public void DisConnect()
      {
            Socket.Close();//关闭服务端
      }

      public void ListenClientConnect()
      {
            while (true)
            {
                ClientSocket = Socket.Accept();//等待客户端连接。
                th?.Abort();//如果接收数据线程不为空，则终止它。
                th = new Thread(ReceiveMessage);//开启接收数据线程。
                th.IsBackground = true;
                th.Start();
            }
      }

      public void ReceiveMessage()
      {
            while (true)
            {
                string ErrorMessage = "";
                try
                {
                  byte[] vs = new byte;
                  int lenght = ClientSocket.Receive(vs);
                  if (lenght == 177)
                  {
                        if (vs != 0xFE && vs != 0x5A && vs != 0xA5)
                        {
                            ErrorMessage = "报文头错误";
                            recvMessageEvent?.Invoke(ErrorMessage);
                            ClientSocket.Close();
                            break;
                        }
                        else
                        {
                            Device.Device_State = true;
                            GetResult(vs);//处理接收的报文数据
                            ErrorMessage = "";//当ErrorMessage为""时，表示接收数据报文成功，且解析成功。通过事件通知数据已经处理完成。
                            recvMessageEvent?.Invoke(ErrorMessage);
                        }
                  }
                  else
                  {
                        Device.Device_State = false;
                        ErrorMessage = "收到的长度不是规定的报文长度：177";
                        recvMessageEvent?.Invoke(ErrorMessage);
                        ClientSocket.Close();
                        break;
                  }
                }
                catch (Exception ex)
                {
                  Device.Device_State = false;
                  ErrorMessage = ex.Message;
                  recvMessageEvent?.Invoke(ErrorMessage);
                  ClientSocket.Close();
                  break;
                }
            }
      } 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

查看完整版本: 建立TCP服务端