Socket 学习实例

整理一份Socket代码，整理前辈的代码

http://www.cnblogs.com/yellowapplemylove/archive/2011/04/19/2021586.html

直接贴代码

一、客户端

/// <summary>
    /// Client客户端
    /// </summary>
    public partial class ClientForm : Form
    {
        private IPAddress serverIp ;
        private IPEndPoint serverFullAddr;
        private Socket sock;
        public ClientForm()
        {
            InitializeComponent();
            this.Load += (e, v) =>
            {
                txtIP.Text = "127.0.0.1";
                txtPort.Text = "2014";
            };
        }
        private void btnConnect_Click(object sender, EventArgs e)
        {
            try
            {
                serverIp = IPAddress.Parse(txtIP.Text.Trim());
                serverFullAddr = new IPEndPoint(serverIp, int.Parse(txtPort.Text.Trim()));
                sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                sock.Connect(serverFullAddr);//建立与远程主机的连接
                //启动新线程用于接收数据
                Thread t = new Thread(new ThreadStart(ReceiveMsg));
                t.Name = "接收消息";
                //一个线程或者是后台线程或者是前台线程。后台线程与前台线程类似，区别是后台线程不会防止进程终止。
                //一旦属于某一进程的所有前台线程都终止，公共语言运行库就会通过对任何仍然处于活动状态的后台线程调用 abort 来结束该进程。
                t.IsBackground = true;
                t.Start();
            }
            catch(Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }
        private void ReceiveMsg()
        {
            try
            {
                while (true)
                {
                    byte[] byterec = new byte[100];
                    this.sock.Receive(byterec);
                    string strrec = System.Text.Encoding.UTF8.GetString(byterec);
                    if (this.txtReceive.InvokeRequired)
                    {
                        this.txtReceive.Invoke(new EventHandler(ChangerText), new object[] { strrec, EventArgs.Empty });
                    }
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show("接收服务器消息发生错误" + ex.Message);
            }
        }
        private void ChangerText(object obj, EventArgs e)
        {
            string s = Convert.ToString(obj);
            this.txtReceive.AppendText(s + Environment.NewLine);
        }
        private void btnSend_Click(object sender, EventArgs e)
        {
            byte[] byteSend =System.Text.Encoding.UTF8.GetBytes(this.txtSend.Text.ToCharArray());
            try
            {
                sock.Send(byteSend);
            }
            catch
            {
                MessageBox.Show("向服务器发送数据错误");
            }
        }
        private void btnClose_Click(object sender, EventArgs e)
        {
            try
            {
                this.sock.Shutdown(SocketShutdown.Receive);
                this.sock.Close();
                Application.Exit();
            }
            catch
            {
                MessageBox.Show("关闭连接发生错误");
            }
        }
    }

二、服务器端

public partial class ServerForm : Form
    {
        private IPAddress serverIp ;//IP地址
        private IPEndPoint serverFullAddr;//完整终端地址
        private Socket sock;
        private System.Timers.Timer timer;
        private ArrayList allStocksList;//当建立了多个连接时用于保存连接
        public ServerForm()
        {
            InitializeComponent();
            this.Load += (e, v) =>
            {
                txtIP.Text = "127.0.0.1";
                txtPort.Text = "2014";
            };
        }
        private void btstart_click(object sender, EventArgs e)
        {
            serverIp = IPAddress.Parse(txtIP.Text.Trim());
            serverFullAddr = new IPEndPoint(serverIp, int.Parse(txtPort.Text.Trim()));
            //构造socket对象，套接字类型为“流套接字”，指定五元组中的协议元
            sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp);
            //指定五元组中的本地二元，即本地主机地址和端口号
            sock.Bind(serverFullAddr);
            //监听是否有连接传入，指定挂起的连接队列的最大值为20
            sock.Listen(20);
            allStocksList = new ArrayList();
            //构造定时器，时间间隙为1秒，即每隔一秒执行一次accept()方法，以获取连接请求队列中//第一个挂起的连接请求
            timer = new System.Timers.Timer(1000);
            timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);
            timer.Enabled = true;
        }
        private void timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            timer.Enabled = false;
            //执行accept()，当挂起队列为空时将阻塞本线程，同时由于上一语句，定时器将停止，直//至有连接传入
            Socket acceptSTock = sock.Accept();
            //将accept()产生的socket对象存入arraylist
            allStocksList.Add(acceptSTock);
            // 构造threading.timer对象，这将导致程序另启线程。线程将执行回调函数，该委托限制//函数参数须为object型。
            //threading.timer构造器的第二个参数即传入回调函数的参数；第//三个参数指定调用回调函数之前的延时，取0则立即启动；
            //最后一个参数指定调用回调函数//的时间间隔，取0则只执行一次。
            System.Threading.Timer ti = new System.Threading.Timer(new TimerCallback(receivemsg), acceptSTock, 0, 0);
            timer.Enabled = true;
        }

        private void receivemsg(object obj)
        {
            Socket acceptStock = (Socket)obj;
            try
            {
                while (true)
                {
                    byte[] byteArray = new byte[100];
                    acceptStock.Receive(byteArray);//接收数据
                    //将字节数组转成字符串
                    string strrec = System.Text.Encoding.UTF8.GetString(byteArray);
                    if (this.txtReceive.InvokeRequired)
                    {
                        this.txtReceive.Invoke(new EventHandler(this.ChangerText), new object[] { strrec, EventArgs.Empty });
                    }
                }
            }
            catch (Exception ex)
            {
                acceptStock.Close();
                MessageBox.Show("接收客户端消息错误" + ex.Message);
            }
        }
        private void ChangerText(object obj, EventArgs e)
        {
            string s = Convert.ToString(obj);
            this.txtReceive.AppendText(s + Environment.NewLine);
        }
        private void btnSend_Click(object sender, EventArgs e)
        {
            Socket sc = null;
            byte[] byteSend =System.Text.Encoding.UTF8.GetBytes(this.tbsend.Text.ToCharArray());
            try
            {
                //向所有的客户端发送数据
                for (int i = 0; i < allStocksList.Count; i++)
                {
                    sc = allStocksList[i] as Socket;
                    sc.Send(byteSend);
                }
            }
            catch (Exception ex)
            {
                if (sc != null)
                {
                    sc.Close();
                }

                MessageBox.Show("向客户端发送信息错误" + ex.Message);
            }
        }
        
        private void btnClose_Click(object sender, EventArgs e)
        {
            try
            {
                Application.Exit();
            }
            catch (Exception ex)
            {
                MessageBox.Show("关闭连接发生错误" + ex.Message);
            }
        }
    }