Socket网络通信基础教程【客户端/服务端】

Halcom

Socket网络通信基础教程

1.         private void button1_Click(object sender, EventArgs e)
   
2.         {
   
3.             //Socket
   
4.             socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
   
5.             string str0 = "Hello Client!";
   
6.             byte[] bytes0 = System.Text.Encoding.Default.GetBytes(str0);
   
7.             socket.Send(bytes0);
   
8.             socket.Blocking = false;
   
9. 
   
10.             //Connect
    
11.             string host = this.textBox1.Text.ToString();
    
12.             int port = int.Parse(this.textBox2.Text.ToString());
    
13.             socket.Connect(host, port);
    
14.             this.clientText.Text = "客户端地址" + socket.LocalEndPoint.ToString();
    
15. 
    
16.             int timesNoMsg = 0;
    
17.             if (socket.Available == 0)
    
18.             {
    
19.                 Thread.Sleep(200);
    
20.                 timesNoMsg++;
    
21.                 if (timesNoMsg / 10 > timeOut)
    
22.                 {
    
23.                     throw new Exception("连接中断");
    
24.                 }
    
25.             }
    
26.             else
    
27.             {
    
28.                 timesNoMsg = 0;
    
29.             }
    
30. 
    
31.             //Send
    
32.             string str = "Hello Unity!";
    
33.             byte[] bytes = System.Text.Encoding.Default.GetBytes(str);
    
34.             socket.Send(bytes);
    
35. 
    
36.             bool flag = true;
    
37.             //Recv
    
38.             while (flag == true)
    
39.             {
    
40.                 int count = socket.Receive(readBuff);
    
41.                 str = System.Text.Encoding.UTF8.GetString(readBuff, 0, count);
    
42.                 if(str.Contains("_"))
    
43.                 {
    
44. 
    
45.                 }
    
46.                 this.recvText.Text = str;
    
47.             }
    
48. 
    
49.             //Close
    
50.             socket.Close();
    
51.         }

复制代码

服务端接受

1. private void button1_Click(object sender, EventArgs e)
   
2.         {
   
3.             connfds = new Dictionary<string, Socket>();
   
4.             //方法
   
5.             Thread t = new Thread(new ThreadStart(listenProc));
   
6.             t.Start();
   
7.         }
   
8.         private void listenProc()
   
9.         {
   
10.             string ServerIP = this.textBox1.Text.ToString();
    
11.             int ServerPort = Convert.ToInt32(this.textBox2.Text.ToString());
    
12. 
    
13.             //新建一个套接字Socket即创建Socket
    
14.             Socket listenfd = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
15.             IPAddress ipAdr = IPAddress.Any;
    
16.             IPEndPoint ipEp = new IPEndPoint(ipAdr, ServerPort);//用IPAddress指定的地址和端口号初始化
    
17. 
    
18.             listenfd.Bind(ipEp);
    
19.             listenfd.Listen(10);
    
20.             //Console.WriteLine("[服务器]启动成功");
    
21. 
    
22.             while (listening_)
    
23.             {
    
24.                 //Accept
    
25.                 Socket connfd = listenfd.Accept();
    
26.                 string connGuid = Guid.NewGuid().ToString("B");
    
27.                 connfds.Add(connGuid, connfd);
    
28.                 //Console.WriteLine("[服务器]Accept");
    
29.                 printmessage(Color.Blue, "[服务器]Accept");
    
30. 
    
31.                 //Recv
    
32.                 byte[] readBuff = new byte[1024];
    
33.                 int count = connfd.Receive(readBuff);
    
34.                 string str = System.Text.Encoding.UTF8.GetString(readBuff, 0, count);
    
35.                 //Console.WriteLine("[服务器接收]" + str);
    
36. 
    
37.                 //Send
    
38. 
    
39.                 byte[] bytes = System.Text.Encoding.Default.GetBytes("\r\n回传" + str);
    
40.                 connfd.Send(bytes);
    
41. 
    
42.                 // 对str操作
    
43.                 string[] strs = str.Split(new[] { "|" }, StringSplitOptions.RemoveEmptyEntries);
    
44.                 bytes = System.Text.Encoding.Default.GetBytes("\r\n回传: " + strs[0]);
    
45. 
    
46.                 // 方法
    
47.                 new Thread(() => BatchProc(connGuid, strs[0])).Start();
    
48. 
    
49.             }
    
50.         }
    
51. 
    
52.         private void BatchProc(string connGuid, string str)
    
53.         {
    
54.             //
    
55.             // 算法部分
    
56.             //
    
57. 
    
58.             if (connfds[connGuid] != null && connfds[connGuid].Connected == true)
    
59.             {
    
60.                 connfds[connGuid].Send(System.Text.Encoding.Default.GetBytes("\r\n回传: " + "[图像检测完成]"));
    
61.                 printmessage(Color.Blue, "[图像检测完成]" + str);
    
62.             }
    
63.         }

复制代码

参考：
【1】C# Socket网络通信基础教程  https://www.pianshen.com/article/4121438054/