using System;
 using System.Collections.Generic;
 using System.ComponentModel;
 using System.Data;
 using System.Drawing;
 using System.Linq;
 using System.Net;
 using System.Net.Sockets;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 using System.Threading;
 using System.IO;
 
 namespace SocketServer
 {
     public partial class FrmServer : Form
     {
         public FrmServer()
         {
             InitializeComponent();
         }
 
         //定義回調(diào):解決跨線程訪問(wèn)問(wèn)題
         private delegate void SetTextValueCallBack(string strValue);
         //定義接收客戶端發(fā)送消息的回調(diào)
         private delegate void ReceiveMsgCallBack(string strReceive);
         //聲明回調(diào)
         private SetTextValueCallBack setCallBack;
         //聲明
         private ReceiveMsgCallBack receiveCallBack;
         //定義回調(diào)：給ComboBox控件添加元素
         private delegate void SetCmbCallBack(string strItem);
         //聲明
         private SetCmbCallBack setCmbCallBack;
         //定義發(fā)送文件的回調(diào)
         private delegate void SendFileCallBack(byte[] bf);
         //聲明
         private SendFileCallBack sendCallBack;
 
         //用于通信的Socket
         Socket socketSend;
         //用于監(jiān)聽(tīng)的SOCKET
         Socket socketWatch;
 
         //將遠(yuǎn)程連接的客戶端的IP地址和Socket存入集合中
         Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();
 
         //創(chuàng)建監(jiān)聽(tīng)連接的線程
         Thread AcceptSocketThread;
         //接收客戶端發(fā)送消息的線程
         Thread threadReceive;
 
         /// <summary>
         /// 開(kāi)始監(jiān)聽(tīng)
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_Start_Click(object sender, EventArgs e)
         {
             //當(dāng)點(diǎn)擊開(kāi)始監(jiān)聽(tīng)的時(shí)候 在服務(wù)器端創(chuàng)建一個(gè)負(fù)責(zé)監(jiān)聽(tīng)I(yíng)P地址和端口號(hào)的Socket
             socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
             //獲取ip地址
             IPAddress ip=IPAddress.Parse(this.txt_IP.Text.Trim());
             //創(chuàng)建端口號(hào)
             IPEndPoint point=new IPEndPoint(ip,Convert.ToInt32(this.txt_Port.Text.Trim()));
             //綁定IP地址和端口號(hào)
             socketWatch.Bind(point);
             this.txt_Log.AppendText("監(jiān)聽(tīng)成功"+" \r \n");
             //開(kāi)始監(jiān)聽(tīng):設(shè)置最大可以同時(shí)連接多少個(gè)請(qǐng)求
             socketWatch.Listen(10);
 
             //實(shí)例化回調(diào)
             setCallBack = new SetTextValueCallBack(SetTextValue);
             receiveCallBack = new ReceiveMsgCallBack(ReceiveMsg);
             setCmbCallBack = new SetCmbCallBack(AddCmbItem);
             sendCallBack = new SendFileCallBack(SendFile);
 
             //創(chuàng)建線程
             AcceptSocketThread = new Thread(new ParameterizedThreadStart(StartListen));
             AcceptSocketThread.IsBackground = true;
             AcceptSocketThread.Start(socketWatch);
         }
 
         /// <summary>
         /// 等待客戶端的連接，并且創(chuàng)建與之通信用的Socket
         /// </summary>
         /// <param name="obj"></param>
         private void StartListen(object obj)
         {
             Socket socketWatch = obj as Socket;
             while (true)
             {               
                 //等待客戶端的連接，并且創(chuàng)建一個(gè)用于通信的Socket
                 socketSend = socketWatch.Accept();
                 //獲取遠(yuǎn)程主機(jī)的ip地址和端口號(hào)
                 string strIp=socketSend.RemoteEndPoint.ToString();
                 dicSocket.Add(strIp, socketSend);
                 this.cmb_Socket.Invoke(setCmbCallBack, strIp);
                 string strMsg = "遠(yuǎn)程主機(jī)：" + socketSend.RemoteEndPoint + "連接成功";
                 //使用回調(diào)
                 txt_Log.Invoke(setCallBack, strMsg);
 
                 //定義接收客戶端消息的線程
                 Thread threadReceive = new Thread(new ParameterizedThreadStart(Receive));
                 threadReceive.IsBackground = true;
                 threadReceive.Start(socketSend);
 
             }
         }
 
        
 
         /// <summary>
         /// 服務(wù)器端不停的接收客戶端發(fā)送的消息
         /// </summary>
         /// <param name="obj"></param>
         private void Receive(object obj)
         {
             Socket socketSend = obj as Socket;
             while (true)
             {
                 //客戶端連接成功后，服務(wù)器接收客戶端發(fā)送的消息
                 byte[] buffer = new byte[2048];
                 //實(shí)際接收到的有效字節(jié)數(shù)
                 int count = socketSend.Receive(buffer);
                 if (count == 0)//count 表示客戶端關(guān)閉，要退出循環(huán)
                 {
                     break;
                 }
                 else
                 {
                     string str = Encoding.Default.GetString(buffer, 0, count);
                     string strReceiveMsg = "接收：" + socketSend.RemoteEndPoint + "發(fā)送的消息:" + str;
                     txt_Log.Invoke(receiveCallBack, strReceiveMsg);
                 }
             }
         }
 
         /// <summary>
         /// 回調(diào)委托需要執(zhí)行的方法
         /// </summary>
         /// <param name="strValue"></param>
         private void SetTextValue(string strValue)
         {
             this.txt_Log.AppendText(strValue + " \r \n");
         }
 
 
         private void ReceiveMsg(string strMsg)
         {
             this.txt_Log.AppendText(strMsg + " \r \n");
         }
 
         private void AddCmbItem(string strItem)
         {
             this.cmb_Socket.Items.Add(strItem);
         }
 
         /// <summary>
         /// 服務(wù)器給客戶端發(fā)送消息
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_Send_Click(object sender, EventArgs e)
         {
             try
             {
                 string strMsg = this.txt_Msg.Text.Trim();
                 byte[] buffer = Encoding.Default.GetBytes(strMsg);
                 List<byte> list = new List<byte>();
                 list.Add(0);
                 list.AddRange(buffer);
                 //將泛型集合轉(zhuǎn)換為數(shù)組
                 byte[] newBuffer = list.ToArray();
                 //獲得用戶選擇的IP地址
                 string ip = this.cmb_Socket.SelectedItem.ToString();
                 dicSocket[ip].Send(newBuffer);
             }
             catch (Exception ex)
             {
                 MessageBox.Show("給客戶端發(fā)送消息出錯(cuò):"+ex.Message);
             }
             //socketSend.Send(buffer);
         }
 
         /// <summary>
         /// 選擇要發(fā)送的文件
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_Select_Click(object sender, EventArgs e)
         {
             OpenFileDialog dia = new OpenFileDialog();
             //設(shè)置初始目錄
             dia.InitialDirectory = @"";
             dia.Title = "請(qǐng)選擇要發(fā)送的文件";
             //過(guò)濾文件類(lèi)型
             dia.Filter = "所有文件|*.*";
             dia.ShowDialog();
             //將選擇的文件的全路徑賦值給文本框
             this.txt_FilePath.Text = dia.FileName;
         }
 
         /// <summary>
         /// 發(fā)送文件
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_SendFile_Click(object sender, EventArgs e)
         {
             List<byte> list = new List<byte>();
             //獲取要發(fā)送的文件的路徑
             string strPath = this.txt_FilePath.Text.Trim();
             using (FileStream sw = new FileStream(strPath,FileMode.Open,FileAccess.Read))
             {
                 byte[] buffer = new byte[2048];
                 int r = sw.Read(buffer, 0, buffer.Length);
                 list.Add(1);
                 list.AddRange(buffer);
 
                 byte[] newBuffer = list.ToArray();
                 //發(fā)送
                 //dicSocket[cmb_Socket.SelectedItem.ToString()].Send(newBuffer, 0, r+1, SocketFlags.None);
                 btn_SendFile.Invoke(sendCallBack, newBuffer);
 
                 
             }
             
         }
 
         private void SendFile(byte[] sendBuffer)
         {
 
             try
             {
                 dicSocket[cmb_Socket.SelectedItem.ToString()].Send(sendBuffer, SocketFlags.None);
             }
             catch (Exception ex)
             {
                 MessageBox.Show("發(fā)送文件出錯(cuò):"+ex.Message);
             }
         }
 
         private void btn_Shock_Click(object sender, EventArgs e)
         {
             byte[] buffer = new byte[1] { 2};
             dicSocket[cmb_Socket.SelectedItem.ToString()].Send(buffer);
         }
 
         /// <summary>
         /// 停止監(jiān)聽(tīng)
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_StopListen_Click(object sender, EventArgs e)
         {
             socketWatch.Close();
             socketSend.Close();
             //終止線程
             AcceptSocketThread.Abort();
             threadReceive.Abort();
         }
     }
 }

 using System;
 using System.Collections.Generic;
 using System.ComponentModel;
 using System.Data;
 using System.Drawing;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 using System.Net.Sockets;
 using System.Net;
 using System.Threading;
 using System.IO;
 
 namespace SocketClient
 {
     public partial class FrmClient : Form
     {
         public FrmClient()
         {
             InitializeComponent();
         }
 
         //定義回調(diào)
         private delegate void SetTextCallBack(string strValue);
         //聲明
         private SetTextCallBack setCallBack;
 
         //定義接收服務(wù)端發(fā)送消息的回調(diào)
         private delegate void ReceiveMsgCallBack(string strMsg);
         //聲明
         private ReceiveMsgCallBack receiveCallBack;
 
         //創(chuàng)建連接的Socket
         Socket socketSend;
         //創(chuàng)建接收客戶端發(fā)送消息的線程
         Thread threadReceive;
 
         /// <summary>
         /// 連接
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_Connect_Click(object sender, EventArgs e)
         {
             try
             {
                 socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                 IPAddress ip = IPAddress.Parse(this.txt_IP.Text.Trim());
                 socketSend.Connect(ip, Convert.ToInt32(this.txt_Port.Text.Trim()));
                 //實(shí)例化回調(diào)
                 setCallBack = new SetTextCallBack(SetValue);
                 receiveCallBack = new ReceiveMsgCallBack(SetValue);
                 this.txt_Log.Invoke(setCallBack, "連接成功");
 
                 //開(kāi)啟一個(gè)新的線程不停的接收服務(wù)器發(fā)送消息的線程
                 threadReceive = new Thread(new ThreadStart(Receive));
                 //設(shè)置為后臺(tái)線程
                 threadReceive.IsBackground = true;
                 threadReceive.Start();
             }
             catch (Exception ex)
             {
                 MessageBox.Show("連接服務(wù)端出錯(cuò):" + ex.ToString());
             }
         }
 
         /// <summary>
         /// 接口服務(wù)器發(fā)送的消息
         /// </summary>
         private void Receive()
         {
             try
             {
                 while (true)
                 {
                     byte[] buffer = new byte[2048];
                     //實(shí)際接收到的字節(jié)數(shù)
                     int r = socketSend.Receive(buffer);
                     if (r == 0)
                     {
                         break;
                     }
                     else
                     {
                         //判斷發(fā)送的數(shù)據(jù)的類(lèi)型
                         if (buffer[0] == 0)//表示發(fā)送的是文字消息
                         {
                             string str = Encoding.Default.GetString(buffer, 1, r - 1);
                             this.txt_Log.Invoke(receiveCallBack, "接收遠(yuǎn)程服務(wù)器:" + socketSend.RemoteEndPoint + "發(fā)送的消息:" + str);
                         }
                         //表示發(fā)送的是文件
                         if (buffer[0] == 1)
                         {
                             SaveFileDialog sfd = new SaveFileDialog();
                             sfd.InitialDirectory = @"";
                             sfd.Title = "請(qǐng)選擇要保存的文件";
                             sfd.Filter = "所有文件|*.*";
                             sfd.ShowDialog(this);
 
                             string strPath = sfd.FileName;
                             using (FileStream fsWrite = new FileStream(strPath, FileMode.OpenOrCreate, FileAccess.Write))
                             {
                                 fsWrite.Write(buffer, 1, r - 1);
                             }
 
                             MessageBox.Show("保存文件成功");
                         }
                     }
 
 
                 }
             }
             catch (Exception ex)
             {
                 MessageBox.Show("接收服務(wù)端發(fā)送的消息出錯(cuò):" + ex.ToString());
             }
         }
 
 
         private void SetValue(string strValue)
         {
             this.txt_Log.AppendText(strValue + "\r \n");
         }
 
         /// <summary>
         /// 客戶端給服務(wù)器發(fā)送消息
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_Send_Click(object sender, EventArgs e)
         {
             try
             {
                 string strMsg = this.txt_Msg.Text.Trim();
                 byte[] buffer = new byte[2048];
                 buffer = Encoding.Default.GetBytes(strMsg);
                 int receive = socketSend.Send(buffer);
             }
             catch (Exception ex)
             {
                 MessageBox.Show("發(fā)送消息出錯(cuò):" + ex.Message);
             }
         }
 
         private void FrmClient_Load(object sender, EventArgs e)
         {
             Control.CheckForIllegalCrossThreadCalls = false;
         }
 
         /// <summary>
         /// 斷開(kāi)連接
         /// </summary>
         /// <param name="sender"></param>
         /// <param name="e"></param>
         private void btn_CloseConnect_Click(object sender, EventArgs e)
         {
             //關(guān)閉socket
             socketSend.Close();
             //終止線程
             threadReceive.Abort();
         }
     }
 }