C# Socket 编程 Sample

Posted 2022-11-23 sunshineyph

使用Socket通信的服务器端编程，熟悉了服务器端和客户端的通信流程，实现了收发信息、文件传送以及震动功能

服务器端先创建Socket，然后将其和本地ip地址以及端口号连接，也就是使用Bind方法，然后使用Listen方法监听。

用Accept方法接受客户端的连接申请，并且等待客户端连接（在winform中，由于Accept方法是阻塞方法，必须创建一个线程来执行，防止主窗体卡死）

客户端连接成功Accept方法会返回一个用于发送和接收消息的Socket，之后就要用这个socket进行通信

在通信过程中要像实现不同功能，比如传送文件，就要在发送的字节流中使用一定的位置来存储信息，也就是使用自己的协议，在这个案例中，取第一个字节标识信息，0代表发送信息，1代表传递文件，2代表震动窗体

服务端代码如下

  1 using System;
  2 using System.Collections.Generic;
  3 using System.ComponentModel;
  4 using System.Data;
  5 using System.Drawing;
  6 using System.Linq;
  7 using System.Text;
  8 using System.Threading.Tasks;
  9 using System.Windows.Forms;
 10 using System.Net.Sockets;
 11 using System.Net;
 12 using System.Threading;
 13 using System.IO;
 14  
 15 namespace ServerReview
 16 
 17     public partial class Form1 : Form
 18     
 19         public Form1()
 20         
 21             InitializeComponent();
 22         
 23         private Socket socketSend;
 24         private Socket socketWatch;
 25         private Dictionary<string, Socket> socketClientList = new Dictionary<string, Socket>();
 26         private void btnStart_Click(object sender, EventArgs e)
 27         
 28             socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 29             IPAddress ip = IPAddress.Any;
 30             IPEndPoint iep = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));
 31             //将套接字和本机地址绑定
 32             socketWatch.Bind(iep);
 33             ShowMsg("监听成功");
 34             //用Listen监听
 35             socketWatch.Listen(10);
 36             //创建新线程不停接受客户端请求
 37             Thread thread = new Thread(ServerAccept);
 38             thread.IsBackground = true;
 39             thread.Start();
 40         
 41         private void ServerAccept()
 42         
 43             while (true)
 44             
 45                 socketSend = socketWatch.Accept();
 46                 socketClientList.Add(socketSend.RemoteEndPoint.ToString(), socketSend);
 47                 cboUsers.Items.Add(socketSend.RemoteEndPoint.ToString());
 48                 ShowMsg(socketSend.RemoteEndPoint.ToString() + "连接成功");
 49                 //开启新线程不停接收消息
 50                 Thread thread = new Thread(ServerReceive);
 51                 thread.IsBackground = true;
 52                 thread.Start();
 53             
 54         
 55         private void ServerReceive()
 56         
 57             while (true)
 58             
 59                 try
 60                 
 61                     byte[] buffer = new byte[1024 * 1024 * 2];
 62                     int byteNum = socketSend.Receive(buffer);
 63                     if (byteNum == 0)
 64                     
 65                         break;
 66                     
 67                     string str = Encoding.UTF8.GetString(buffer, 0, byteNum);
 68                     ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + str);
 69                 
 70                 catch  
 71             
 72         
 73         private void ShowMsg(string str)
 74         
 75             txtLog.AppendText(str + "\r\n");
 76         
 77  
 78         private void Form1_Load(object sender, EventArgs e)
 79         
 80             Control.CheckForIllegalCrossThreadCalls = false;
 81         
 82  
 83         private void btnSend_Click(object sender, EventArgs e)
 84         
 85             string str = txtMsg.Text;
 86             List<byte> list = new List<byte>();
 87             list.Add(0);
 88             byte[] buffer = Encoding.UTF8.GetBytes(str);
 89             list.AddRange(buffer);
 90             byte[] newBuffer = list.ToArray();
 91             string ip = cboUsers.SelectedItem.ToString();
 92             socketClientList[ip].Send(newBuffer);
 93         
 94  
 95         private void btnSelectFile_Click(object sender, EventArgs e)
 96         
 97             OpenFileDialog ofd = new OpenFileDialog();
 98             ofd.InitialDirectory = @"D:\";
 99             ofd.Title = "请选择要发送的文件";
