客戶端向服務(wù)端發(fā)送數(shù)據(jù)-網(wǎng)絡(luò)編程

客戶端向服務(wù)端發(fā)送數(shù)據(jù)一網(wǎng)絡(luò)編程LT服務(wù)器端源碼：;importjava.io.File;importjava.io.FileNotFoundException;importjava.io.FileOutputStream;importjava.io.lOException;importjava.io.Inputstream;importjava.io.InputStreamReader;import.ServerSocket;import.Socket;*文ServerReceive.java工實現(xiàn)功能：作為服務(wù)器接收客戶端發(fā)送的文件具體實現(xiàn)過程：1、建立Socketserver,等待客戶端的連接2、當(dāng)有客戶端連接的時候，按照雙方的約定，這時要讀取三行數(shù)據(jù)其中保存客戶端要發(fā)送的文件名和文件大小信息3、根據(jù)文件名在本地創(chuàng)建文件，并建立好流通信4、循環(huán)接收數(shù)據(jù)包，將數(shù)據(jù)包寫入文聞5、當(dāng)接收數(shù)據(jù)的長度等于提前文件發(fā)過來的文件長度，即表示文件接收完畢，關(guān)閉文件6、文件接收工作結(jié)束publicclassServerReceive{publicstaticvoidmain(String[]args){卜與服務(wù)器建立連接的通信句柄★/ServerSocketss=null;Sockets=null;義用于后接收后在本地創(chuàng)建的文件對象和文件輸出流對象*/Filefile=null;FileOutputStreamfos=null;/**定義輸入流，使用socket的inputstream對數(shù)據(jù)包進行輸入*/Inputstreamis=null;/**定義byte數(shù)組來作為數(shù)據(jù)包的存儲數(shù)據(jù)包*/byte[]buffer=newbyte[4096*5];/**用來接收文件發(fā)送請求的字符串★/Stringcomm=null;/**建立socekt通信，等待服務(wù)器進行連接*/try{ss=newServerSocket(4004);s=ss.accept();}catch(lOExceptione){e.printStackTrace();}/**讀取一行客戶端發(fā)送過來的約定信息*/try(InputStreamReaderisr=newlnputStreamReader(s.getlnputStream());BufferedReaderbr=newBufferedReader(isr);comm=br.readLine();}catch(lOExceptione){System,out,printing服務(wù)器與客戶端斷開連接}開始解析客戶端發(fā)送過來的請求命令*/intindex=comm.indexOf(,7#H);/**判斷協(xié)議是否為發(fā)送文件的協(xié)議?Stringxieyi=comm.substring(0,index);if(!xieyi.equals(n111H)){("服務(wù)器收到的協(xié)議碼不正確)return;/**解析出文件的名字和大小*/comm=comm.substring(index+2);index=comm.indexOf('7#n);Stringfilename=comm.substring(0,index).trim();Stringfilesize=comm.substring(index+2).trim();/★★創(chuàng)建空文件，用來進行接收文件//file=newFile(filename);if(!file.exists()){try{file.createNewFile();}catch(lOExceptione){System.out.printin("服務(wù)器端創(chuàng)建文件失敗))}else{/“在此也可以詢問是否覆蓋?/("本路徑已存在相同文件,進行橙蓋))/"【以上就是客戶端代碼中寫到的服務(wù)器的準(zhǔn)備部分】7/**.服務(wù)器接收文件的關(guān)鍵代碼?/try(/”將文件包裝到文件輸出流時象中7fos=newFileOutputStream(file);longfilesize=Long.parseLong(filesize);is=s.getlnputStream();/“size為每次接收數(shù)據(jù)包的長度?/intsize=0;/“count用來記錄已接收到文件的長度./longcount=0;/”使用while循環(huán)接收數(shù)據(jù)包?/while(count<file__size){從輸入流中讀取一個數(shù)據(jù)包Vsize=is.read(buffer);/"將剛剛讀取的數(shù)據(jù)包寫到本地文件中去?/fos.write(buffer,0,size);fos.flush();/*?將已接收到文件的長度+size?/count+=size;?服務(wù)器端接收到數(shù)據(jù)包,大小為-+size);)}catch(FileNotFoundExceptione){System.out.println(■服務(wù)器寫文件失敗")；}catch(lOExceptione){Systenout.primin(-服務(wù)器：客戶端斷開連接)}finally{L將打開的文件關(guān)閉如如需要,也可以在此關(guān)閉socket連接7try{if(fos!=null)fos.close();}catch(lOExceptione){e.printStackTrace();}//catch(lOExceptione)}//finally}//publicstaticvoidmain(StringQargs)}//publicclassServerReceive客戶瑞源碼,importjava.io.File;importjava.io.FilelnputStream;importjava.io.FileNotFoundException;importjava.ioJOException;importjava.io.OutputStream;importjava.io.PrintStream;import.Socket;.*文件名：ClientSend.java實現(xiàn)功能：作為客戶端向服務(wù)器發(fā)送一個文件.具體實現(xiàn)過程：1、建立與服務(wù)器端的連接，IP：,port：40042、將文件的名字和大小通過自定義的文件傳輸協(xié)議，發(fā)送到服務(wù)器3、循環(huán)讀取本地文件，將文件打包發(fā)送到數(shù)據(jù)輸出流中4、關(guān)閉文件，結(jié)束傳輸7publicclassClientSend{publicstaticvoidmain(StringQargs){r與服務(wù)器建立連接的通信句柄?/Sockets=null;〃?定義文件對象，即為要發(fā)送的文件如果使用絕對路徑，不要忘記使用7和T的區(qū)別具體區(qū)別，請讀者自行錢詢7Filesendfile=newFile(HAPLCHMM)：/“定義文件輸入流，用來打開、讀取即將要發(fā)送的文件?/FilelnputStreamfis=null;/**定必byte數(shù)組來作為數(shù)據(jù)包的存儲數(shù)據(jù)包System,out,printing服務(wù)器連接中斷)此處睡眠2s,等待服務(wù)器把相關(guān)的工作準(zhǔn)備好}//catch(lOExceptione)System,out,printing服務(wù)器連接中斷)此處睡眠2s,等待服務(wù)器把相關(guān)的工作準(zhǔn)備好}//catch(lOExceptione)/**定義輸出流，使用socket的outputstream對數(shù)據(jù)包進行輸出*/Outputstreamos=null;/**檢查要發(fā)送的文件是否存在*/if(!sendfile.exists()){("客戶端：要發(fā)送的文件不存在)return;)/*涓服務(wù)器建立連接*/try{s=newSocket?！薄?，4004);}catch(lOExceptione){System.out,printing未連接到服務(wù)器)}/**用文件對象初始化fis對象以便于可以提取出文件的大小try{fis=newFilelnputStream(sendfile);}catch(FileNotFoundExceptione1){e1.printStackTrace();/★★首先先向服務(wù)器發(fā)送關(guān)于文件的信息，以便于服務(wù)器進行接收的相關(guān)準(zhǔn)備工作具體的準(zhǔn)備工作，請查看服務(wù)器代碼。|"1*發(fā)送的內(nèi)容包括：發(fā)送文件協(xié)議碼(此處為111)/#文件名(帶后綴名)/#文件大小try(Printstreamps=newPrintStream(s.getOutputStream());ps.println(n111/#"+sendfile.getName()+"/#"+fis.available());ps.flush();}catch(lOExceptione){也是為了保證網(wǎng)絡(luò)的延遲讀者可自行選擇添加此代碼*/try{Thread.sleep(2000);}catch(InterruptedExceptione1){e1.printStackTrace();)/**之前的準(zhǔn)備工作結(jié)束之后下面就是文件傳輸?shù)年P(guān)鍵代碼try{/**獲取socket的Outputstream,以便向其中寫入數(shù)據(jù)包*/os=s.getOutputStream();/**size用來記錄每次讀取文件的大小Rintsize=0;/**使用while循環(huán)讀取文件，直到文件讀取結(jié)束*/while((size=fis.read(buffer))!=-1){("客戶端發(fā)送數(shù)據(jù)包，大小為"+size);/**向輸出流中寫入剛剛讀到的數(shù)據(jù)包*/os.write(buffer50,size);卜*刷新一下*/os.flush();5}catch(FileNotFoundExceptione){System.out.printin("客戶端讀取文件出錯)}catch(lOExceptione){System.out.