文件傳輸協(xié)議的簡(jiǎn)單設(shè)計(jì)與實(shí)現(xiàn)

1、課 程 設(shè) 計(jì) 課程名稱 計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì) 題目名稱 文件傳輸協(xié)議的簡(jiǎn)單設(shè)計(jì)與實(shí)現(xiàn) 學(xué)生學(xué)院 專業(yè)班級(jí)_ _ 學(xué) 號(hào) 學(xué)生姓名_ _指導(dǎo)教師_ _ 2010 年 1 月 5 日設(shè)計(jì)摘要關(guān)鍵詞：SOCKET編程，F(xiàn)TPclient/server程序摘要：本課程設(shè)計(jì)包含了文件傳輸協(xié)議的簡(jiǎn)單設(shè)計(jì)與實(shí)現(xiàn)。文件傳送是各種計(jì)算機(jī)網(wǎng)絡(luò)實(shí)現(xiàn)的基本功能，文件傳送協(xié)議是一種最基本的應(yīng)用層協(xié)議按照客戶/服務(wù)器的模式進(jìn)行工作，提供交互式的訪問，是INTERNET使用最廣泛的協(xié)議之一。文件傳輸協(xié)議的簡(jiǎn)單設(shè)計(jì)與實(shí)現(xiàn)建立在計(jì)算機(jī)網(wǎng)絡(luò)實(shí)驗(yàn)環(huán)境TCP/IP 網(wǎng)絡(luò)體系結(jié)構(gòu)之上，使用socket 編程接口編寫兩個(gè)程序，分別為客戶

2、程序(client.c)和服務(wù)器程序（server.c），實(shí)現(xiàn)下述命令功能：get , put, pwd, dir, cd, ？, quit 等，利用了已有網(wǎng)絡(luò)環(huán)境設(shè)計(jì)并實(shí)現(xiàn)簡(jiǎn)單應(yīng)用層協(xié)議。本設(shè)計(jì)包括了具體設(shè)計(jì)任務(wù)，基本思路及所涉及的相關(guān)理論，設(shè)計(jì)流程圖，調(diào)試過程中出現(xiàn)的問題及相應(yīng)解決辦法，實(shí)驗(yàn)運(yùn)行結(jié)果，核心程序，個(gè)人體會(huì)及建議等。目錄1、文件傳輸協(xié)議的簡(jiǎn)單設(shè)計(jì)與實(shí)現(xiàn)-181. 1 具體設(shè)計(jì)任務(wù)-181.2 基本思路及所涉及的相關(guān)理論-181.2.1基本思路-182.2.2 相關(guān)理論-181.3設(shè)計(jì)流程圖-191.4實(shí)驗(yàn)運(yùn)行情況-191.5 核心程序-22 2.5.1 服務(wù)器（sever）程序

3、-22 2.5.2 客戶（client）程序-291.6心得體會(huì)-37參考文獻(xiàn)-382、文件傳輸協(xié)議的簡(jiǎn)單設(shè)計(jì)與實(shí)現(xiàn)2. 1 具體設(shè)計(jì)任務(wù)計(jì)算機(jī)網(wǎng)絡(luò)實(shí)驗(yàn)環(huán)境建立在TCP/IP 網(wǎng)絡(luò)體系結(jié)構(gòu)之上。各計(jì)算機(jī)除了安裝TCP/IP 軟件外，還安裝了TCP/IP 開發(fā)系統(tǒng)。實(shí)驗(yàn)室各計(jì)算機(jī)具備Windows環(huán)境中套接字socket 的編程接口功能，可為用戶提供全網(wǎng)范圍的進(jìn)程通信功能。本實(shí)驗(yàn)要求利用這些功能，設(shè)計(jì)和實(shí)現(xiàn)一個(gè)簡(jiǎn)單的文件傳送協(xié)議。用socket 編程接口編寫兩個(gè)程序，分別為客戶程序(client.c)和服務(wù)器程序（server.c），該程序應(yīng)能實(shí)現(xiàn)下述命令功能：get：取遠(yuǎn)方的一個(gè)文件put：傳

