建立TCP服务端

利用Socket建立TCP服务端。
项目要求：建立一个TCP服务端，接收机器人发送过来的实时数据。机器人会一直尝试连接一个IP地址端口号，连接上之后就会将数据报文发送过来。服务端要根据报文格式对数据进行解析。当发送过来的数据报文不符合格式的时候，断开Socket连接。
主要代码：

1.         public Robot_Method(Robot_Device _Device)
2.         {
3.             Device = _Device;
4.         }
5.         private Robot_Device Device;//设备实体类
6.         private Socket Socket = null;//服务端Socket。
7.         private Socket ClientSocket = null;//客户端Socket
8.         Thread th;//接收数据线程
9.         //接收数据事件
10.         public Action<string> recvMessageEvent = null;
11.       
12.         public void Connect()
13.         {
14.             Socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
15.             IPAddress Localhost = IPAddress.Any;
16.             int LocalPort = Device.Device_Port;
17.             IPEndPoint endPoint = new IPEndPoint(Localhost, LocalPort);//服务端需要开启的网络终结点。客户端链接这个IP地址和端口号。
18.             Socket.Bind(endPoint);//绑定网络终结点
19.             Socket.Listen(1);
20.             Thread th = new Thread(ListenClientConnect);//开启线程来等待客户端连接。
21.             th.IsBackground = true;
22.             th.Start();
23.         }
24.         public void DisConnect()
25.         {
26.             Socket.Close();//关闭服务端
27.         }
29.         public void ListenClientConnect()
30.         {
31.             while (true)
32.             {
33.                 ClientSocket = Socket.Accept();//等待客户端连接。
34.                 th?.Abort();//如果接收数据线程不为空，则终止它。
35.                 th = new Thread(ReceiveMessage);//开启接收数据线程。
36.                 th.IsBackground = true;
37.                 th.Start();
38.             }
39.         }
41.         public void ReceiveMessage()
42.         {
43.             while (true)
44.             {
45.                 string ErrorMessage = "";
46.                 try
47.                 {
48.                     byte[] vs = new byte[1024];
49.                     int lenght = ClientSocket.Receive(vs);
50.                     if (lenght == 177)
51.                     {
52.                         if (vs[0] != 0xFE && vs[1] != 0x5A && vs[2] != 0xA5)
53.                         {
54.                             ErrorMessage = "报文头错误";
55.                             recvMessageEvent?.Invoke(ErrorMessage);
56.                             ClientSocket.Close();
57.                             break;
58.                         }
59.                         else
60.                         {
61.                             Device.Device_State = true;
62.                             GetResult(vs);//处理接收的报文数据
63.                             ErrorMessage = "";//当ErrorMessage为""时，表示接收数据报文成功，且解析成功。通过事件通知数据已经处理完成。
64.                             recvMessageEvent?.Invoke(ErrorMessage);
65.                         }
66.                     }
67.                     else
68.                     {
69.                         Device.Device_State = false;
70.                         ErrorMessage = "收到的长度不是规定的报文长度：177";
71.                         recvMessageEvent?.Invoke(ErrorMessage);
72.                         ClientSocket.Close();
73.                         break;
74.                     }
75.                 }
76.                 catch (Exception ex)
77.                 {
78.                     Device.Device_State = false;
79.                     ErrorMessage = ex.Message;
80.                     recvMessageEvent?.Invoke(ErrorMessage);
81.                     ClientSocket.Close();
82.                     break;
83.                 }
84.             }
85.         }

复制代码

 

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