C# 56. Tcp Server

1. TCP Server类

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Net;
5. using System.Net.Sockets;
6. using System.Text;
7. using System.Threading.Tasks;
9. namespace Xxxxx
10. {
11.     public class TcpServer
12.     {
13.         private TcpListener listener;
14.         private bool isRunning = false;
15.         private dataProcessdelegate dataProcessFunc;
18.         public bool StartServer(string ip, int port, dataProcessdelegate dataProcessFunc1)
19.         {
20.             if(isRunning == false)
21.             {
22.                 dataProcessFunc = dataProcessFunc1;
23.                 IPAddress ipAddress = IPAddress.Parse(ip);
24.                 listener = new TcpListener(ipAddress, port);
25.                 Start();
26.             }
27.             else
28.             {
29.                 Stop();
30.             }
31.             return isRunning;
32.         }
34.         public void Start()
35.         {
36.             isRunning = true;
37.             listener.Start();
38.             Console.WriteLine($"Server started and listening on port {listener.LocalEndpoint}");
40.             Task.Run(() => AcceptClientsAsync());
41.         }
43.         public void Stop()
44.         {
45.             isRunning = false;
46.             listener.Stop();
47.             client.Close();
48.             Console.WriteLine("Server stopped.");
49.         }
51.         private async Task AcceptClientsAsync()
52.         {
53.             while (isRunning)
54.             {
55.                 try
56.                 {
57.                     TcpClient client = await listener.AcceptTcpClientAsync();       //#1
58.                     Console.WriteLine("Client connected.");
59.                     HandleClientAsync(client);      //#2，前面没有awiat则不会停在HandleClientAsync而是跳到#1。加了awiat则等待HandleClientAsync执行完成
60.                 }
61.                 catch (ObjectDisposedException) when (!isRunning)
62.                 {
63.                     // Server is stopping, ignore this exception
64.                 }
65.                 catch (Exception ex)
66.                 {
67.                     Console.WriteLine($"Error accepting client: {ex.Message}");
68.                 }
69.             }
70.         }
72.         private async Task HandleClientAsync(TcpClient client)
73.         {
74.             NetworkStream stream = client.GetStream();
75.             byte[] buffer = new byte[2048];
76.             int bytesRead;
78.             bool isRunningLocally = true; // 局部标志，用于控制循环
80.             try
81.             {
82.                 while ((bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length)) != 0 && isRunningLocally)
83.                 {
84.                     //string message = Encoding.UTF8.GetString(buffer, 0, bytesRead);
85.                     string message = System.Text.Encoding.Default.GetString(buffer, 0, bytesRead);
86.                     Console.WriteLine($"Received from client: {message}");
88.                     dataProcessFunc(buffer, bytesRead);
90.                     // 检查服务器是否仍在运行
91.                     if (!isRunning)
92.                     {
93.                         isRunningLocally = false; // 设置标志以跳出循环
94.                     }
95.                 }
96.             }
97.             catch (Exception ex)
98.             {
99.                 Console.WriteLine($"Error handling client: {ex.Message}");
100.             }
101.             finally
102.             {
103.                 client.Close();
104.                 Console.WriteLine("Client disconnected.");
105.             }
106.         }
107.     }
108. }

复制代码

2. 主类

1. //定义一个数据处理的委托
2. dataProcessdelegate dataProcessFunc;
4. TcpServer tcpServer = new TcpServer();
5. private void buttonOpenServer_Click(object sender, EventArgs e)
6. {
7.     if (serialPort1.IsOpen)
8.     {
9.         MessageBox.Show("请先关闭串口！");
10.         return;
11.     }
12.     bool flag;
13.     dataProcessFunc = new dataProcessdelegate(CmdParseInvoke);   
14.     flag = tcpServer.StartServer(textBoxIP.Text.Trim(), Convert.ToInt32(this.textBoxPort.Text.Trim()),  dataProcessFunc);
15.     if (flag == true)   //已连接
16.     {
17.         CommType = CommTypeEnum.TcpType;
18.         buttonOpenServer.Text = "关闭服务";
19.         buttonOpenServer.BackColor = Color.LightCoral;
20.     }
21.     else
22.     {
23.         CommType = CommTypeEnum.UnSelectType;
24.         buttonOpenServer.Text = "打开服务";
25.         buttonOpenServer.BackColor = Color.LimeGreen;
26.     }
27. }
29. private void CmdParseInvoke(byte[] buf, int length)
30. {
31.     Invoke((EventHandler)(delegate
32.     {
33.         CmdParse(buf, length);
34.     })
35.     );
36. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。