4、給遠(yuǎn)方一個(gè)文件pwd：顯示遠(yuǎn)主當(dāng)前目錄dir：列出遠(yuǎn)方當(dāng)前目錄cd ：改變遠(yuǎn)方當(dāng)前目錄？ ：顯示你提供的命令quit ：退出返回2.2基本思路及所涉及的相關(guān)理論2.2.1基本思路 設(shè)計(jì)程序使客戶端連接的時(shí)候，服務(wù)器將會(huì)向客戶端發(fā)回一條消息告知它的IP地址，然后關(guān)閉連接并繼續(xù)接收端口的連接。建立各個(gè)命令功能對(duì)應(yīng)的函數(shù)，發(fā)送請(qǐng)求，等待服務(wù)器端的服務(wù)。服務(wù)器端初始化WinSock，創(chuàng)建SOCKET，獲取主機(jī)信息，并對(duì)客戶端進(jìn)行會(huì)話，發(fā)送回復(fù)訊息給客戶端，響應(yīng)完畢后關(guān)閉連接，釋放WinSock。2.2.2 相關(guān)理論 文件傳送是各種計(jì)算機(jī)網(wǎng)絡(luò)都實(shí)現(xiàn)的基本功能，文件傳送協(xié)議是一種最基本的應(yīng)用層協(xié)議按照客戶

5、/服務(wù)器的模式進(jìn)行工作，提供交互式的訪問，是INTERNET使用最廣泛的協(xié)議之一。計(jì)算機(jī)網(wǎng)絡(luò)實(shí)驗(yàn)環(huán)境建立在TCP/IP 網(wǎng)絡(luò)體系結(jié)構(gòu)之上。各計(jì)算機(jī)除了安裝TCP/IP 軟件外，還安裝了TCP/IP 開發(fā)系統(tǒng)。實(shí)驗(yàn)室各計(jì)算機(jī)具備Windows環(huán)境中套接字socket 的編程接口功能，可為用戶提供全網(wǎng)范圍的進(jìn)程通信功能。本設(shè)計(jì)利用這些功能，設(shè)計(jì)和實(shí)現(xiàn)一個(gè)簡(jiǎn)單的文件傳送協(xié)議。用socket 編程接口編寫兩個(gè)程序，分別為客戶程序(client.c)和服務(wù)器程序（server.c）。2.3 設(shè)計(jì)流程圖2.4實(shí)驗(yàn)運(yùn)行情況服務(wù)器端運(yùn)行，默認(rèn)自動(dòng)啟動(dòng)監(jiān)聽，情況如下圖：服務(wù)如果關(guān)閉監(jiān)聽，效果如下圖：客服端運(yùn)行，

6、如下圖：輸入服務(wù)器端的IP和端口號(hào)進(jìn)行連接，效果如圖：下面設(shè)置文件保存位置，如圖：下面演示上傳一個(gè)視頻文件，然后再下載下來，其中上傳過程的進(jìn)度信息：上傳完成后的效果圖：下載文件的進(jìn)度提示信息：下載完成后，指定目錄下就有了該文件了：2.5 核心程序2.5.1 服務(wù)器（server）程序如下using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Net;using System.Net.Sockets;using Sys

7、tem.IO;using System.Windows.Forms;namespace TCP文件傳輸_服務(wù)器 class WorkThread byte buffer; int bufferSize= 4096; Thread mythread; Socket handler; public WorkThread(Socket workSocket) handler = workSocket; buffer = new bytebufferSize; mythread = new Thread(BeginCommunication); public void Start() mythread

