using System;

 using System.Collections.Generic;

 using System.ComponentModel;

 using System.Data;

 using System.Drawing;

 using System.Linq;

 using System.Text;

 using System.Windows.Forms;

 using System.Net.Sockets;

 using System.Net;

 using System.Threading;

 namespace socket网络编程

 {

     public partial class frmServer : Form

     {

         public frmServer()

         {

             InitializeComponent();

             Control.CheckForIllegalCrossThreadCalls = false;

         }

         private void BtnStart_Click(object sender, EventArgs e)

         {

             try

             {

                 //Socket服务器端

                 //引入命名空间：using System.Net;

                 //引入命名空间：using System.Net.Sockets;

                 //1、创建Socket

                 Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //第一个参数：设置网络寻址协议；第二个参数：设置数据传输方式；第三个参数：设置通信协议

                 //2、绑定IP和端口

                 this.txtLog.Text = "创建服务端Socket对象\r\n"+this.txtLog.Text;

                 IPAddress ip = IPAddress.Parse(txtIp.Text.Trim()); //IP地址

                 int port = Convert.ToInt32(txtPort.Text.Trim()); //端口

                 IPEndPoint ipEndpoint = new IPEndPoint(ip, port);

                 serverSocket.Bind(ipEndpoint);

                 //3、开启侦听

                 serverSocket.Listen(); //挂起连接队列的最大长度。

                 //4、开始接收客户端连接

                 this.txtLog.Text = "开启接受客户端连接\r\n" + this.txtLog.Text;

                 ThreadPool.QueueUserWorkItem(new WaitCallback(this.StartAcceptClient), serverSocket);

             }

             catch (Exception ex)

             {

                 throw ex;

             }

         }

         List<Socket> ClientProxSocket = new List<Socket>();

         public void StartAcceptClient(object state)

         {

             try

             {

                 var serverSocket = (Socket)state;

                 while (true)

                 {

                     Socket proxSocket = serverSocket.Accept(); //为新建连接创建新的Socket对象

                     this.txtLog.Text = string.Format("客户端:{0}已连接\r\n{1}", proxSocket.RemoteEndPoint.ToString(), this.txtLog.Text); //proxSocket.RemoteEndPoint：获取连接信息

                     ClientProxSocket.Add(proxSocket);

                     //服务端接受客户端的消息

                     ThreadPool.QueueUserWorkItem(new WaitCallback(RecieveData),proxSocket);

                     //string str = DateTime.Now.ToString();

                     //byte[] data = Encoding.UTF8.GetBytes(str); //待发送字节数组

                     //proxSocket.Send(data, 0, data.Length, SocketFlags.None); //发送消息,发送的消息必须大于0个字节

                     //proxSocket.Shutdown(SocketShutdown.Both);

                     //this.txtLog.Text = "关闭\r\n" + this.txtLog.Text;

                     //proxSocket.Close(); //关闭

                 }

             }

             catch (Exception ex)

             {

                 throw ex;

             }

         }

         public void RecieveData(object obj)

         {

             var proxSocket = (Socket)obj;

             byte[] data = new byte[ * ];

             //方法返回值，实际接受的数据的长度(字节数)

             while (true)

             {

                 try //处理客户端异常退出

                 {

                     int reallen = proxSocket.Receive(data, , data.Length, SocketFlags.None);

                     if (reallen == )

                     {

                         this.txtLog.Text = string.Format("客户端:{0}退出\r\n{1}", proxSocket.RemoteEndPoint.ToString(), this.txtLog.Text);

                         //客户端退出

                         proxSocket.Shutdown(SocketShutdown.Both);

                         proxSocket.Close();

                         ClientProxSocket.Remove(proxSocket);

                         return;

                     }

                     string formClientMsg = Encoding.UTF8.GetString(data, , reallen);

                     this.txtLog.Text = string.Format("接受客户端{0}的消息:{1}\r\n{2}", proxSocket.RemoteEndPoint.ToString(), formClientMsg, this.txtLog.Text);

                 }

                 catch (Exception ex)

                 {

                 }

             }

         }

         private void BtnSend_Click(object sender, EventArgs e)

         {

             try

             {

                 foreach (var socket in ClientProxSocket)

                 {

                     if (socket.Connected)

                     {

                         string str = this.txtMsg.Text.Trim();

                         byte[] data = Encoding.UTF8.GetBytes(str);

                         socket.Send(data, , data.Length, SocketFlags.None);

                     }

                 }

             }

             catch (Exception ex)

             {

                 throw ex;

             }

         }

     }

 }