100             ofd.Filter = "所有文件|*.*";
101             ofd.ShowDialog();
102             txtFilePath.Text = ofd.FileName;
103         
104  
105         private void btnSendFile_Click(object sender, EventArgs e)
106         
107             string path = txtFilePath.Text;
108             using(FileStream fsRead = new FileStream(path, FileMode.Open, FileAccess.Read))
109             
110                 try
111                 
112                     byte[] buffer = new byte[1024 * 1024 * 5];
113                     int l = fsRead.Read(buffer, 0, buffer.Length);
114                     List<byte> list = new List<byte>();
115                     list.Add(1);
116                     list.AddRange(buffer);
117                     byte[] newBuffer = list.ToArray();
118                     socketClientList[cboUsers.SelectedItem.ToString()].Send(newBuffer,0,l+1,SocketFlags.None);
119                 
120                 catch  
121             
122         
123  
124         private void btnShake_Click(object sender, EventArgs e)
125         
126             byte[] buffer = new byte[1];
127             buffer[0] = 2;
128             socketClientList[cboUsers.SelectedItem.ToString()].Send(buffer);
129         
130     
131 

客户端代码如下：

 1 using System;
 2 using System.Collections.Generic;
 3 using System.ComponentModel;
 4 using System.Data;
 5 using System.Drawing;
 6 using System.IO;
 7 using System.Linq;
 8 using System.Net;
 9 using System.Net.Sockets;
10 using System.Text;
11 using System.Threading;
12 using System.Threading.Tasks;
13 using System.Windows.Forms;
14  
15 namespace ClientRevier
16 
17     public partial class Form1 : Form
18     
19         public Form1()
20         
21             InitializeComponent();
22         
23  
24         private void Form1_Load(object sender, EventArgs e)
25         
26             Control.CheckForIllegalCrossThreadCalls = false;
27         
28         private Socket socketClient;
29         private void btnStart_Click(object sender, EventArgs e)
30         
31             socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
32             IPAddress ip = IPAddress.Parse(txtServer.Text);
33             IPEndPoint iep = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));
34             socketClient.Connect(iep);
35             ShowMsg("连接成功");
36             //因为要不停接受消息，所以用while循环，并且为了接受消息的同时能做其他事，把这个放到线程中执行
37             Thread thread = new Thread(ClientRecieve);
38             thread.IsBackground = true;
39             thread.Start();
40         
41         private void ClientRecieve()
42         
43             while (true)
44             
45                 byte[] buffer = new byte[1024 * 1024 * 2];
46                 int byteNum = socketClient.Receive(buffer);
47                 if (byteNum == 0)
48                 
49                     break;
50                 
51                 switch (buffer[0])
52                 
53                     case 0:
54                         string str = Encoding.UTF8.GetString(buffer, 1, byteNum-1);
55                         ShowMsg(socketClient.RemoteEndPoint + ":" + str);
56                         break;
57                     case 1:
58                         SaveFileDialog sfd = new SaveFileDialog();
59                         sfd.InitialDirectory = @"D\";
60                         sfd.Title = "请选择需要保存的路径";
61                         sfd.Filter = "文本文件|*.txt|图片文件|*.jpg|所有文件|*.*";
62                         sfd.ShowDialog(this);
63                         using(FileStream fsWrite = new FileStream(sfd.FileName, FileMode.OpenOrCreate, FileAccess.Write))
64                         
65                             fsWrite.Write(buffer, 1, byteNum - 1);
66                             MessageBox.Show("保存成功");
67                         
68                         break;
69                     case 2:
70                         for(int i = 0; i < 1000; i++)
71                         
72                             this.Location = new Point(200, 200);
73                             this.Location = new Point(230, 230);
74                         
75                         break;
76                     default:break;
77                 
78                 
79             
80         
81         private void ShowMsg(string str)
82         
83             txtLog.AppendText(str + "\r\n");
84         
85  
86         private void btnSend_Click(object sender, EventArgs e)
87         
88             string str = txtMsg.Text;
89             byte[] buffer = Encoding.UTF8.GetBytes(str);
90             socketClient.Send(buffer);
91  
92         
93     
94