8、.Start(); public void Abort() mythread.Abort(); private void BeginCommunication() while (true)/從客戶端接收數(shù)據(jù),直到連接斷開 try int reCount = handler.Receive(buffer); string insStr =Encoding.BigEndianUnicode.GetString(buffer, 0, reCount); if (insStr.Substring(0, 4) = "name")/收到下文件請(qǐng)求 string fileName = i

9、nsStr.Substring(5, insStr.Length - 5); SendFile(fileName, handler); else if (insStr.Substring(0, 4) = "boot")/收到獲取根目錄請(qǐng)求 string listStr = GetFileNames("F:", false); SendString(handler, listStr); else if (insStr.Substring(0, 4) = "path")/收到獲取指定目錄內(nèi)容請(qǐng)求 string path = insStr.

10、Substring(5, insStr.Length - 5); string listStr = GetFileNames(path, false); SendString(handler, listStr); else if (insStr.Substring(0, 4) = "Queu")/獲取下載文件夾請(qǐng)求,回復(fù)完整文件名列表 string path = insStr.Substring(5, insStr.Length - 5); string listStr = GetFileNames(path, true); SendString(handler, list

11、Str); else if (insStr.Substring(0, 4) = "upld")/收到上傳文件請(qǐng)求 string reFileName = insStr.Substring(5, insStr.Length - 5); LoadFile(reFileName, handler); else if (insStr.Substring(0, 4) = "quit")/收到斷開連接命令 HostQuit(); break; catch HostQuit();break; private void LoadFile(string reFileNam

12、e, Socket handler) try FileStream fs = new FileStream(reFileName, FileMode.Create, FileAccess.Write); handler.Receive(buffer, 8, SocketFlags.None);/接收文件大小 long filesize = BitConverter.ToInt64(buffer, 0); long receiveCount = 0; while (receiveCount < filesize)/接收文件 int readcount = handler.Receive(b

13、uffer, bufferSize, SocketFlags.None); fs.Write(buffer, 0, readcount); receiveCount += readcount; fs.Close(); catch HostQuit(); private void SendFile(string fileNmae, Socket handler) try FileStream fs = new FileStream(fileNmae, FileMode.Open, FileAccess.Read); long size = fs.Length; byte bysize = Bit

14、Converter.GetBytes(size); handler.Send(bysize, 8, SocketFlags.None);/發(fā)送文件大小 BinaryReader br = new BinaryReader(fs); int sendcount = 0; while (sendcount < size)/發(fā)送文件 int readcount = br.Read(buffer, 0, bufferSize); sendcount += readcount; handler.Send(buffer, readcount, SocketFlags.None); catch Hos

15、tQuit(); private void HostQuit() GlobalValues.canControl.WaitOne(); GlobalValues.canControl.Release(); if (handler.Connected = true) handler.Shutdown(SocketShutdown.Both); handler.Close(); private void SendString(Socket handler,string listStr) byte list = Encoding.BigEndianUnicode.GetBytes(listStr);

