【文章內(nèi)容簡(jiǎn)介】 { (請(qǐng)選擇文件！ )。 return。 } string Path = 。 Thread SendFile = new Thread(StartSend)。 ()。 } //發(fā)送文件函數(shù) Socket client。 public void StartSend(Object Path) { string file = (string)()。 string message = null。 try { //指向遠(yuǎn)程服務(wù)端節(jié)點(diǎn) IPEndPoint ipep = new IPEndPoint(SendIP, myport1)。 //創(chuàng)建套接字 client = new Socket(, , )。 //連接到發(fā)送端 (ipep)。 //獲得客戶端節(jié)點(diǎn)對(duì)象 IPEndPoint clientep = (IPEndPoint)。 FileInfo EzoneFile = new FileInfo(file)。 //打開(kāi)文件流 FileStream EzoneStream = ()。 //包的大小 int PacketSize = 10000。 //包的數(shù)量 int PacketCount = (int)( / ((long)PacketSize))。 //最后一個(gè)包的大小 int LastDataPacket = (int)( ((long)(PacketSize * PacketCount)))。 //發(fā)送 [文件名 ]到客戶端 string path = C:\\Temp\\ + 。 (client, (path))。 //數(shù)據(jù)包 byte[] data = new byte[PacketSize]。 //開(kāi)始循環(huán)發(fā)送數(shù)據(jù)包 16 for (int i = 0。 i PacketCount。 i++) { //從文件流讀取數(shù)據(jù)并填充數(shù)據(jù)包 (data, 0, )。 //發(fā)送數(shù)據(jù)包 (client, data)。 } //如果還有多余的數(shù)據(jù)包 ,則應(yīng)該發(fā)送完畢 ! if (LastDataPacket != 0) { data = new byte[LastDataPacket]。 (data, 0, )。 (client, data)。 } ()。 ()。 } catch { (遠(yuǎn)程主機(jī)未開(kāi)啟！ )。 } //關(guān)閉文件流 ()。 message = () + : 文件發(fā)送完畢 \n。 AddMessage(message)。 } private void button1_Click(object sender, EventArgs e) { string Message = 。 ()。 AddMessage(我 : + Message+\n)。 try { (client1, (Message))。 } catch { (請(qǐng)開(kāi)啟服務(wù)！ )。 } } private void ST_Click(object sender, EventArgs e) { ()。 17 if ( == 啟動(dòng)服務(wù) ) { try { SendIP = ()。 } catch { (IP地址有錯(cuò)誤！ )。 return。 } try { //指向遠(yuǎn)程服務(wù)端節(jié)點(diǎn) IPEndPoint ipep = new IPEndPoint(SendIP, myport2)。 //創(chuàng)建套接字 client1 = new Socket(, , )。 //連接到發(fā)送端 (ipep)。 } catch { (遠(yuǎn)程主機(jī)未開(kāi)啟 )。 } //建立消息監(jiān)聽(tīng)線程 Listen2 = new Thread(ListenMessage)。 ()。 Listen1 = new Thread(ListenFile)。 ()。 = 關(guān)閉服務(wù) 。 } else { = 啟動(dòng)服務(wù) 。 } } //監(jiān)聽(tīng)文件接收端 private void ListenFile() { IPAddress myIP = (())[0]。 ServerFileSocket = new Socket(, , )。 (new IPEndPoint(myIP, 2052))。 18 (10)。 //等待客戶鏈接 while (Flag == true) { Socket client = ()。 message = () + : 客戶端 : + () + 接入 \n。 AddMessage(message)。 Thread rec = new Thread(ReceiveFile)。 (client)。 } } /// summary /// 接收文件的函數(shù) /// /summary /// param name=Myclient/param public void ReceiveFile(Object Myclient) { Socket client = (Socket)Myclient。 //獲得 [文件名 ] string SendFileName = ((client))。 //創(chuàng)建目錄 string Path = (0, (\\) + 1)。 if (!(@Path)) (@Path)。 else { (@Path, true)。 (@Path)。 } //創(chuàng)建一個(gè)新文件 FileStream MyFileStream = new FileStream(SendFileName, , )。 //已發(fā)送包的個(gè)數(shù) int SendedCount = 0。 while (true) { byte[] data = (client)。 if ( == 0) { break。 } else 19 { SendedCount++。 //將接收到的數(shù)據(jù)包寫(xiě)入到文件流對(duì)象 (data, 0, )。 } } //關(guān)閉文件流 ()。 message = () + : 文件傳輸完成！文件保存在 + SendFileName + \n。 AddMessage(message)。 } //監(jiān)聽(tīng)接收消息進(jìn)程 private void ListenMessage() { while (Flag == true) { string Message = 對(duì)方 : + ((client1)) + \n。 AddMessage(Message)。 } } private void button2_Click(object sender, EventArgs e) { ()。 ()。 ()。 } int device_number = 0。 bool yulan = true。 private void buttonSee_Click(object sender, EventArgs e)