UDP協(xié)議實(shí)現(xiàn)二進(jìn)制文件傳輸(java)

./1.UDP概念UDP是UserDatagramProtocol的簡稱,中文名是用戶數(shù)據(jù)包協(xié)議,是OSI參考模型中一種無連接的傳輸層協(xié)議,提供面向事務(wù)的簡單不可靠信息傳送服務(wù),IETFRFC768是UDP的正式規(guī)。2.文件傳輸流程2.1在此使用UDP協(xié)議傳送文件的程序中,先在服務(wù)器端設(shè)定監(jiān)聽端口號(hào)〔3666,在接收客戶端發(fā)來的請求之前一直處于阻塞狀態(tài)；在客戶端則從本地讀取二進(jìn)制文件并封裝成數(shù)據(jù)報(bào),并發(fā)送到相應(yīng)的服務(wù)器端〔ip:127.0.0.1,端口：3666；當(dāng)服務(wù)器端接收到客戶端發(fā)來的請求后,則對數(shù)據(jù)進(jìn)行處理,即讀取并保存數(shù)據(jù),然后返回操作后的信息到客戶端；當(dāng)客戶端接收到服務(wù)器端的信息后,則輸出服務(wù)器端返回的信息,到此時(shí)就完成了客戶端的請求和服務(wù)器端的應(yīng)答；最后關(guān)閉DatagramSocket。3.程序流程圖Receive<>Receive<>接收到來自客戶端的數(shù)據(jù)writeFile<>Socket<>readFile<>sendTo<>Receive<>sendTo<>客戶端服務(wù)器端YN顯示返回的信息Close<>Socket<>數(shù)據(jù)應(yīng)答發(fā)送文件4.程序部分源碼4.1服務(wù)器端源碼publicclassServerextendsThread{ DatagramSocketds=null; DatagramPacketdp=null; Filefile=null;Overridepublicvoidrun<>{//TODOAuto-generatedmethodstubtry{//設(shè)置端口為3666ds=newDatagramSocket<3666>;while<true>{byte[]buf=newbyte[1024*64];//用于接收長度為1024的數(shù)據(jù)包dp=newDatagramPacket<buf,buf.length>;//從此套接字接收數(shù)據(jù)報(bào)包,此方法在接收到數(shù)據(jù)之前處于阻塞狀態(tài)ds.receive<dp>;//保存接收文件,文件名取系統(tǒng)當(dāng)前時(shí)間longtemp=System.currentTimeMillis<>;this.saveFile<dp,temp+"">;//為使反饋過程效果明顯,線程休眠2秒后發(fā)送回復(fù)信息 Thread.sleep<2000>; Stringmessage="serverhasreceivedit."; DatagramPacketpacket=newDatagramPacket<message.getBytes<>, message.length<>,InetAddress.getLocalHost<>,6666>;//發(fā)送回復(fù)數(shù)據(jù)包ds.send<packet>; } }catch<Exceptione>{ e.printStackTrace<>; } }/** *保存接收到的文件 * *paramdp *paramfilePath保存文件所在的路徑 *throwsIOException */privatevoidsaveFile<DatagramPacketdp,StringfilePath>throwsIOException{ FileOutputStreamfileOutputStream=newFileOutputStream<newFile< filePath>>; fileOutputStream.write<dp.getData<>,0,dp.getData<>.length>; fileOutputStream.close<>; }｝4.2客戶端源碼publicclassClient{privateDatagramSocketds=null;privateDatagramPacketdp=null;/** *傳輸文件 *paramfilePath文件所在路徑 */publicvoidTransmitFile<StringfilePath>{try{//從本地讀取文件byte[]data=this.readFile<filePath>;ds=newDatagramSocket<6666>;//封裝數(shù)據(jù)報(bào)dp=newDatagramPacket<data,<int>data.length, InetAddress.getLocalHost<>,3666>;//開始傳輸文件ds.send<dp>;//接收從服務(wù)器回復(fù)的信息byte[]buf=newbyte[1024];dp=newDatagramPacket<buf,buf.length>;ds.receive<dp>;byte[]server=dp.getData<>; System.out.println<"客戶端-->收到服務(wù)器返回的信息:\n"+newString<server,0,dp.getLength<>>.trim<>>; }catch<Exceptione>{ e.printStackTrace<>; }finally{ds.close<>; } }/** *讀取文件 * *paramfilePath *文件路徑 *return *throwsIOException */publicbyte[]readFile<StringfilePath>throwsIOException{ Filefile=newFile<filePath>;if<!file.exists<>>{returnnull; } InputStreaminputStream=newFileInputStream<file>; ByteArrayOutputStreamout=newByteArrayOutputStream<1024>;byte[]data=newbyte[1024];intlen=0;while<<len=inputStream.read<data>>!=-1>{ out.write<dat