16、 byte listcountbuffer = BitConverter.GetBytes(Convert.ToInt64(list.Length); try handler.Send(listcountbuffer, 8, SocketFlags.None);/發(fā)送列表大小 int sendcount = 0; while (sendcount < list.Length)/發(fā)送列表 if (sendcount + bufferSize < list.Length)/不是最后一次 int i = handler.Send(list, sendcount, bufferSize,

17、SocketFlags.None); sendcount += i; else int i = handler.Send(list, sendcount, list.Length - sendcount, SocketFlags.None);/發(fā)送最后一次 sendcount += i; catch (Exception e) MessageBox.Show("連接斷開."); /fileOnly=true則獲取指定目錄及子目錄內(nèi)所有文件信息,fileOnly=false則獲取指定目錄文件信息及文件夾信息 private string GetFileNames(string

18、 path, bool fileOnly) string listStr = string.Empty; DirectoryInfo drct = new DirectoryInfo(path); foreach (FileSystemInfo fsi in drct.GetFileSystemInfos() if (fsi is FileInfo) /文件 FileInfo fi = (FileInfo)fsi; listStr += fi.FullName; listStr += "n" if (fi.Length < 1024) string sizeStr =

19、 fi.Length.ToString() + "字節(jié)" listStr += sizeStr; else if (fi.Length < 1024 * 1024) double temp = Convert.ToDouble(fi.Length) / 1024; string sizeStr = string.Format("0:F1", temp) + "KB" listStr += sizeStr; else if (fi.Length < 1024 * 1024 * 1024) double temp = Conv

20、ert.ToDouble(fi.Length) / 1024 / 1024; string sizeStr = string.Format("0:F1", temp) + "MB" listStr += sizeStr; else double temp = Convert.ToDouble(fi.Length) / 1024 / 1024 / 1024; string sizeStr = string.Format("0:F1", temp) + "GB" listStr += sizeStr; listStr

21、+= "n" listStr += fi.LastWriteTime.ToString("yyyy-MM-dd hh:mm:ss"); listStr += "n" else if (fsi is DirectoryInfo) if (fileOnly) listStr += GetFileNames(fsi.FullName, true); else /文件夾 DirectoryInfo di = (DirectoryInfo)fsi; listStr += di.FullName; listStr += "n"

22、 listStr += "dir" listStr += "n" listStr += di.LastWriteTime.ToString("yyyy-MM-dd hh:mm:ss"); listStr += "n" return listStr; public 服務(wù)器() InitializeComponent(); Control.CheckForIllegalCrossThreadCalls = false; string HostName = Dns.GetHostName(); /得到主機(jī)名 IPHost

23、Entry IpEntry = Dns.GetHostEntry(HostName); /得到主機(jī)IP string strIPAddr = IpEntry.AddressList0.ToString(); tsTxb_IPAdd.Text = strIPAddr; hostIPAddress = IPAddress.Parse(strIPAddr); Server = new IPEndPoint(hostIPAddress,Convert.ToInt32(tsTxb_Port.Text); sock = new Socket(AddressFamily.InterNetwork, Sock

24、etType.Stream, ProtocolType.Tcp); sock.Bind(Server); sock.Listen(10); string str = "正在監(jiān)聽端口 " + tsTxb_Port.Text + "." tsLbl_Status.Text = "狀態(tài):" + str; AcceptTh = new Thread(ThAccept); AcceptTh.Start();/開始監(jiān)聽端口/下面是監(jiān)聽和停止監(jiān)聽的按鈕事件private void btn_Start_Click(object sender, Eve

25、ntArgs e) tsBtn_Start.Enabled = false; tsBtn_Stop.Enabled = true; Server = new IPEndPoint(hostIPAddress, Convert.ToInt32(tsTxb_Port.Text); sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); sock.Bind(Server); sock.Listen(10); string str = "正在監(jiān)聽端口 " + tsTxb_

26、Port.Text + "." tsLbl_Status.Text = "狀態(tài):" + str; AcceptTh = new Thread(ThAccept); AcceptTh.Start(); private void btn_stop_Click(object sender, EventArgs e) tsBtn_Start.Enabled = true; tsBtn_Stop.Enabled = false; try sock.Shutdown(SocketShutdown.Both); catch sock.Close(); tsLbl_St

27、atus.Text = "狀態(tài):已停止監(jiān)聽" 2.5.2 客戶（client）程序/MyThread.cs中的實(shí)現(xiàn)using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.IO;using System.Net.Sockets;using System.Threading;using System.Windows.Forms;namespace 客戶端_TCP文件傳輸 public class myThread Thread downloadT

28、h; Thread uploadTh; Socket wordSocket; string fileName; string savePath; byte buffer; const int bufferSize = 4096; ToolStripProgressBar tspBar; ToolStripStatusLabel speed; int startTime=0; long receivecount = 0; long sendCount = 0; int upOrDown = 1;/指示上傳或下載 System.Windows.Forms.Timer timer1 = new Sy

29、stem.Windows.Forms.Timer(); public myThread(Socket workSock, string FileName,string SavePath, ref ToolStripProgressBar TspBar, ref ToolStripStatusLabel Speed) wordSocket = workSock; fileName = FileName; savePath = SavePath; buffer = new bytebufferSize; downloadTh = new Thread(new ThreadStart(Downloa

30、d); uploadTh = new Thread(new ThreadStart(Upload); tspBar = TspBar; speed = Speed; public myThread(Socket workSock, string FileName,ref ToolStripProgressBar TspBar, ref ToolStripStatusLabel Speed) wordSocket = workSock; fileName = FileName; buffer = new bytebufferSize; downloadTh = new Thread(new Th

31、readStart(Download); uploadTh = new Thread(new ThreadStart(Upload); tspBar = TspBar; speed = Speed; public void StartDownload() upOrDown = 1; downloadTh.Start(); timer1.Enabled = true; timer1.Interval = 100; timer1.Tick += new EventHandler(timer1_Tick); startTime = System.Environment.TickCount; time

32、r1.Start(); public void StartUpload() upOrDown = 0; uploadTh.Start(); timer1.Enabled = true; timer1.Interval = 50; timer1.Tick += new EventHandler(timer1_Tick); startTime = System.Environment.TickCount; timer1.Start(); void timer1_Tick(object sender, EventArgs e) int spentTime = System.Environment.T

33、ickCount - startTime; if (spentTime != 0) if (upOrDown = 1) double sp = Convert.ToDouble(receivecount) / Convert.ToDouble(spentTime) * 1000 / 1024; if (sp < 1024) speed.Text = tspBar.Value.ToString() + "% 下載速度:" + string.Format("0:F1", sp) + "KB" else speed.Text = ts

34、pBar.Value.ToString() + "% 下載速度:" + string.Format("0:F1", sp / 1024) + "MB/S" else double sp = Convert.ToDouble(sendCount) / Convert.ToDouble(spentTime) * 1000 / 1024; if (sp < 1024) speed.Text = tspBar.Value.ToString() + "% 上傳速度:" + string.Format("0:F

35、1", sp) + "KB" else speed.Text = tspBar.Value.ToString() + "% 上傳速度:" + string.Format("0:F1", sp / 1024) + "MB/S" private void Download() try string ins = "name=" + fileName; byte data = Encoding.BigEndianUnicode.GetBytes(ins); wordSocket.Send(da

36、ta, data.Length, SocketFlags.None);/發(fā)送下載請(qǐng)求 string reFileName = savePath + "" + GetFileName(fileName); Directory.CreateDirectory(savePath); FileStream fs = new FileStream(reFileName, FileMode.Create, FileAccess.Write); wordSocket.Receive(buffer, 8, SocketFlags.None);/接收文件大小 long filesize =

37、BitConverter.ToInt64(buffer, 0); while (receivecount < filesize)/接收文件 int readcount = wordSocket.Receive(buffer, bufferSize, SocketFlags.None); fs.Write(buffer, 0, readcount); receivecount += readcount; tspBar.Value = Convert.ToInt32(Convert.ToDouble(receivecount) / Convert.ToDouble(filesize) * 1

38、00); tspBar.Value = 100; timer1_Tick(new object(), new EventArgs(); fs.Close(); timer1.Stop(); StaticValue.isBusy = false; catch MessageBox.Show("連接斷開."); timer1.Stop(); if (wordSocket.Connected = true) wordSocket.Shutdown(SocketShutdown.Both); wordSocket.Close(); timer1.Stop(); StaticValue.isBusy = false; private void Upload() try string shortFileName = fileName.Substring(fileName.LastIndexOf('') + 1, fileName.Length - fileName.LastIndexOf('') - 1); string serverFileName = StaticValue.curServerPath + "" + shortFi