winform学习日志（二十三）---------------socket（TCP）发送文件
日期：2014-06-10 浏览次数：20686 次
一：由于在上一个随笔的基础之上拓展的所以直接上代码，客户端：
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.Threading; using System.Net; using System.IO; namespace client { public partial class Client : Form { public Client() { InitializeComponent(); } //创建 1个客户端套接字 和1个负责监听服务端请求的线程 Socket socketClient = null; Thread threadClient = null; private delegate void SetText(string text); /// <summary> /// 链接服务端 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_login_Click(object sender, EventArgs e) { socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //这里的ip地址，端口号都是服务端绑定的相关数据。 IPAddress ip = IPAddress.Parse(tb_ip.Text.Trim()); IPEndPoint endpoint = new IPEndPoint(ip, Convert.ToInt32(tb_socket.Text.Trim())); socketClient.Connect(endpoint);//链接有端口号与IP地址确定服务端. ThreadStart thS = new ThreadStart(this.ReceMsg); //客户端在接受服务端发送过来的数据是通过Socket 中的Receive方法， //该方法会阻断线程，所以我们自己为该方法创建了一个线程 threadClient = new Thread(thS); threadClient.IsBackground = true;//设置后台线程 threadClient.Start(); } //接收服务端数据 public void ReceMsg() { while (true)//持续监听服务端发来的消息 { //定义一个2M的内存缓冲区 用于临时性存储接收到的信息 byte[] buffer = new byte[1024 * 1024 * 2]; //将客户端套接字接收到的数据存入内存缓冲区, 并获取其长度 int length = socketClient.Receive(buffer); //clientSocket.Receive(buffer);//接收服务端发送过来的数据 string ReceiveMsg = System.Text.Encoding.UTF8.GetString(buffer,0,length);//把接收到的字节数组转成字符串显示在文本框中,如果没有长度,就会以零填充满,后面的日期就会不显示了。 ShowMsg("接收到数据: " + ReceiveMsg); } } //消息框里面数据 void ShowMsg(string str) { if (this.tb_infor.InvokeRequired) { SetText st = new SetText(ShowMsg); this.Invoke(st, new object[] { str }); } else { //string Ystr = ""; //if (tb_infor.Text != "") //{ // Ystr = tb_infor.Text + "\r\n"; //} //tb_infor.Text = Ystr + str + GetCurrentTime(); //代替上面的方法 tb_infor.AppendText(str + GetCurrentTime() + "\r\n"); } } /// <summary> /// 打开文件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_openfile_Click(object sender, EventArgs e) { if (openFileDialog1.ShowDialog() == DialogResult.OK)//这里需要小括号 ShowDialog() { tb_openfile.Text = openFileDialog1.FileName; } } #region /// <summary> /// 发送文件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_sendfile_Click(object sender, EventArgs e) { using (FileStream fs = new FileStream(tb_openfile.Text, FileMode.Open)) { byte[] buffer = new byte[1024 * 1024 * 2]; int readlength = fs.Read(buffer, 0, buffer.Length); byte[] filebuffer = new byte[readlength + 1]; filebuffer[0] = 1; Buffer.BlockCopy(buffer, 0, filebuffer, 1, readlength); //第一参数：表示源数组,第二个：表示从源数组中的哪个位置开始拷贝,第三个：表示目标数组。,第四个：表示从目标数组的哪个位置开始填充.,五：表示：拷贝多少数据 socketClient.Send(filebuffer); } } /// <summary> /// 发送消息 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_sendmessage_Click(object sender, EventArgs e) { string txtMsg = tb_message.Text; sendmessage(txtMsg); } /// <summary> /// 发送信息 /// </summary> /// <param name="txtMsg"></param> private void sendmessage(string txtMsg) { //将输入的内容字符串转换为机器可以识别的字节数组 byte[] buffer = Encoding.UTF8.GetBytes(txtMsg); byte[] messagebuffer = new byte[buffer.Length + 1];//定义一个新数组,加个标记位,标记是信息 messagebuffer[0] = 0;//设置标识，表示发送的是字符串 Buffer.BlockCopy(buffer, 0, messagebuffer, 1, buffer.Length);//源数组中的数据拷贝到新数组中 socketClient.Send(messagebuffer); ShowMsg("发送的数据: " + txtMsg); } #endregion /// <summary> /// 获取当前系统时间的方法 /// </summary> /// <returns>当前时间</returns> private DateTime GetCurrentTime() { DateTime currentTime = new DateTime(); currentTime = DateTime.Now; return currentTime; } //快捷键 Enter发送信息 private void tb_message_PreviewKeyDown(object sender, PreviewKeyDownEventArgs e) {//当光标位于文本框时 如果用户按下了键盘上的Enter键 if (e.KeyCode == Keys.Enter) { //则调用客户端向服务端发送信息的方法 sendmessage(tb_message.Text.Trim()); } } } }
二：服务端
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; using System.IO; namespace socket { public partial class Server : Form { public Server() { InitializeComponent(); //关闭对文本框的非法线程操作检查,不建议用 //TextBox.CheckForIllegalCrossThreadCalls = false; } Socket socketWatch = null;//负责监听客户端的套接字 Thread threadWatch = null;//负责监听客户端的线程 Thread threadMoveList = null;//负责去掉失败的socket的ip //声明一个带参数委托处理文本显示 private delegate void SetText(string text); //声明一个处理ip添加到listbox的委托 private delegate void listboxAdd(string ipsocket); //声明一个处理在listbox去除ip的委托 private delegate void listboxmove(string ipsocket); /// 开始服务端监听 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_StartServer_Click(object sender, EventArgs e) { #region //创建一个Socket实例 //第一个参数表示使用ipv4 //第二个参数表示发送的是数据流 //第三个参数表示使用的协议是Tcp协议 socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //获取ip地址 IPAddress ip = IPAddress.Parse(tb_ip.Text.Trim()); //创建一个网络通信节点，这个通信节点包含了ip地址，跟端口号。 //这里的端口我们设置为1029，这里设置大于1024，为什么自己查一下端口号范围使用说明。 IPEndPoint endPoint = new IPEndPoint(ip, int.Parse(tb_socket.Text.Trim())); //设置SOCKET允许多个SOCKET访问同一个本地IP地址和端口号 socketWatch.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true); //Socket绑定网路通信节点 socketWatch.Bind(endPoint); //将套接字的监听队列长度限制为10 socketWatch.Listen(10); ShowMsg("开启监听！"); //实力化一个线程上的委托 ThreadStart threadDelegate = new ThreadStart(this.accpet);//还需要invoke //实力化一个处理线程委托的的新线程 threadWatch = new Thread(threadDelegate); //等同于上面两句newthread = new Thread(new ThreadStart(this.accpet)); threadWatch.IsBackground = true; threadWatch.Start(); #endregion } //消息框里面数据 public void ShowMsg(string str) { if (this.tb_infor.InvokeRequired) { //实例化一个委托 SetText d = new SetText(ShowMsg); this.Invoke(d, new object[] { str }); } else { //string Ystr = ""; //if (tb_infor.Text != "") //{ // Ystr = tb_infor.Text + "\r\n"; //} //this.tb_infor.Text = Ystr + str + GetCurrentTime(); tb_infor.AppendText(str + GetCurrentTime() + "\r\n"); } } Dictionary<string, Socket> socketDir = new Dictionary<string, Socket>();//将每一个与客户端进行通信的Socket放到该集合中. public void accpet() { while (true)//注意该循环,服务端要持续监听,要不然一个客户端链接过后就无法链接第二个客户端了。 { Socket SocketConnection = null;//创建一个负责和客户端通信的套接字 //创建一个接收客户端通信的Socket SocketConnection = socketWatch.Accept(); socketDir.Add(SocketConnection.RemoteEndPoint.ToString(), SocketConnection);//将负责与客户端进行通信的Socket实例添加到集合中。 //如果监听到客户端有链接，则运行到下一部，提示，链接成功！ listboxADD(SocketConnection.RemoteEndPoint.ToString()); ShowMsg("链接成功！"); //创建一个通信线程 ParameterizedThreadStart pts = new ParameterizedThreadStart(ServerRecMsg); Thread thr = new Thread(pts); //在定义窗体线程的时候,设置线程启动前状态就行了,解决异常 thr.SetApartmentState(ApartmentState.STA); thr.IsBackground = true; //启动线程 thr.Start(SocketConnection); } } /// <summary> /// 在ip栏里添加建立socket的ip /// </summary> private void listboxADD(string ipsocket) { if (this.ltb_IP.InvokeRequired) { listboxAdd list = new listboxAdd(listboxADD); this.Invoke(list,new object[]{ipsocket}); } else { ltb_IP.Items.Add(ipsocket); } } } /// <summary> /// 向客户端发送信息 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_sendany_Click(object sender, EventArgs e) { string SendMsg = tb_message.Text; if (SendMsg != "") { byte[] buffer = System.Text.Encoding.UTF8.GetBytes(SendMsg); //将要发送的数据，生成字节数组。 if (!string.IsNullOrEmpty(this.ltb_IP.Text)) { string ipendpoint = this.ltb_IP.SelectedItem .ToString();//在服务端，选择与客户端进行通信的IP地址与端口号 socketDir[ipendpoint].Send(buffer);//向客户端发送数据 ShowMsg("向客户端发送了:" + SendMsg); } else { MessageBox.Show("请选择与哪个客户端进行通信"); } } } /// <summary> /// 获取当前系统时间的方法 /// </summary> /// <returns>当前时间</returns> private DateTime GetCurrentTime() { DateTime currentTime = new DateTime(); currentTime = DateTime.Now; return currentTime; } /// <summary> /// 接收客户端发来的信息 /// </summary> /// <param name="socketClientPara">客户端套接字对象</param> private void ServerRecMsg(object socketClientPara) { Socket socketServer = socketClientPara as Socket; while (true) { int length = -1; //创建一个内存缓冲区 其大小为1024*1024字节 即1M byte[] arrServerRecMsg = new byte[1024 * 1024 * 2]; try //由于Socket中的Receive方法容易抛出异常，所以我们在这里要捕获异常。 { //将接收到的信息存入到内存缓冲区,并返回其字节数组的长度 length = socketServer.Receive(arrServerRecMsg); } catch (SocketException ex)//注意：在捕获异常时，先确定具体的异常类型。 { ShowMsg("出现了异常:" + ex.Message); socketDir.Remove(socketServer.RemoteEndPoint.ToString());//如果出现了异常，将该Socket实例从集合中移除 //ParameterizedThreadStart Delegatemove = new ParameterizedThreadStart(listboxmoveway);//用ParameterizedThreadStart其方法可以带一个object类型的参数 //threadMoveList = new Thread(Delegatemove); //threadMoveList.IsBackground = true; //threadMoveList.Start(); //listboxmoveway(socketServer.RemoteEndPoint);//调用方法 //socketServer.Close(); break;//出现异常以后，终止整个循环的执行 } catch (Exception ex) { ShowMsg("出现了异常:" + ex.Message); break; } if (arrServerRecMsg[0] == 0)//表示字符串 { //将机器接受到的字节数组转换为人可以读懂的字符串 string strSRecMsg = Encoding.UTF8.GetString(arrServerRecMsg, 1, length-1); //将发送的字符串信息附加到文本框txtMsg上 ShowMsg("接受客户端数据:" + strSRecMsg); } else if (arrServerRecMsg[0] == 1) { SaveFileDialog savefile=new SaveFileDialog(); if(savefile.ShowDialog()==DialogResult.OK) { using(FileStream fs=new FileStream(savefile.FileName,FileMode.Create)) { fs.Write(arrServerRecMsg, 1, length - 1);//将文件写到磁盘上，从1开始到receiveLength-1 ShowMsg("文件写成功!" ); } } } } } } }
免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
