C#网络编程之Socket编程

 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(); } //定义回调:解决跨线程访问问题 private delegate void SetTextValueCallBack(string strValue); //定义接收客户端发送消息的回调 private delegate void ReceiveMsgCallBack(string strReceive); //声明回调 private SetTextValueCallBack setCallBack; //声明 private ReceiveMsgCallBack receiveCallBack; //定义回调：给ComboBox控件添加元素 private delegate void SetCmbCallBack(string strItem); //声明 private SetCmbCallBack setCmbCallBack; //定义发送文件的回调 private delegate void SendFileCallBack(byte[] bf); //声明 private SendFileCallBack sendCallBack; //用于通信的Socket Socket socketSend; //用于监听的SOCKET Socket socketWatch; //将远程连接的客户端的IP地址和Socket存入集合中 Dictionary dicSocket = new Dictionary(); //创建监听连接的线程 Thread AcceptSocketThread; //接收客户端发送消息的线程 Thread threadReceive; /// 
 /// 开始监听 /// 
 ///  ///  private void btn_Start_Click(object sender, EventArgs e) { //当点击开始监听的时候 在服务器端创建一个负责监听IP地址和端口号的Socket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //获取ip地址 IPAddress ip=IPAddress.Parse(this.txt_IP.Text.Trim()); //创建端口号 IPEndPoint point=new IPEndPoint(ip,Convert.ToInt32(this.txt_Port.Text.Trim())); //绑定IP地址和端口号 socketWatch.Bind(point); this.txt_Log.AppendText("监听成功"+" \r \n"); //开始监听:设置最大可以同时连接多少个请求 socketWatch.Listen(10); //实例化回调 setCallBack = new SetTextValueCallBack(SetTextValue); receiveCallBack = new ReceiveMsgCallBack(ReceiveMsg); setCmbCallBack = new SetCmbCallBack(AddCmbItem); sendCallBack = new SendFileCallBack(SendFile); //创建线程 AcceptSocketThread = new Thread(new ParameterizedThreadStart(StartListen)); AcceptSocketThread.IsBackground = true; AcceptSocketThread.Start(socketWatch); } /// 
 /// 等待客户端的连接，并且创建与之通信用的Socket /// 
 ///  private void StartListen(object obj) { Socket socketWatch = obj as Socket; while (true) { //等待客户端的连接，并且创建一个用于通信的Socket socketSend = socketWatch.Accept(); //获取远程主机的ip地址和端口号 string strIp=socketSend.RemoteEndPoint.ToString(); dicSocket.Add(strIp, socketSend); this.cmb_Socket.Invoke(setCmbCallBack, strIp); string strMsg = "远程主机：" + socketSend.RemoteEndPoint + "连接成功"; //使用回调 txt_Log.Invoke(setCallBack, strMsg); //定义接收客户端消息的线程 Thread threadReceive = new Thread(new ParameterizedThreadStart(Receive)); threadReceive.IsBackground = true; threadReceive.Start(socketSend); } } /// 
 /// 服务器端不停的接收客户端发送的消息 /// 
 ///  private void Receive(object obj) { Socket socketSend = obj as Socket; while (true) { //客户端连接成功后，服务器接收客户端发送的消息 byte[] buffer = new byte[2048]; //实际接收到的有效字节数 int count = socketSend.Receive(buffer); if (count == 0)//count 表示客户端关闭，要退出循环 { break; } else { string str = Encoding.Default.GetString(buffer, 0, count); string strReceiveMsg = "接收：" + socketSend.RemoteEndPoint + "发送的消息:" + str; txt_Log.Invoke(receiveCallBack, strReceiveMsg); } } } /// 
 /// 回调委托需要执行的方法 /// 
 ///  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); } /// 
 /// 服务器给客户端发送消息 /// 
 ///  ///  private void btn_Send_Click(object sender, EventArgs e) { try { string strMsg = this.txt_Msg.Text.Trim(); byte[] buffer = Encoding.Default.GetBytes(strMsg); List list = new List(); list.Add(0); list.AddRange(buffer); //将泛型集合转换为数组 byte[] newBuffer = list.ToArray(); //获得用户选择的IP地址 string ip = this.cmb_Socket.SelectedItem.ToString(); dicSocket[ip].Send(newBuffer); } catch (Exception ex) { MessageBox.Show("给客户端发送消息出错:"+ex.Message); } //socketSend.Send(buffer); } /// 
 /// 选择要发送的文件 /// 
 ///  ///  private void btn_Select_Click(object sender, EventArgs e) { OpenFileDialog dia = new OpenFileDialog(); //设置初始目录 dia.InitialDirectory = @""; dia.Title = "请选择要发送的文件"; //过滤文件类型 dia.Filter = "所有文件|*.*"; dia.ShowDialog(); //将选择的文件的全路径赋值给文本框 this.txt_FilePath.Text = dia.FileName; } /// 
 /// 发送文件 /// 
 ///  ///  private void btn_SendFile_Click(object sender, EventArgs e) { List list = new List(); //获取要发送的文件的路径 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(); //发送 //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("发送文件出错:"+ex.Message); } } private void btn_Shock_Click(object sender, EventArgs e) { byte[] buffer = new byte[1] { 2}; dicSocket[cmb_Socket.SelectedItem.ToString()].Send(buffer); } /// 
 /// 停止监听 /// 
 ///  ///  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(); } //定义回调 private delegate void SetTextCallBack(string strValue); //声明 private SetTextCallBack setCallBack; //定义接收服务端发送消息的回调 private delegate void ReceiveMsgCallBack(string strMsg); //声明 private ReceiveMsgCallBack receiveCallBack; //创建连接的Socket Socket socketSend; //创建接收客户端发送消息的线程 Thread threadReceive; /// 
 /// 连接 /// 
 ///  ///  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())); //实例化回调 setCallBack = new SetTextCallBack(SetValue); receiveCallBack = new ReceiveMsgCallBack(SetValue); this.txt_Log.Invoke(setCallBack, "连接成功"); //开启一个新的线程不停的接收服务器发送消息的线程 threadReceive = new Thread(new ThreadStart(Receive)); //设置为后台线程 threadReceive.IsBackground = true; threadReceive.Start(); } catch (Exception ex) { MessageBox.Show("连接服务端出错:" + ex.ToString()); } } /// 
 /// 接口服务器发送的消息 /// 
 private void Receive() { try { while (true) { byte[] buffer = new byte[2048]; //实际接收到的字节数 int r = socketSend.Receive(buffer); if (r == 0) { break; } else { //判断发送的数据的类型 if (buffer[0] == 0)//表示发送的是文字消息 { string str = Encoding.Default.GetString(buffer, 1, r - 1); this.txt_Log.Invoke(receiveCallBack, "接收远程服务器:" + socketSend.RemoteEndPoint + "发送的消息:" + str); } //表示发送的是文件 if (buffer[0] == 1) { SaveFileDialog sfd = new SaveFileDialog(); sfd.InitialDirectory = @""; sfd.Title = "请选择要保存的文件"; 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("接收服务端发送的消息出错:" + ex.ToString()); } } private void SetValue(string strValue) { this.txt_Log.AppendText(strValue + "\r \n"); } /// 
 /// 客户端给服务器发送消息 /// 
 ///  ///  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("发送消息出错:" + ex.Message); } } private void FrmClient_Load(object sender, EventArgs e) { Control.CheckForIllegalCrossThreadCalls = false; } /// 
 /// 断开连接 /// 
 ///  ///  private void btn_CloseConnect_Click(object sender, EventArgs e) { //关闭socket socketSend.Close(); //终止线程 threadReceive.Abort(); } } }