关键字: socket 网络编程 点对点 传输文件 文件传输 监听端口
服务器用来接收文件，不停的监听端口，有发送文件就马上开始接收文件 服务端代码： C#代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Net; using System.Threading; using System.Net.Sockets; using System.IO; namespace TestSocketServerHSTF { public partial class Form1 : Form { public Form1() { InitializeComponent(); //不显示出dataGridView1的最后一行空白 dataGridView1.AllowUserToAddRows = false; } #region 定义变量 #endregion #region 进入窗体即启动服务 private void Form1_Load(object sender, EventArgs e) { //开启接收线程 Thread TempThread = new Thread(new ThreadStart(this.StartReceive)); TempThread.Start(); } #endregion #region 功能函数 private void StartReceive() { //创建一个网络端点 IPEndPoint ipep = new IPEndPoint(IPAddress.Any, int.Parse("2005")); //MessageBox.Show(IPAddress.Any); //创建一个套接字 Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //绑定套接字到端口 server.Bind(ipep); //开始侦听(并堵塞该线程) server.Listen(10); //确认连接 Socket client = server.Accept(); //获得客户端节点对象 IPEndPoint clientep = (IPEndPoint)client.RemoteEndPoint; //获得[文件名] string SendFileName = System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client)); //MessageBox.Show("文件名" + SendFileName); //获得[包的大小] string bagSize = System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client)); //MessageBox.Show("包大小" + bagSize); //获得[包的总数量] int bagCount = int.Parse(System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client))); //MessageBox.Show("包的总数量" + bagCount); //获得[最后一个包的大小] string bagLast = System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client)); //MessageBox.Show("最后一个包的大小" + bagLast); //创建一个新文件 FileStream MyFileStream = new FileStream(SendFileName, FileMode.Create, FileAccess.Write); //已发送包的个数 int SendedCount = 0; while (true) { byte[] data = TransferFiles.ReceiveVarData(client); if (data.Length == 0) { break; } else { SendedCount++; //将接收到的数据包写入到文件流对象 MyFileStream.Write(data, 0, data.Length); //显示已发送包的个数 //MessageBox.Show("已发送包个数"+SendedCount.ToString()); } } //关闭文件流 MyFileStream.Close(); //关闭套接字 client.Close(); //填加到dgv里 //文件大小，IP，已发送包的个数，文件名，包的总量，最后一个包的大小 this.dataGridView1.Rows.Add(bagSize, clientep.Address, SendedCount, SendFileName, bagCount, bagLast); //MessageBox.Show("文件接收完毕!"); } #endregion #region 拦截Windows消息,关闭窗体时执行 protected override void WndProc(ref Message m) { const int WM_SYSCOMMAND = 0x0112; const int SC_CLOSE = 0xF060; if (m.Msg == WM_SYSCOMMAND && (int)m.WParam == SC_CLOSE) {//捕捉关闭窗体消息 // User clicked close button //this.WindowState = FormWindowState.Minimized;//把右上角红叉关闭按钮变最小化 ServiceStop(); } base.WndProc(ref m); } #endregion #region 停止服务 //停止服务 private void ServiceStop() { try { } catch { } try { } catch { } } #endregion } } using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Net; using System.Threading; using System.Net.Sockets; using System.IO; namespace TestSocketServerHSTF { public partial class Form1 : Form { public Form1() { InitializeComponent(); //不显示出dataGridView1的最后一行空白 dataGridView1.AllowUserToAddRows = false; } #region 定义变量 #endregion #region 进入窗体即启动服务 private void Form1_Load(object sender, EventArgs e) { //开启接收线程 Thread TempThread = new Thread(new ThreadStart(this.StartReceive)); TempThread.Start(); } #endregion #region 功能函数 private void StartReceive() { //创建一个网络端点 IPEndPoint ipep = new IPEndPoint(IPAddress.Any, int.Parse("2005")); //MessageBox.Show(IPAddress.Any); //创建一个套接字 Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //绑定套接字到端口 server.Bind(ipep); //开始侦听(并堵塞该线程) server.Listen(10); //确认连接 Socket client = server.Accept(); //获得客户端节点对象 IPEndPoint clientep = (IPEndPoint)client.RemoteEndPoint; //获得[文件名] string SendFileName = System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client)); //MessageBox.Show("文件名" + SendFileName); //获得[包的大小] string bagSize = System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client)); //MessageBox.Show("包大小" + bagSize); //获得[包的总数量] int bagCount = int.Parse(System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client))); //MessageBox.Show("包的总数量" + bagCount); //获得[最后一个包的大小] string bagLast = System.Text.Encoding.Unicode.GetString(TransferFiles.ReceiveVarData(client)); //MessageBox.Show("最后一个包的大小" + bagLast); //创建一个新文件 FileStream MyFileStream = new FileStream(SendFileName, FileMode.Create, FileAccess.Write); //已发送包的个数 int SendedCount = 0; while (true) { byte[] data = TransferFiles.ReceiveVarData(client); if (data.Length == 0) { break; } else { SendedCount++; //将接收到的数据包写入到文件流对象 MyFileStream.Write(data, 0, data.Length); //显示已发送包的个数 //MessageBox.Show("已发送包个数"+SendedCount.ToString()); } } //关闭文件流 MyFileStream.Close(); //关闭套接字 client.Close(); //填加到dgv里 //文件大小，IP，已发送包的个数，文件名，包的总量，最后一个包的大小 this.dataGridView1.Rows.Add(bagSize, clientep.Address, SendedCount, SendFileName, bagCount, bagLast); //MessageBox.Show("文件接收完毕!"); } #endregion #region 拦截Windows消息,关闭窗体时执行 protected override void WndProc(ref Message m) { const int WM_SYSCOMMAND = 0x0112; const int SC_CLOSE = 0xF060; if (m.Msg == WM_SYSCOMMAND && (int)m.WParam == SC_CLOSE) {//捕捉关闭窗体消息 // User clicked close button //this.WindowState = FormWindowState.Minimized;//把右上角红叉关闭按钮变最小化 ServiceStop(); } base.WndProc(ref m); } #endregion #region 停止服务 //停止服务 private void ServiceStop() { try { } catch { } try { } catch { } } #endregion } } 客户端用来发送文件，选择文件后点发送按钮发送文件 客户端代码： C#代码 //title: 点对点文件传输程序 // //Begin-发送端// using System; using System.Drawing; using System.Collections; using System.ComponentModel; using System.Windows.Forms; using System.Data; using System.IO; using System.Net; using System.Net.Sockets; using System.Threading; namespace 发送端 { /// <summary> /// Form1 的摘要说明。 /// </summary> public class Form1 : System.Windows.Forms.Form { private System.Windows.Forms.GroupBox groupBox1; private System.Windows.Forms.OpenFileDialog openFileDialog1; private System.Windows.Forms.TextBox textBox1; private System.Windows.Forms.Button button1; private System.Windows.Forms.Label label1; private System.Windows.Forms.TextBox textBox2; private System.Windows.Forms.Label label2; private System.Windows.Forms.TextBox textBox3; private System.Windows.Forms.GroupBox groupBox2; private System.Windows.Forms.Label label3; private System.Windows.Forms.TextBox textBox4; private System.Windows.Forms.Label label4; private System.Windows.Forms.TextBox textBox5; private System.Windows.Forms.GroupBox groupBox3; private System.Windows.Forms.GroupBox groupBox4; private System.Windows.Forms.Button button2; private System.Windows.Forms.Label label5; private System.Windows.Forms.TextBox textBox6; private System.Windows.Forms.Label label6; private System.Windows.Forms.Label label7; private System.Windows.Forms.ProgressBar progressBar1; private System.Windows.Forms.TextBox textBox7; private System.Windows.Forms.Label label8; private System.Windows.Forms.Label label9; private System.Windows.Forms.TextBox textBox8; private System.Windows.Forms.Label label10; private System.Windows.Forms.TextBox textBox9; private System.Windows.Forms.Label label11; private System.Windows.Forms.Label label12; private System.Windows.Forms.TextBox textBox10; /// <summary> /// 必需的设计器变量。 /// </summary> private System.ComponentModel.Container components = null; public Form1() { // // Windows 窗体设计器支持所必需的 // InitializeComponent(); // // TODO: 在 InitializeComponent 调用后添加任何构造函数代码 // } /// <summary> /// 清理所有正在使用的资源。 /// </summary> protected override void Dispose( bool disposing ) { if( disposing ) { if (components != null) { components.Dispose(); } } base.Dispose( disposing ); } #region Windows 窗体设计器生成的代码 /// <summary> /// 设计器支持所需的方法 - 不要使用代码编辑器修改 /// 此方法的内容。 /// </summary> private void InitializeComponent() { this.groupBox1 = new System.Windows.Forms.GroupBox(); this.textBox2 = new System.Windows.Forms.TextBox(); this.textBox3 = new System.Windows.Forms.TextBox(); this.label2 = new System.Windows.Forms.Label(); this.label1 = new System.Windows.Forms.Label(); this.button1 = new System.Windows.Forms.Button(); this.textBox1 = new System.Windows.Forms.TextBox(); this.label6 = new System.Windows.Forms.Label(); this.openFileDialog1 = new System.Windows.Forms.OpenFileDialog(); this.groupBox2 = new System.Windows.Forms.GroupBox(); this.textBox6 = new System.Windows.Forms.TextBox(); this.textBox5 = new System.Windows.Forms.TextBox(); this.label4 = new System.Windows.Forms.Label(); this.textBox4 = new System.Windows.Forms.TextBox(); this.label3 = new System.Windows.Forms.Label(); this.label5 = new System.Windows.Forms.Label(); this.label9 = new System.Windows.Forms.Label(); this.groupBox3 = new System.Windows.Forms.GroupBox(); this.textBox8 = new System.Windows.Forms.TextBox(); this.textBox9 = new System.Windows.Forms.TextBox(); this.textBox7 = new System.Windows.Forms.TextBox(); this.progressBar1 = new System.Windows.Forms.ProgressBar(); this.label7 = new System.Windows.Forms.Label(); this.label8 = new System.Windows.Forms.Label(); this.label10 = new System.Windows.Forms.Label(); this.label11 = new System.Windows.Forms.Label(); this.label12 = new System.Windows.Forms.Label(); this.textBox10 = new System.Windows.Forms.TextBox(); this.groupBox4 = new System.Windows.Forms.GroupBox(); this.button2 = new System.Windows.Forms.Button(); this.groupBox1.SuspendLayout(); this.groupBox2.SuspendLayout(); this.groupBox3.SuspendLayout(); this.groupBox4.SuspendLayout(); this.SuspendLayout(); // // groupBox1 // this.groupBox1.Controls.Add(this.textBox2); this.groupBox1.Controls.Add(this.textBox3); this.groupBox1.Controls.Add(this.label2); this.groupBox1.Controls.Add(this.label1); this.groupBox1.Controls.Add(this.button1); this.groupBox1.Controls.Add(this.textBox1); this.groupBox1.Controls.Add(this.label6); this.groupBox1.Location = new System.Drawing.Point(0, 0); this.groupBox1.Name = "groupBox1"; this.groupBox1.Size = new System.Drawing.Size(416, 96); this.groupBox1.TabIndex = 0; this.groupBox1.TabStop = false; this.groupBox1.Text = "文件信息"; // // textBox2 // this.textBox2.Location = new System.Drawing.Point(80, 40); this.textBox2.Name = "textBox2"; this.textBox2.ReadOnly = true; this.textBox2.Size = new System.Drawing.Size(232, 21); this.textBox2.TabIndex = 3; // // textBox3 // this.textBox3.Location = new System.Drawing.Point(80, 64); this.textBox3.Name = "textBox3"; this.textBox3.ReadOnly = true; this.textBox3.Size = new System.Drawing.Size(136, 21); this.textBox3.TabIndex = 3; // // label2 // this.label2.Location = new System.Drawing.Point(8, 72); this.label2.Name = "label2"; this.label2.Size = new System.Drawing.Size(100, 16); this.label2.TabIndex = 4; this.label2.Text = "文件大小："; // // label1 // this.label1.Location = new System.Drawing.Point(16, 48); this.label1.Name = "label1"; this.label1.Size = new System.Drawing.Size(96, 16); this.label1.TabIndex = 2; this.label1.Text = "文件名："; // // button1 // this.button1.Location = new System.Drawing.Point(320, 16); this.button1.Name = "button1"; this.button1.Size = new System.Drawing.Size(88, 23); this.button1.TabIndex = 1; this.button1.Text = "浏览"; this.button1.Click += new System.EventHandler(this.button1_Click); // // textBox1 // this.textBox1.Location = new System.Drawing.Point(8, 16); this.textBox1.Name = "textBox1"; this.textBox1.ReadOnly = true; this.textBox1.Size = new System.Drawing.Size(304, 21); this.textBox1.TabIndex = 0; // // label6 // this.label6.Location = new System.Drawing.Point(224, 72); this.label6.Name = "label6"; this.label6.Size = new System.Drawing.Size(96, 16); this.label6.TabIndex = 2; this.label6.Text = "（单位：字节）"; // // openFileDialog1 // this.openFileDialog1.Filter = "所有文件|*.*"; // // groupBox2 // this.groupBox2.Controls.Add(this.textBox6); this.groupBox2.Controls.Add(this.textBox5); this.groupBox2.Controls.Add(this.label4); this.groupBox2.Controls.Add(this.textBox4); this.groupBox2.Controls.Add(this.label3); this.groupBox2.Controls.Add(this.label5); this.groupBox2.Controls.Add(this.label9); this.groupBox2.Location = new System.Drawing.Point(0, 96); this.groupBox2.Name = "groupBox2"; this.groupBox2.Size = new System.Drawing.Size(416, 72); this.groupBox2.TabIndex = 1; this.groupBox2.TabStop = false; this.groupBox2.Text = "系统设置"; // // textBox6 // this.textBox6.Location = new System.Drawing.Point(96, 40); this.textBox6.Name = "textBox6"; this.textBox6.Size = new System.Drawing.Size(72, 21); this.textBox6.TabIndex = 3; this.textBox6.Text = "50000"; // // textBox5 // this.textBox5.Location = new System.Drawing.Point(320, 16); this.textBox5.Name = "textBox5"; this.textBox5.Size = new System.Drawing.Size(80, 21); this.textBox5.TabIndex = 3; this.textBox5.Text = "2005"; // // label4 // this.label4.Location = new System.Drawing.Point(256, 24); this.label4.Name = "label4"; this.label4.Size = new System.Drawing.Size(100, 16); this.label4.TabIndex = 2; this.label4.Text = "传输端口："; // // textBox4 // this.textBox4.Location = new System.Drawing.Point(96, 16); this.textBox4.Name = "textBox4"; this.textBox4.ReadOnly = true; this.textBox4.Size = new System.Drawing.Size(144, 21); this.textBox4.TabIndex = 1; // // label3 // this.label3.Location = new System.Drawing.Point(16, 24); this.label3.Name = "label3"; this.label3.Size = new System.Drawing.Size(100, 16); this.label3.TabIndex = 0; this.label3.Text = "本机IP地址："; // // label5 // this.label5.Location = new System.Drawing.Point(24, 48); this.label5.Name = "label5"; this.label5.Size = new System.Drawing.Size(88, 16); this.label5.TabIndex = 2; this.label5.Text = "包的大小："; // // label9 // this.label9.Location = new System.Drawing.Point(176, 48); this.label9.Name = "label9"; this.label9.Size = new System.Drawing.Size(224, 16); this.label9.TabIndex = 2; this.label9.Text = "（范围：10000 - 60000 单位：字节）"; // // groupBox3 // this.groupBox3.Controls.Add(this.textBox8); this.groupBox3.Controls.Add(this.textBox9); this.groupBox3.Controls.Add(this.textBox7); this.groupBox3.Controls.Add(this.progressBar1); this.groupBox3.Controls.Add(this.label7); this.groupBox3.Controls.Add(this.label8); this.groupBox3.Controls.Add(this.label10); this.groupBox3.Controls.Add(this.label11); this.groupBox3.Controls.Add(this.label12); this.groupBox3.Controls.Add(this.textBox10); this.groupBox3.Location = new System.Drawing.Point(0, 168); this.groupBox3.Name = "groupBox3"; this.groupBox3.Size = new System.Drawing.Size(416, 168); this.groupBox3.TabIndex = 2; this.groupBox3.TabStop = false; this.groupBox3.Text = "状态信息"; // // textBox8 // this.textBox8.Location = new System.Drawing.Point(120, 40); this.textBox8.Name = "textBox8"; this.textBox8.ReadOnly = true; this.textBox8.Size = new System.Drawing.Size(160, 21); this.textBox8.TabIndex = 1; // // textBox9 // this.textBox9.Location = new System.Drawing.Point(120, 64); this.textBox9.Name = "textBox9"; this.textBox9.ReadOnly = true; this.textBox9.Size = new System.Drawing.Size(80, 21); this.textBox9.TabIndex = 1; // // textBox7 // this.textBox7.Location = new System.Drawing.Point(120, 16); this.textBox7.Name = "textBox7"; this.textBox7.ReadOnly = true; this.textBox7.Size = new System.Drawing.Size(160, 21); this.textBox7.TabIndex = 1; // // progressBar1 // this.progressBar1.Location = new System.Drawing.Point(8, 136); this.progressBar1.Name = "progressBar1"; this.progressBar1.Size = new System.Drawing.Size(400, 23); this.progressBar1.Step = 1; this.progressBar1.TabIndex = 3; // // label7 // this.label7.Location = new System.Drawing.Point(32, 24); this.label7.Name = "label7"; this.label7.Size = new System.Drawing.Size(96, 16); this.label7.TabIndex = 2; this.label7.Text = "接收端IP地址："; // // label8 // this.label8.Location = new System.Drawing.Point(40, 48); this.label8.Name = "label8"; this.label8.Size = new System.Drawing.Size(80, 16); this.label8.TabIndex = 2; this.label8.Text = "包的总数量："; // // label10 // this.label10.Location = new System.Drawing.Point(8, 72); this.label10.Name = "label10"; this.label10.Size = new System.Drawing.Size(120, 16); this.label10.TabIndex = 2; this.label10.Text = "最后一个包的大小："; // // label11 // this.label11.Location = new System.Drawing.Point(200, 72); this.label11.Name = "label11"; this.label11.Size = new System.Drawing.Size(96, 16); this.label11.TabIndex = 2; this.label11.Text = "（单位：字节）"; // // label12 // this.label12.Location = new System.Drawing.Point(16, 96); this.label12.Name = "label12"; this.label12.Size = new System.Drawing.Size(104, 16); this.label12.TabIndex = 2; this.label12.Text = "已发送包的数量："; // // textBox10 // this.textBox10.Location = new System.Drawing.Point(120, 88); this.textBox10.Name = "textBox10"; this.textBox10.ReadOnly = true; this.textBox10.Size = new System.Drawing.Size(80, 21); this.textBox10.TabIndex = 1; // // groupBox4 // this.groupBox4.Controls.Add(this.button2); this.groupBox4.Location = new System.Drawing.Point(0, 336); this.groupBox4.Name = "groupBox4"; this.groupBox4.Size = new System.Drawing.Size(416, 48); this.groupBox4.TabIndex = 3; this.groupBox4.TabStop = false; this.groupBox4.Text = "系统控制"; // // button2 // this.button2.Location = new System.Drawing.Point(16, 16); this.button2.Name = "button2"; this.button2.Size = new System.Drawing.Size(75, 23); this.button2.TabIndex = 0; this.button2.Text = "开始发送"; this.button2.Click += new System.EventHandler(this.button2_Click); // // Form1 // this.AutoScaleBaseSize = new System.Drawing.Size(6, 14); this.ClientSize = new System.Drawing.Size(416, 389); this.Controls.Add(this.groupBox4); this.Controls.Add(this.groupBox3); this.Controls.Add(this.groupBox2); this.Controls.Add(this.groupBox1); this.FormBorderStyle = System.Windows.Forms.FormBorderStyle.FixedSingle; this.MaximizeBox = false; this.Name = "Form1"; this.Text = "点对点文件传输软体发送端"; this.Load += new System.EventHandler(this.EzoneSend_Load); this.groupBox1.ResumeLayout(false); this.groupBox1.PerformLayout(); this.groupBox2.ResumeLayout(false); this.groupBox2.PerformLayout(); this.groupBox3.ResumeLayout(false); this.groupBox3.PerformLayout(); this.groupBox4.ResumeLayout(false); this.ResumeLayout(false); } #endregion /// <summary> /// 应用程序的主入口点。 /// </summary> [STAThread] static void Main() { Application.Run(new Form1()); } private void button1_Click(object sender, System.EventArgs e) { //选择要进行传输的文件 if(this.openFileDialog1.ShowDialog()==DialogResult.OK) { FileInfo EzoneFile=new FileInfo(this.openFileDialog1.FileName); this.textBox1.Text=EzoneFile.FullName; this.textBox2.Text=EzoneFile.Name; this.textBox3.Text=EzoneFile.Length.ToString(); } } private void StartSend() { //创建一个文件对象 FileInfo EzoneFile=new FileInfo(this.textBox1.Text); //打开文件流 FileStream EzoneStream=EzoneFile.OpenRead(); //包的大小 int PacketSize=int.Parse(this.textBox6.Text); //包的数量 int PacketCount=(int)(EzoneStream.Length/((long)PacketSize)); this.textBox8.Text=PacketCount.ToString(); this.progressBar1.Maximum=PacketCount; //最后一个包的大小 int LastDataPacket=(int)(EzoneStream.Length-((long)(PacketSize*PacketCount))); this.textBox9.Text=LastDataPacket.ToString(); 创建一个网络端点 //IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("192.168.1.136"), int.Parse(this.textBox5.Text)); MessageBox.Show(IPAddress.Any); 创建一个套接字 //Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //MessageBox.Show(server.ToString()); //指向远程服务端节点 IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("192.168.1.136"), int.Parse(this.textBox5.Text)); //创建套接字 Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //连接到发送端 client.Connect(ipep); 绑定套接字到端口 //client.Bind(ipep); //MessageBox.Show(ipep.ToString()); 开始侦听(并堵塞该线程) //server.Listen(10); //确认连接 //Socket client = server.Accept(); //MessageBox.Show(client.ToString()); //获得客户端节点对象 IPEndPoint clientep=(IPEndPoint)client.RemoteEndPoint; //获得客户端的IP地址 //this.textBox7.Text=clientep.Address.ToString(); //发送[文件名]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(EzoneFile.Name)); //发送[包的大小]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(PacketSize.ToString())); //发送[包的总数量]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(PacketCount.ToString())); //发送[最后一个包的大小]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(LastDataPacket.ToString())); //数据包 byte[] data=new byte[PacketSize]; //开始循环发送数据包 for(int i=0;i<PacketCount;i++) { //从文件流读取数据并填充数据包 EzoneStream.Read(data,0,data.Length); //发送数据包 CommonModule.EzoneModule.SendVarData(client,data); //显示发送数据包的个数 this.textBox10.Text=((int)(i+1)).ToString(); //进度条值的显示 this.progressBar1.PerformStep(); } //如果还有多余的数据包,则应该发送完毕! if(LastDataPacket!=0) { data=new byte[LastDataPacket]; EzoneStream.Read(data,0,data.Length); CommonModule.EzoneModule.SendVarData(client,data); this.progressBar1.Value=this.progressBar1.Maximum; } //关闭套接字 client.Close(); //server.Close(); //关闭文件流 EzoneStream.Close(); this.button2.Enabled=true; MessageBox.Show("文件传输完毕!"); } private void button2_Click(object sender, System.EventArgs e) { //开启文件传输子线程 Thread TempThread=new Thread(new ThreadStart(this.StartSend)); TempThread.Start(); this.button2.Enabled=false; } private void EzoneSend_Load(object sender, System.EventArgs e) { //获得本机的IP地址 this.textBox4.Text=Dns.GetHostByName(Dns.GetHostName()).AddressList[0].ToString(); } } } //title: 点对点文件传输程序 // //Begin-发送端// using System; using System.Drawing; using System.Collections; using System.ComponentModel; using System.Windows.Forms; using System.Data; using System.IO; using System.Net; using System.Net.Sockets; using System.Threading; namespace 发送端 { /// <summary> /// Form1 的摘要说明。 /// </summary> public class Form1 : System.Windows.Forms.Form { private System.Windows.Forms.GroupBox groupBox1; private System.Windows.Forms.OpenFileDialog openFileDialog1; private System.Windows.Forms.TextBox textBox1; private System.Windows.Forms.Button button1; private System.Windows.Forms.Label label1; private System.Windows.Forms.TextBox textBox2; private System.Windows.Forms.Label label2; private System.Windows.Forms.TextBox textBox3; private System.Windows.Forms.GroupBox groupBox2; private System.Windows.Forms.Label label3; private System.Windows.Forms.TextBox textBox4; private System.Windows.Forms.Label label4; private System.Windows.Forms.TextBox textBox5; private System.Windows.Forms.GroupBox groupBox3; private System.Windows.Forms.GroupBox groupBox4; private System.Windows.Forms.Button button2; private System.Windows.Forms.Label label5; private System.Windows.Forms.TextBox textBox6; private System.Windows.Forms.Label label6; private System.Windows.Forms.Label label7; private System.Windows.Forms.ProgressBar progressBar1; private System.Windows.Forms.TextBox textBox7; private System.Windows.Forms.Label label8; private System.Windows.Forms.Label label9; private System.Windows.Forms.TextBox textBox8; private System.Windows.Forms.Label label10; private System.Windows.Forms.TextBox textBox9; private System.Windows.Forms.Label label11; private System.Windows.Forms.Label label12; private System.Windows.Forms.TextBox textBox10; /// <summary> /// 必需的设计器变量。 /// </summary> private System.ComponentModel.Container components = null; public Form1() { // // Windows 窗体设计器支持所必需的 // InitializeComponent(); // // TODO: 在 InitializeComponent 调用后添加任何构造函数代码 // } /// <summary> /// 清理所有正在使用的资源。 /// </summary> protected override void Dispose( bool disposing ) { if( disposing ) { if (components != null) { components.Dispose(); } } base.Dispose( disposing ); } #region Windows 窗体设计器生成的代码 /// <summary> /// 设计器支持所需的方法 - 不要使用代码编辑器修改 /// 此方法的内容。 /// </summary> private void InitializeComponent() { this.groupBox1 = new System.Windows.Forms.GroupBox(); this.textBox2 = new System.Windows.Forms.TextBox(); this.textBox3 = new System.Windows.Forms.TextBox(); this.label2 = new System.Windows.Forms.Label(); this.label1 = new System.Windows.Forms.Label(); this.button1 = new System.Windows.Forms.Button(); this.textBox1 = new System.Windows.Forms.TextBox(); this.label6 = new System.Windows.Forms.Label(); this.openFileDialog1 = new System.Windows.Forms.OpenFileDialog(); this.groupBox2 = new System.Windows.Forms.GroupBox(); this.textBox6 = new System.Windows.Forms.TextBox(); this.textBox5 = new System.Windows.Forms.TextBox(); this.label4 = new System.Windows.Forms.Label(); this.textBox4 = new System.Windows.Forms.TextBox(); this.label3 = new System.Windows.Forms.Label(); this.label5 = new System.Windows.Forms.Label(); this.label9 = new System.Windows.Forms.Label(); this.groupBox3 = new System.Windows.Forms.GroupBox(); this.textBox8 = new System.Windows.Forms.TextBox(); this.textBox9 = new System.Windows.Forms.TextBox(); this.textBox7 = new System.Windows.Forms.TextBox(); this.progressBar1 = new System.Windows.Forms.ProgressBar(); this.label7 = new System.Windows.Forms.Label(); this.label8 = new System.Windows.Forms.Label(); this.label10 = new System.Windows.Forms.Label(); this.label11 = new System.Windows.Forms.Label(); this.label12 = new System.Windows.Forms.Label(); this.textBox10 = new System.Windows.Forms.TextBox(); this.groupBox4 = new System.Windows.Forms.GroupBox(); this.button2 = new System.Windows.Forms.Button(); this.groupBox1.SuspendLayout(); this.groupBox2.SuspendLayout(); this.groupBox3.SuspendLayout(); this.groupBox4.SuspendLayout(); this.SuspendLayout(); // // groupBox1 // this.groupBox1.Controls.Add(this.textBox2); this.groupBox1.Controls.Add(this.textBox3); this.groupBox1.Controls.Add(this.label2); this.groupBox1.Controls.Add(this.label1); this.groupBox1.Controls.Add(this.button1); this.groupBox1.Controls.Add(this.textBox1); this.groupBox1.Controls.Add(this.label6); this.groupBox1.Location = new System.Drawing.Point(0, 0); this.groupBox1.Name = "groupBox1"; this.groupBox1.Size = new System.Drawing.Size(416, 96); this.groupBox1.TabIndex = 0; this.groupBox1.TabStop = false; this.groupBox1.Text = "文件信息"; // // textBox2 // this.textBox2.Location = new System.Drawing.Point(80, 40); this.textBox2.Name = "textBox2"; this.textBox2.ReadOnly = true; this.textBox2.Size = new System.Drawing.Size(232, 21); this.textBox2.TabIndex = 3; // // textBox3 // this.textBox3.Location = new System.Drawing.Point(80, 64); this.textBox3.Name = "textBox3"; this.textBox3.ReadOnly = true; this.textBox3.Size = new System.Drawing.Size(136, 21); this.textBox3.TabIndex = 3; // // label2 // this.label2.Location = new System.Drawing.Point(8, 72); this.label2.Name = "label2"; this.label2.Size = new System.Drawing.Size(100, 16); this.label2.TabIndex = 4; this.label2.Text = "文件大小："; // // label1 // this.label1.Location = new System.Drawing.Point(16, 48); this.label1.Name = "label1"; this.label1.Size = new System.Drawing.Size(96, 16); this.label1.TabIndex = 2; this.label1.Text = "文件名："; // // button1 // this.button1.Location = new System.Drawing.Point(320, 16); this.button1.Name = "button1"; this.button1.Size = new System.Drawing.Size(88, 23); this.button1.TabIndex = 1; this.button1.Text = "浏览"; this.button1.Click += new System.EventHandler(this.button1_Click); // // textBox1 // this.textBox1.Location = new System.Drawing.Point(8, 16); this.textBox1.Name = "textBox1"; this.textBox1.ReadOnly = true; this.textBox1.Size = new System.Drawing.Size(304, 21); this.textBox1.TabIndex = 0; // // label6 // this.label6.Location = new System.Drawing.Point(224, 72); this.label6.Name = "label6"; this.label6.Size = new System.Drawing.Size(96, 16); this.label6.TabIndex = 2; this.label6.Text = "（单位：字节）"; // // openFileDialog1 // this.openFileDialog1.Filter = "所有文件|*.*"; // // groupBox2 // this.groupBox2.Controls.Add(this.textBox6); this.groupBox2.Controls.Add(this.textBox5); this.groupBox2.Controls.Add(this.label4); this.groupBox2.Controls.Add(this.textBox4); this.groupBox2.Controls.Add(this.label3); this.groupBox2.Controls.Add(this.label5); this.groupBox2.Controls.Add(this.label9); this.groupBox2.Location = new System.Drawing.Point(0, 96); this.groupBox2.Name = "groupBox2"; this.groupBox2.Size = new System.Drawing.Size(416, 72); this.groupBox2.TabIndex = 1; this.groupBox2.TabStop = false; this.groupBox2.Text = "系统设置"; // // textBox6 // this.textBox6.Location = new System.Drawing.Point(96, 40); this.textBox6.Name = "textBox6"; this.textBox6.Size = new System.Drawing.Size(72, 21); this.textBox6.TabIndex = 3; this.textBox6.Text = "50000"; // // textBox5 // this.textBox5.Location = new System.Drawing.Point(320, 16); this.textBox5.Name = "textBox5"; this.textBox5.Size = new System.Drawing.Size(80, 21); this.textBox5.TabIndex = 3; this.textBox5.Text = "2005"; // // label4 // this.label4.Location = new System.Drawing.Point(256, 24); this.label4.Name = "label4"; this.label4.Size = new System.Drawing.Size(100, 16); this.label4.TabIndex = 2; this.label4.Text = "传输端口："; // // textBox4 // this.textBox4.Location = new System.Drawing.Point(96, 16); this.textBox4.Name = "textBox4"; this.textBox4.ReadOnly = true; this.textBox4.Size = new System.Drawing.Size(144, 21); this.textBox4.TabIndex = 1; // // label3 // this.label3.Location = new System.Drawing.Point(16, 24); this.label3.Name = "label3"; this.label3.Size = new System.Drawing.Size(100, 16); this.label3.TabIndex = 0; this.label3.Text = "本机IP地址："; // // label5 // this.label5.Location = new System.Drawing.Point(24, 48); this.label5.Name = "label5"; this.label5.Size = new System.Drawing.Size(88, 16); this.label5.TabIndex = 2; this.label5.Text = "包的大小："; // // label9 // this.label9.Location = new System.Drawing.Point(176, 48); this.label9.Name = "label9"; this.label9.Size = new System.Drawing.Size(224, 16); this.label9.TabIndex = 2; this.label9.Text = "（范围：10000 - 60000 单位：字节）"; // // groupBox3 // this.groupBox3.Controls.Add(this.textBox8); this.groupBox3.Controls.Add(this.textBox9); this.groupBox3.Controls.Add(this.textBox7); this.groupBox3.Controls.Add(this.progressBar1); this.groupBox3.Controls.Add(this.label7); this.groupBox3.Controls.Add(this.label8); this.groupBox3.Controls.Add(this.label10); this.groupBox3.Controls.Add(this.label11); this.groupBox3.Controls.Add(this.label12); this.groupBox3.Controls.Add(this.textBox10); this.groupBox3.Location = new System.Drawing.Point(0, 168); this.groupBox3.Name = "groupBox3"; this.groupBox3.Size = new System.Drawing.Size(416, 168); this.groupBox3.TabIndex = 2; this.groupBox3.TabStop = false; this.groupBox3.Text = "状态信息"; // // textBox8 // this.textBox8.Location = new System.Drawing.Point(120, 40); this.textBox8.Name = "textBox8"; this.textBox8.ReadOnly = true; this.textBox8.Size = new System.Drawing.Size(160, 21); this.textBox8.TabIndex = 1; // // textBox9 // this.textBox9.Location = new System.Drawing.Point(120, 64); this.textBox9.Name = "textBox9"; this.textBox9.ReadOnly = true; this.textBox9.Size = new System.Drawing.Size(80, 21); this.textBox9.TabIndex = 1; // // textBox7 // this.textBox7.Location = new System.Drawing.Point(120, 16); this.textBox7.Name = "textBox7"; this.textBox7.ReadOnly = true; this.textBox7.Size = new System.Drawing.Size(160, 21); this.textBox7.TabIndex = 1; // // progressBar1 // this.progressBar1.Location = new System.Drawing.Point(8, 136); this.progressBar1.Name = "progressBar1"; this.progressBar1.Size = new System.Drawing.Size(400, 23); this.progressBar1.Step = 1; this.progressBar1.TabIndex = 3; // // label7 // this.label7.Location = new System.Drawing.Point(32, 24); this.label7.Name = "label7"; this.label7.Size = new System.Drawing.Size(96, 16); this.label7.TabIndex = 2; this.label7.Text = "接收端IP地址："; // // label8 // this.label8.Location = new System.Drawing.Point(40, 48); this.label8.Name = "label8"; this.label8.Size = new System.Drawing.Size(80, 16); this.label8.TabIndex = 2; this.label8.Text = "包的总数量："; // // label10 // this.label10.Location = new System.Drawing.Point(8, 72); this.label10.Name = "label10"; this.label10.Size = new System.Drawing.Size(120, 16); this.label10.TabIndex = 2; this.label10.Text = "最后一个包的大小："; // // label11 // this.label11.Location = new System.Drawing.Point(200, 72); this.label11.Name = "label11"; this.label11.Size = new System.Drawing.Size(96, 16); this.label11.TabIndex = 2; this.label11.Text = "（单位：字节）"; // // label12 // this.label12.Location = new System.Drawing.Point(16, 96); this.label12.Name = "label12"; this.label12.Size = new System.Drawing.Size(104, 16); this.label12.TabIndex = 2; this.label12.Text = "已发送包的数量："; // // textBox10 // this.textBox10.Location = new System.Drawing.Point(120, 88); this.textBox10.Name = "textBox10"; this.textBox10.ReadOnly = true; this.textBox10.Size = new System.Drawing.Size(80, 21); this.textBox10.TabIndex = 1; // // groupBox4 // this.groupBox4.Controls.Add(this.button2); this.groupBox4.Location = new System.Drawing.Point(0, 336); this.groupBox4.Name = "groupBox4"; this.groupBox4.Size = new System.Drawing.Size(416, 48); this.groupBox4.TabIndex = 3; this.groupBox4.TabStop = false; this.groupBox4.Text = "系统控制"; // // button2 // this.button2.Location = new System.Drawing.Point(16, 16); this.button2.Name = "button2"; this.button2.Size = new System.Drawing.Size(75, 23); this.button2.TabIndex = 0; this.button2.Text = "开始发送"; this.button2.Click += new System.EventHandler(this.button2_Click); // // Form1 // this.AutoScaleBaseSize = new System.Drawing.Size(6, 14); this.ClientSize = new System.Drawing.Size(416, 389); this.Controls.Add(this.groupBox4); this.Controls.Add(this.groupBox3); this.Controls.Add(this.groupBox2); this.Controls.Add(this.groupBox1); this.FormBorderStyle = System.Windows.Forms.FormBorderStyle.FixedSingle; this.MaximizeBox = false; this.Name = "Form1"; this.Text = "点对点文件传输软体发送端"; this.Load += new System.EventHandler(this.EzoneSend_Load); this.groupBox1.ResumeLayout(false); this.groupBox1.PerformLayout(); this.groupBox2.ResumeLayout(false); this.groupBox2.PerformLayout(); this.groupBox3.ResumeLayout(false); this.groupBox3.PerformLayout(); this.groupBox4.ResumeLayout(false); this.ResumeLayout(false); } #endregion /// <summary> /// 应用程序的主入口点。 /// </summary> [STAThread] static void Main() { Application.Run(new Form1()); } private void button1_Click(object sender, System.EventArgs e) { //选择要进行传输的文件 if(this.openFileDialog1.ShowDialog()==DialogResult.OK) { FileInfo EzoneFile=new FileInfo(this.openFileDialog1.FileName); this.textBox1.Text=EzoneFile.FullName; this.textBox2.Text=EzoneFile.Name; this.textBox3.Text=EzoneFile.Length.ToString(); } } private void StartSend() { //创建一个文件对象 FileInfo EzoneFile=new FileInfo(this.textBox1.Text); //打开文件流 FileStream EzoneStream=EzoneFile.OpenRead(); //包的大小 int PacketSize=int.Parse(this.textBox6.Text); //包的数量 int PacketCount=(int)(EzoneStream.Length/((long)PacketSize)); this.textBox8.Text=PacketCount.ToString(); this.progressBar1.Maximum=PacketCount; //最后一个包的大小 int LastDataPacket=(int)(EzoneStream.Length-((long)(PacketSize*PacketCount))); this.textBox9.Text=LastDataPacket.ToString(); 创建一个网络端点 //IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("192.168.1.136"), int.Parse(this.textBox5.Text)); MessageBox.Show(IPAddress.Any); 创建一个套接字 //Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //MessageBox.Show(server.ToString()); //指向远程服务端节点 IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("192.168.1.136"), int.Parse(this.textBox5.Text)); //创建套接字 Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //连接到发送端 client.Connect(ipep); 绑定套接字到端口 //client.Bind(ipep); //MessageBox.Show(ipep.ToString()); 开始侦听(并堵塞该线程) //server.Listen(10); //确认连接 //Socket client = server.Accept(); //MessageBox.Show(client.ToString()); //获得客户端节点对象 IPEndPoint clientep=(IPEndPoint)client.RemoteEndPoint; //获得客户端的IP地址 //this.textBox7.Text=clientep.Address.ToString(); //发送[文件名]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(EzoneFile.Name)); //发送[包的大小]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(PacketSize.ToString())); //发送[包的总数量]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(PacketCount.ToString())); //发送[最后一个包的大小]到客户端 CommonModule.EzoneModule.SendVarData(client,System.Text.Encoding.Unicode.GetBytes(LastDataPacket.ToString())); //数据包 byte[] data=new byte[PacketSize]; //开始循环发送数据包 for(int i=0;i<PacketCount;i++) { //从文件流读取数据并填充数据包 EzoneStream.Read(data,0,data.Length); //发送数据包 CommonModule.EzoneModule.SendVarData(client,data); //显示发送数据包的个数 this.textBox10.Text=((int)(i+1)).ToString(); //进度条值的显示 this.progressBar1.PerformStep(); } //如果还有多余的数据包,则应该发送完毕! if(LastDataPacket!=0) { data=new byte[LastDataPacket]; EzoneStream.Read(data,0,data.Length); CommonModule.EzoneModule.SendVarData(client,data); this.progressBar1.Value=this.progressBar1.Maximum; } //关闭套接字 client.Close(); //server.Close(); //关闭文件流 EzoneStream.Close(); this.button2.Enabled=true; MessageBox.Show("文件传输完毕!"); } private void button2_Click(object sender, System.EventArgs e) { //开启文件传输子线程 Thread TempThread=new Thread(new ThreadStart(this.StartSend)); TempThread.Start(); this.button2.Enabled=false; } private void EzoneSend_Load(object sender, System.EventArgs e) { //获得本机的IP地址 this.textBox4.Text=Dns.GetHostByName(Dns.GetHostName()).AddressList[0].ToString(); } } } 公共类，服务端客户端都需要用到 C#代码 Begin-公共模块// using System; using System.Collections.Generic; using System.Text; using System.Net; using System.Net.Sockets; using System.Windows.Forms; namespace TestSocketServerHSTF { class TransferFiles { public TransferFiles() { // // TODO: 在此处添加构造函数逻辑 // } public static int SendData(Socket s, byte[] data) { int total = 0; int size = data.Length; int dataleft = size; int sent; while (total < size) { sent = s.Send(data, total, dataleft, SocketFlags.None); total += sent; dataleft -= sent; } return total; } public static byte[] ReceiveData(Socket s, int size) { int total = 0; int dataleft = size; byte[] data = new byte[size]; int recv; while (total < size) { recv = s.Receive(data, total, dataleft, SocketFlags.None); if (recv == 0) { data = null; break; } total += recv; dataleft -= recv; } return data; } public static int SendVarData(Socket s, byte[] data) { int total = 0; int size = data.Length; int dataleft = size; int sent; byte[] datasize = new byte[4]; datasize = BitConverter.GetBytes(size); sent = s.Send(datasize); while (total < size) { sent = s.Send(data, total, dataleft, SocketFlags.None); total += sent; dataleft -= sent; } return total; } public static byte[] ReceiveVarData(Socket s) { int total = 0; int recv; byte[] datasize = new byte[4]; recv = s.Receive(datasize, 0, 4, SocketFlags.None); int size = BitConverter.ToInt32(datasize, 0); int dataleft = size; byte[] data = new byte[size]; while (total < size) { recv = s.Receive(data, total, dataleft, SocketFlags.None); if (recv == 0) { data = null; break; } total += recv; dataleft -= recv; } return data; } } } /End-公共模块/// Begin-公共模块// using System; using System.Collections.Generic; using System.Text; using System.Net; using System.Net.Sockets; using System.Windows.Forms; namespace TestSocketServerHSTF { class TransferFiles { public TransferFiles() { // // TODO: 在此处添加构造函数逻辑 // } public static int SendData(Socket s, byte[] data) { int total = 0; int size = data.Length; int dataleft = size; int sent; while (total < size) { sent = s.Send(data, total, dataleft, SocketFlags.None); total += sent; dataleft -= sent; } return total; } public static byte[] ReceiveData(Socket s, int size) { int total = 0; int dataleft = size; byte[] data = new byte[size]; int recv; while (total < size) { recv = s.Receive(data, total, dataleft, SocketFlags.None); if (recv == 0) { data = null; break; } total += recv; dataleft -= recv; } return data; } public static int SendVarData(Socket s, byte[] data) { int total = 0; int size = data.Length; int dataleft = size; int sent; byte[] datasize = new byte[4]; datasize = BitConverter.GetBytes(size); sent = s.Send(datasize); while (total < size) { sent = s.Send(data, total, dataleft, SocketFlags.None); total += sent; dataleft -= sent; } return total; } public static byte[] ReceiveVarData(Socket s) { int total = 0; int recv; byte[] datasize = new byte[4]; recv = s.Receive(datasize, 0, 4, SocketFlags.None); int size = BitConverter.ToInt32(datasize, 0); int dataleft = size; byte[] data = new byte[size]; while (total < size) { recv = s.Receive(data, total, dataleft, SocketFlags.None); if (recv == 0) { data = null; break; } total += recv; dataleft -= recv; } return data; } } } /End-公共模块///