1 private void Form1_Load(object sender, EventArgs e)2 3         {4 5             Control.CheckForIllegalCrossThreadCalls = false;6 7         }8 9  10 11         private void btnListen_Click(object sender, EventArgs e)12 13         {14 15             //ip地址16 17             IPAddress ip = IPAddress.Parse(txtIP.Text);18 19            // IPAddress ip = IPAddress.Any;20 21             //端口号22 23             IPEndPoint point=new IPEndPoint(ip,int.Parse(txtPort.Text));24 25             //创建监听用的Socket26 27             /*28 29              * AddressFamily.InterNetWork：使用 IP4地址。30 31 SocketType.Stream：支持可靠、双向、基于连接的字节流，而不重复数据。此类型的 Socket 与单个对方主机进行通信，并且在通信开始之前需要远程主机连接。Stream 使用传输控制协议 (Tcp) ProtocolType 和 InterNetworkAddressFamily。32 33 ProtocolType.Tcp：使用传输控制协议。34 35              */36 37             //使用IPv4地址，流式socket方式，tcp协议传递数据38 39             Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);40 41             //创建好socket后，必须告诉socket绑定的IP地址和端口号。42 43             //让socket监听point44 45             try46 47             {48 49                 //socket监听哪个端口50 51                 socket.Bind(point);52 53                 //同一个时间点过来10个客户端，排队54 55                 socket.Listen(10);56 57                 ShowMsg("服务器开始监听");58 59                 Thread thread = new Thread(AcceptInfo);60 61                 thread.IsBackground = true;62 63                 thread.Start(socket);64 65             }66 67             catch (Exception ex)68 69             {70 71                72 73                ShowMsg(ex.Message);74 75             }76 77         }78 79         //记录通信用的Socket80 81         Dictionary<string,Socket> dic=new Dictionary<string, Socket>();82 83        // private Socket client;84 85         void AcceptInfo(object o)86 87         {88 89             Socket socket = o as Socket;90 91             while (true)92 93             {94 95                 //通信用socket96 97                 try98 99                 {
100
101                     //创建通信用的Socket
102
103                   Socket  tSocket = socket.Accept();
104
105                   string point = tSocket.RemoteEndPoint.ToString();
106
107                     //IPEndPoint endPoint = (IPEndPoint)client.RemoteEndPoint;
108
109                     //string me = Dns.GetHostName();//得到本机名称
110
111                     //MessageBox.Show(me);
112
113                  ShowMsg(point + "连接成功！");
114
115                  cboIpPort.Items.Add(point);
116
117                  dic.Add(point, tSocket);
118
119                     //接收消息
120
121                     Thread th = new Thread(ReceiveMsg);
122
123                     th.IsBackground = true;
124
125                     th.Start(tSocket);
126
127                 }
128
129                 catch (Exception ex)
130
131                 {
132
133                     ShowMsg(ex.Message);
134
135                     break;
136
137                 }
138
139             }
140
141         }
142
143         //接收消息
144
145         void ReceiveMsg(object o)
146
147         {
148
149             Socket client = o as Socket;
150
151             while (true)
152
153             {
154
155                 //接收客户端发送过来的数据
156
157                 try
158
159                 {
160
161                     //定义byte数组存放从客户端接收过来的数据
162
163                     byte[] buffer = new byte[1024 * 1024];
164
165                     //将接收过来的数据放到buffer中，并返回实际接受数据的长度
166
167                     int n = client.Receive(buffer);
168
169                     //将字节转换成字符串
170
171                     string words = Encoding.UTF8.GetString(buffer, 0, n);
172
173
174
175                     ShowMsg(client.RemoteEndPoint.ToString() + ":" + words);
176
177                 }
178
179                 catch (Exception ex)
180
181                 {
182
183                    ShowMsg(ex.Message);
184
185                     break;
186
187                 }
188
189             }
190
191         }
192
193
194
195         void ShowMsg(string msg)
196
197         {
198
199             txtLog.AppendText(msg+"\r\n");
200
201         }
202
203
204
205         private void Form1_FormClosing(object sender, FormClosingEventArgs e)
206
207         {
208
209             //主窗体关闭时关闭子线程
210
211
212
213         }
214
215         //给客户端发送消息
216
217         private void btnSend_Click(object sender, EventArgs e)
218
219         {
220
221             try
222
223             {
224
225                 ShowMsg(txtMsg.Text);
226
227                 string ip = cboIpPort.Text;
228
229                 byte[] buffer = Encoding.UTF8.GetBytes(txtMsg.Text);
230
231                 dic[ip].Send(buffer);
232
233                 // client.Send(buffer);
234
235             }
236
237             catch (Exception ex)
238
239             {
240
241                ShowMsg(ex.Message);
242
243             }
244
245
246
247         }

  1 Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);2 3         private void btnConnection_Click(object sender, EventArgs e)4 5         {6 7             //连接到的目标IP8 9             IPAddress ip = IPAddress.Parse(txtIP.Text);10 11             //IPAddress ip = IPAddress.Any;12 13             //连接到目标IP的哪个应用(端口号！)14 15             IPEndPoint point=new IPEndPoint(ip,int.Parse(txtPort.Text));16 17             try18 19             {20 21                 //连接到服务器22 23                 client.Connect(point);24 25                 ShowMsg("连接成功");26 27                 ShowMsg("服务器" + client.RemoteEndPoint.ToString());28 29                 ShowMsg("客户端:" + client.LocalEndPoint.ToString());30 31                 //连接成功后，就可以接收服务器发送的信息了32 33                 Thread th=new Thread(ReceiveMsg);34 35                 th.IsBackground = true;36 37                 th.Start();38 39             }40 41             catch (Exception ex)42 43             {44 45                 ShowMsg(ex.Message);46 47             }48 49         }50 51         //接收服务器的消息52 53         void ReceiveMsg()54 55         {56 57             while (true)58 59             {60 61                 try62 63                 {64 65                     byte[] buffer = new byte[1024 * 1024];66 67                     int n = client.Receive(buffer);68 69                     string s = Encoding.UTF8.GetString(buffer, 0, n);70 71                     ShowMsg(client.RemoteEndPoint.ToString() + ":" + s);72 73                 }74 75                 catch (Exception ex)76 77                 {78 79                     ShowMsg(ex.Message);80 81                     break;82 83                 }84 85             }86 87           88 89         }90 91  92 93         void ShowMsg(string msg)94 95         {96 97             txtInfo.AppendText(msg+"\r\n");98 99         }
100
101
102
103         private void btnSend_Click(object sender, EventArgs e)
104
105         {
106
107             //客户端给服务器发消息
108
109             if (client!=null)
110
111             {
112
113                 try
114
115                 {
116
117                    ShowMsg(txtMsg.Text);
118
119                     byte[] buffer = Encoding.UTF8.GetBytes(txtMsg.Text);
120
121                     client.Send(buffer);
122
123                 }
124
125                 catch (Exception ex)
126
127                 {
128
129                    ShowMsg(ex.Message);
130
131                 }
132
133             }
134
135
136
137         }
138
139
140
141         private void ClientForm_Load(object sender, EventArgs e)
142
143         {
144
145             Control.CheckForIllegalCrossThreadCalls = false;
146
147         }