我想做過web開發(fā)的程序員大部分都做過文件上傳的功能,大多數(shù)時(shí)候我們都是借助于commons-fileupload這樣的jar包實(shí)現(xiàn)的。下面我試著通過讀取Socket的輸入流來實(shí)現(xiàn)一個(gè)文件上傳的功能。
創(chuàng)新互聯(lián)是一家專業(yè)提供磴口企業(yè)網(wǎng)站建設(shè),專注與成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)、成都h5網(wǎng)站建設(shè)、小程序制作等業(yè)務(wù)。10年已為磴口眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)的建站公司優(yōu)惠進(jìn)行中。
在做文件上傳之前我們需要先了解一下HTTP POST的附件上傳協(xié)議。HTTP附件上傳協(xié)議是RFC1876協(xié)議,RFC1876協(xié)議是在HTTP協(xié)議的基礎(chǔ)上為INPUT標(biāo)簽增加了file屬性,同時(shí)限定了Form的method必須為POST
,ENCTYPE
必須為multipart/form-data
。RFC1867協(xié)議對(duì)HTTP頭作了適當(dāng)?shù)刈兏?,content-type頭由以前的:content-type:application/x-www-form-urlencoded變?yōu)?code>content-type:multipart/form-data;+空格+boundary=字符串。RFC1867增加了文件上傳得功能,而上傳文件內(nèi)容自然也會(huì)被加入到HTTP的實(shí)體中?,F(xiàn)在因?yàn)榧扔蠬TTP一般的參數(shù)實(shí)體,又有上傳文件的實(shí)體,所以用boundary把每種實(shí)體進(jìn)行了分割。具體的看下圖:
接下來就開始我們的代碼部分吧。
我在前面的文章中寫過創(chuàng)建一個(gè)自己的Web服務(wù)器,現(xiàn)在我們的重點(diǎn)要放在對(duì)socket的輸入流的解析中。具體代碼如下:
public void parseRequest() { LineNumberReader br = new LineNumberReader(new InputStreamReader(inputStream)); StringBuffer sb = new StringBuffer(); String str = null; try { //讀取請(qǐng)求行 String requestLine = br.readLine(); if (!StringUtils.isEmpty(requestLine)) { sb.append(requestLine); String[] reqs = requestLine.split(" "); if (reqs != null && reqs.length > 0) { if ("GET".equals(reqs[0])) { method = "GET"; } else { method = "POST"; } } } //讀取請(qǐng)求頭 while ((str = br.readLine()) != null) { if ("".equals(str)) { break; } if (!StringUtils.isEmpty(str)) { if (str.indexOf(":") > 0) { String[] strs = str.split(":"); headers.put(strs[0].toLowerCase(), strs[1].trim()); } } sb.append(str).append("\n"); } //POST請(qǐng)求,Content-type為 multipart/form-data String contentType = null; if ("POST".equals(method) && ((contentType = headers.get("content-type")) != null && headers.get("content-type").startsWith("multipart/form-data"))) { //文件上傳的分割位 這里只處理單個(gè)文件的上傳 String boundary = contentType.substring(contentType.indexOf("boundary") + "boundary=".length()); //解析消息體 while ((str = br.readLine()) != null) { //解析結(jié)束的標(biāo)記 do { //讀取boundary中的內(nèi)容 //讀取Content-Disposition str = br.readLine(); //說明是文件上傳 if (str.indexOf("Content-Disposition:") >= 0 && str.indexOf("filename") > 0) { str = str.substring("Content-Disposition:".length()); String[] strs = str.split(";"); String fileName = strs[strs.length - 1].replace("\"", "").split("=")[1]; System.out.println("fileName = " + fileName); //這一行是Content-Type br.readLine(); //這一行是換行 br.readLine(); //正式去讀文件的內(nèi)容 BufferedWriter bw = null; try { bw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream("G:\\LearnVideo\\fileLoad" + File.separator + fileName), "UTF-8")); while (true) { str = br.readLine(); if (str.startsWith("--" + boundary)) { break; } bw.write(str); bw.newLine(); } bw.flush(); } catch (Exception e) { } finally { if (bw != null) { bw.close(); } } } if (str.indexOf("Content-Disposition:") >= 0) { str = str.substring("Content-Disposition:".length()); String[] strs = str.split(";"); String name = strs[strs.length - 1].replace("\"", "").split("=")[1]; br.readLine(); StringBuilder stringBuilder = new StringBuilder(); while (true) { str = br.readLine(); if (str.startsWith("--" + boundary)) { break; } stringBuilder.append(str); } parameters.put(name, stringBuilder.toString()); } } while (("--" + boundary).equals(str)); //解析結(jié)束 if (str.equals("--" + boundary + "--")) { break; } } } //System.out.println(sb.toString()); //獲取URI uri = StringUtils.parserUri(sb.toString(), " "); int flag = -1; //說明有參數(shù) if ((flag = uri.indexOf('?')) >= 0) { String oldUri = uri; uri = uri.substring(0,flag); String parameterPath = oldUri.substring(flag+1); String[] parameter = parameterPath.split("&"); if (parameter != null && parameter.length > 0) { for (int i = 0; i < parameter.length; i++) { String str1 = parameter[i]; if((flag = str1.indexOf('=')) >= 0){ String key = str1.substring(0,flag); String value = str1.substring(flag+1); parameters.put(key,value); }else{ parameters.put(str,null); } } } } } catch (IOException e) { e.printStackTrace(); } }
我們啟動(dòng)自己創(chuàng)建的Web服務(wù)器,然后在瀏覽器中輸入:http://localhost:8004/static/uploadPage.html,頁面如下:
選擇我們要上次的文件,然后點(diǎn)擊上傳按鈕,我們會(huì)發(fā)現(xiàn)我們的功能已經(jīng)被上傳到G:\LearnVideo\fileLoad這個(gè)目錄下了。示例如下:
完整的代碼請(qǐng)從這里下載:FullStackTraining_jb51.rar
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。
當(dāng)前標(biāo)題:Java中用Socket實(shí)現(xiàn)HTTP文件上傳實(shí)例
文章出自:http://aaarwkj.com/article24/jegcce.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供微信小程序、手機(jī)網(wǎng)站建設(shè)、外貿(mào)建站、企業(yè)建站、網(wǎng)站改版、品牌網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)