這篇文章主要介紹了java如何模擬客戶端向服務(wù)器上傳文件,具有一定借鑒價值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。
成都創(chuàng)新互聯(lián)是專業(yè)的井研網(wǎng)站建設(shè)公司,井研接單;提供網(wǎng)站設(shè)計制作、做網(wǎng)站,網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行井研網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來合作!
具體內(nèi)容如下
先來了解一下客戶端與服務(wù)器Tcp通信的基本步驟:
服務(wù)器端先啟動,然后啟動客戶端向服務(wù)器端發(fā)送數(shù)據(jù)。
服務(wù)器端收到客戶端發(fā)送的數(shù)據(jù),服務(wù)器端會響應(yīng)應(yīng)客戶端,向客戶端發(fā)送響應(yīng)結(jié)果。
客戶端讀取服務(wù)器發(fā)送的數(shù)據(jù)
文件上傳步驟:
客戶端使用本地字節(jié)輸入流,指定上傳數(shù)據(jù)的數(shù)據(jù)源。
客戶端使用網(wǎng)絡(luò)字節(jié)輸出流,把讀取的本地文件上傳到服務(wù)器。
服務(wù)器使用網(wǎng)絡(luò)字節(jié)輸入流,讀取客戶端上傳的文件。
服務(wù)器使用本地字節(jié)輸出流,把讀取到的文件保存到服務(wù)器硬盤上。
服務(wù)器使用網(wǎng)絡(luò)字節(jié)輸出流,給客戶端響應(yīng)一個“上傳成功”。
客戶端使用網(wǎng)絡(luò)字節(jié)輸入流,讀取服務(wù)器響應(yīng)的數(shù)據(jù)。
客戶端的代碼實(shí)現(xiàn)
public class fileClient { public static void main(String[] args) throws IOException { FileInputStream fis = new FileInputStream("D:\\1.jpg");//創(chuàng)建一個本地的輸入流,用于指定上傳數(shù)據(jù)的數(shù)據(jù)源 Socket socket = new Socket("127.0.0.1",8888);//創(chuàng)建一個客戶端對象,host是服務(wù)器名稱或Ip地址 OutputStream os = socket.getOutputStream();//使用socket中的方法,獲取網(wǎng)絡(luò)字節(jié)輸出流對象 byte[] bytes = new byte[1024];//把本地硬盤的數(shù)據(jù)通過網(wǎng)絡(luò)字節(jié)輸出流傳遞給客戶端 int len = 0; while ((len = fis.read(bytes))!=-1){ os.write(bytes,0,len); } socket.shutdownOutput();//為了解決阻塞問題 InputStream is = socket.getInputStream();//使用socket中的方法,獲取網(wǎng)絡(luò)字節(jié)輸入流,用于讀取客戶端的數(shù)據(jù) while((len = is.read(bytes))!=-1){//讀取客戶端的數(shù)據(jù)進(jìn)行輸出 System.out.println(new String(bytes,0,len)); } socket.close();//關(guān)閉流 fis.close(); } }
服務(wù)器端代碼實(shí)現(xiàn)
public class fileServer { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(8888);//創(chuàng)建服務(wù)器端對象 //while(true){//讓服務(wù)器一直處于運(yùn)行狀態(tài),保證客戶端可以隨時向服務(wù)器上傳文件 new Thread(new Runnable() {//為了提高文件上傳效率,來一個客戶端開一個線程 @Override public void run() { try{ Socket socket = serverSocket.accept();//使用accept方法接收客戶端的數(shù)據(jù) InputStream is = socket.getInputStream();//創(chuàng)建網(wǎng)絡(luò)字節(jié)輸入流 File file = new File("D:\\upload");//判斷服務(wù)器硬盤中的文件夾是否存在,此文件夾用于存儲客戶端上傳的內(nèi)容 if (!file.exists()){//判斷服務(wù)器端的文件夾是否存在 file.mkdirs(); } String fileName = "\\picture"+System.currentTimeMillis()+new Random().nextInt(99999)+".jpg";//自己隨機(jī)生成文件名,防止重復(fù) FileOutputStream fos = new FileOutputStream(file+fileName);// int len; byte[] bytes = new byte[1024]; while((len = is.read(bytes))!= -1 ){//將客戶端的數(shù)據(jù)寫入服務(wù)器硬盤中 fos.write(bytes,0,len); } OutputStream os = socket.getOutputStream();//向客戶端回應(yīng) os.write("上傳成功".getBytes()); socket.close(); fos.close(); }catch (IOException e){//在這里只能使用try catch解決異常,因?yàn)閞un方法不支持拋出異常 System.out.println(e); } } }).start(); //} } }
注:在開啟多線程的時候,因?yàn)閞un方法的父類并不支持throws解決異常,所以run也不支持,只能使用try…catch解決異常
解釋一下為什么在上傳數(shù)據(jù)的時候客戶端和服務(wù)器會出現(xiàn)阻塞問題以及解決阻塞的方法
為什么會出現(xiàn)阻塞?
出現(xiàn)阻塞的根本問題是,客戶端從本地硬盤讀取文件給服務(wù)器的時候,因?yàn)橛玫氖莣hile循環(huán),所以文件的結(jié)束符-1并沒有被讀取到服務(wù)器,這時上傳到服務(wù)器的文件就沒有結(jié)束符,服務(wù)器把讀取到的文件保存到服務(wù)器硬盤上時就會一直執(zhí)行while循環(huán),導(dǎo)致阻塞。另外還有一個阻塞時服務(wù)器向客戶端響應(yīng)文件時候的阻塞。
解決阻塞問題的方法?
阻塞問題的根本原因就是因?yàn)樵谧x取的時候沒有結(jié)束符,用 socket.shutdownOutput() 給上傳的文件一個中止序列。
API對 shutdownOutput() 的解釋:對于 TCP 套接字,任何以前寫入的數(shù)據(jù)都將被發(fā)送,并且后跟 TCP的正常連接終止序列。
感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享的“java如何模擬客戶端向服務(wù)器上傳文件”這篇文章對大家有幫助,同時也希望大家多多支持創(chuàng)新互聯(lián),關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,更多相關(guān)知識等著你來學(xué)習(xí)!
新聞標(biāo)題:java如何模擬客戶端向服務(wù)器上傳文件
文章分享:http://aaarwkj.com/article38/ggphpp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供微信公眾號、關(guān)鍵詞優(yōu)化、面包屑導(dǎo)航、企業(yè)網(wǎng)站制作、標(biāo)簽優(yōu)化、品牌網(wǎng)站制作
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)