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 Form1 : Form 
    { 
        public Form1() 
        { 
            InitializeComponent(); 
            this.txtPort.Text = "5000"; 
            this.txtIp.Text = "192.168.137.1"; 
        } 
        private void btnStart_Click(object sender, EventArgs e) 
        { 
            //當(dāng)點(diǎn)擊開始監(jiān)聽的時(shí)候，在服務(wù)器端創(chuàng)建一個(gè)負(fù)責(zé)監(jiān)聽IP地址跟端口號的Socket 
            Socket socketWatch = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp); 
            //Any:提供一個(gè) IP 地址，指示服務(wù)器應(yīng)偵聽所有網(wǎng)絡(luò)接口上的客戶端活動(dòng)。此字段為只讀。 
            IPAddress ip = IPAddress.Any; 
            //創(chuàng)建端口號對象；將txtPort.Text控件的值設(shè)為服務(wù)端的端口號 
            IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text)); 
            //監(jiān)聽 
            socketWatch.Bind(point); 
            ShowMsg("監(jiān)聽成功"); 
            socketWatch.Listen(10);//連接隊(duì)列的最大長度 ;即：一個(gè)時(shí)間點(diǎn)內(nèi)最大能讓幾個(gè)客戶端連接進(jìn)來，超過長度就進(jìn)行排隊(duì) 
            //等待客戶端連接;Accept()這個(gè)方法能接收客戶端的連接，并為新連接創(chuàng)建一個(gè)負(fù)責(zé)通信的Socket 
            Thread th = new Thread(Listen); //被線程執(zhí)行的方法如果有參數(shù)的話,參數(shù)必須是object類型 
            Control.CheckForIllegalCrossThreadCalls = false; //因?yàn)?net不允許跨線程訪問的，所以這里取消跨線程的檢查。.net不檢查是否有跨線程訪問了，所有就不會報(bào)： “從不是創(chuàng)建控件“txtLog”的線程訪問它” 這個(gè)錯(cuò)誤了，從而實(shí)現(xiàn)了跨線程訪問 
            th.IsBackground = true; //將th這個(gè)線程設(shè)為后臺線程。 
            //Start(object parameter); parameter:一個(gè)對象，包含線程執(zhí)行的方法要使用的數(shù)據(jù),即線程執(zhí)行Listen方法，Listen的參數(shù) 
            th.Start(socketWatch);  //這個(gè)括號里的參數(shù)其實(shí)是Listen()方法的參數(shù)。因?yàn)門hread th = new Thread(Listen)這個(gè)括號里只能寫方法名(函數(shù)名) 但是Listen()方法是有參數(shù)的，所有就要用Start()方法將它的參數(shù)添加進(jìn)來 
        } 
        /// <summary> 
        /// 等待客戶端連接，如果監(jiān)控到有客戶端連接進(jìn)來就創(chuàng)建一個(gè)與之通信的Socket 
        /// </summary> 
        /// <param name="o"></param> 
        void Listen(object o) //這里為什么不直接傳遞Socket類型的參數(shù)呢？ 原因是：被線程執(zhí)行的方法如果有參數(shù)的話,參數(shù)必須是object類型 
        { 
            Socket socketWatch = o as Socket; 
            while (true) //為什么這里要有個(gè)while循環(huán)？因?yàn)楫?dāng)一個(gè)人連接進(jìn)來的時(shí)候創(chuàng)建了與之通信的Socket后就程序就會往下執(zhí)行了，就不會再回來為第二個(gè)人的連接創(chuàng)建負(fù)責(zé)通信的Socket了。（應(yīng)該是每個(gè)人(每個(gè)客戶端)創(chuàng)建一個(gè)與之通信的Socket）所以要寫在循環(huán)里。 
            { 
                //等待客戶端連接;Accept()這個(gè)方法能接收客戶端的連接，并為新連接創(chuàng)建一個(gè)負(fù)責(zé)通信的Socket 
                Socket socketSend = socketWatch.Accept(); 
                dic.Add(socketSend.RemoteEndPoint.ToString(), socketSend); //（根據(jù)客戶端的IP地址和端口號找負(fù)責(zé)通信的Socket，每個(gè)客戶端對應(yīng)一個(gè)負(fù)責(zé)通信的Socket），ip地址及端口號作為鍵，將負(fù)責(zé)通信的Socket作為值填充到dic鍵值對中。 
                //我們通過負(fù)責(zé)通信的這個(gè)socketSend對象的一個(gè)RemoteEndPoint屬性，能夠拿到遠(yuǎn)程連過來的客戶端的Ip地址跟端口號 
                ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + "連接成功");//效果：192.168.1.32:連接成功 
                comboBox1.Items.Add(socketSend.RemoteEndPoint.ToString()); //將連接過來的每個(gè)客戶端都添加到combBox控件中。 
                //客戶端連接成功后，服務(wù)器應(yīng)該接收客戶端發(fā)來的消息。  
                Thread getdata = new Thread(GetData); 
                getdata.IsBackground = true; 
                getdata.Start(socketSend); 
            } 
        } 
        Dictionary<string, Socket> dic = new Dictionary<string, Socket>(); 
        /// <summary> 
        /// 不停的接收客戶端發(fā)送過來的消息 
        /// </summary> 
        /// <param name="o"></param> 
        void GetData(object o) 
        { 
            while (true) 
            { 
                Socket socketSend = o as Socket; 
                //將客戶端發(fā)過來的數(shù)據(jù)先放到一個(gè)字節(jié)數(shù)組里面去 
                byte[] buffer = new byte[1024 * 1024 * 2]; //創(chuàng)建一個(gè)字節(jié)數(shù)組，字節(jié)數(shù)組的長度為2M 
                //實(shí)際接收到的有效字節(jié)數(shù); (利用Receive方法接收客戶端傳過來的數(shù)據(jù)，然后把數(shù)據(jù)保存到buffer字節(jié)數(shù)組中，返回一個(gè)接收到的數(shù)據(jù)的長度) 
                int r = socketSend.Receive(buffer); 
                if (r == 0) //如果接收到的有效字節(jié)數(shù)為0 說明客戶端已經(jīng)關(guān)閉了。這時(shí)候就跳出循環(huán)了。 
                { 
                    //只有客戶端給用戶發(fā)消息，不可能是發(fā)0個(gè)長度的字節(jié)。即便發(fā)空消息，空消息也是有過個(gè)長度的。所有接收到的有效字節(jié)長度為0就代表客戶端已經(jīng)關(guān)閉了 
                    break; 
                } 
                //將buffer這個(gè)字節(jié)數(shù)組里面的數(shù)據(jù)按照UTF8的編碼，解碼成我們能夠讀懂的的string類型，因?yàn)閎uffer這個(gè)數(shù)組的實(shí)際存儲數(shù)據(jù)的長度是r個(gè) ，所以從索引為0的字節(jié)開始解碼，總共解碼r個(gè)字節(jié)長度。 
                string str = Encoding.UTF8.GetString(buffer, 0, r); 
                ShowMsg(socketSend.RemoteEndPoint.ToString() + ":" + str); 
            } 
        } 
        private void ShowMsg(string str) 
        { 
            txtLog.AppendText(str + "\r\n"); //將str這個(gè)字符串添加到txtLog這個(gè)文本框中。 
        } 
        /// <summary> 
        /// 服務(wù)端給客戶端發(fā)信息 
        /// </summary> 
        /// <param name="sender"></param> 
        /// <param name="e"></param> 
        private void btnSend_Click_1(object sender, EventArgs e) 
        { 
            if (comboBox1.SelectedItem == null) //如果comboBox控件沒有選中值。就提示用戶選擇客戶端 
            { 
                MessageBox.Show("請選擇客戶端"); 
                return; 
            } 
            string str = txtMes.Text; //獲取用戶輸入的內(nèi)容 （服務(wù)端要給客戶端發(fā)的信息） 
            byte[] strByte = Encoding.Default.GetBytes(str); //將信息轉(zhuǎn)換成二進(jìn)制字節(jié)數(shù)組 
            string getIp = comboBox1.SelectedItem as string; //comboBox存儲的是客戶端的（ip+端口號） 
            Socket socketSend = dic[getIp] as Socket; //根據(jù)這個(gè)（ip及端口號）去dic鍵值對中找對應(yīng) 賦值與客戶端通信的Socket【每個(gè)客戶端都有一個(gè)負(fù)責(zé)與之通信的Socket】 
            socketSend.Send(strByte); //將信息發(fā)送到客戶端 
        } 
    } 
}