使用httpclient傳輸文件

客戶端代碼：

package httpclient;

import java.io.File;
import java.io.FileNotFoundException;
import java.util.HashMap;
import java.util.Map;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.multipart.FilePart;
import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;
import org.apache.commons.httpclient.methods.multipart.Part;
import org.apache.commons.httpclient.methods.multipart.StringPart;

public class HttpClientTest {
 public static void main(String[] args) throws Exception {
  HttpClientTest httpClientTest = new HttpClientTest();
  httpClientTest.httpFileTest();
 }

 public void httpFileTest() throws Exception {
  File localFile = new File("D:\\httptest.txt");
  File localFile1 = new File("D:\\httptest1.txt");
  String url = "http://10.136.2.10:8080/yld-base-webapp-modules-appconnectorin/api/test.do";
  PostMethod filePost = new PostMethod(url);
  FilePart fp = new FilePart("file", localFile);
  FilePart fp1 = new FilePart("file1", localFile1);
  // StringPart:普通的文本參數
  StringPart uname = new StringPart("username", "aa");
  StringPart pass = new StringPart("password", "123456");
  Part[] parts = { uname, pass, fp,fp1 };
  // 對於MIME類型的請求，httpclient建議全用MulitPartRequestEntity進行包裝
  MultipartRequestEntity mre = new MultipartRequestEntity(parts, filePost.getParams());
  filePost.setRequestEntity(mre);
  HttpClient client = new HttpClient();
  int status = client.executeMethod(filePost);
  System.out.println(status + "--------------");

 }
}

服務端代碼：

package com.yld.publicservice.springweb.service;

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.springframework.stereotype.Service;

import com.boco.common.ReturnValue;

/**
 * 解析httpclient中上傳的文件,只能處理文件--若是要記錄其餘信息(如表單域中的其餘信息),參考監控工程中的方法
 * 實現原理：解析請求數據流
 * @author  boco
 */
@Service
public class FileUpLoadService {
 private List<String> fileRealNames = new ArrayList<String>();
 private static final String outFilePath = "/home/lilong/uptoserver/";

 public List<String> getFileRealNames() {
  return fileRealNames;
 }

 /**
  * 提供給外部調用的接口
  *
  * @param  request
  * @return
  */
 public ReturnValue fileUpLoad(HttpServletRequest request) {
  ReturnValue returnValue = fileUpLoadMain(request);
  return returnValue;
 }

 /**
  * 文件上傳的主服務
  *
  * @param  request
  * @return
  */
 @SuppressWarnings("unused")
 private ReturnValue fileUpLoadMain(HttpServletRequest request) {
  final int NONE = 0; // 狀態碼，表示沒有特殊操做
  final int DATAHEADER = 1; // 表示下一行要讀到報頭信息
  // 請求消息實體的總長度(請求消息中除消息頭以外的數據長度)
  int totalbytes = request.getContentLength();
  File file; // 上傳文件儲存在服務器上
  // 容納請求消息實體的字節數組
  byte[] dataOrigin = new byte[totalbytes];
  // 對於post多個文件的表單，b做爲原始數據的副本提供提取文件數據的操做
  byte[] b = new byte[totalbytes];
  // 請求消息類型
  String contentType = request.getContentType();
  String fieldname = ""; // 表單域的名稱
  String fieldvalue = ""; // 表單域的值
  String fileFormName = ""; // 上傳的文件再表單中的名稱
  String fileRealName = ""; // 上傳文件的真實名字
  String boundary = ""; // 分界符字符串
  String lastboundary = ""; // 結束分界符字符串
  int fileSize = 0; // 文件長度
  // 容納表單域的名稱/值的哈希表
  Map<String, String> formfieldsTable = new HashMap<String, String>();
  // 容納文件域的名稱/文件名的哈希表
  Map<String, String> filenameTable = new HashMap<String, String>();
  // 在消息頭類型中找到分界符的定義
  int pos = contentType.indexOf("boundary=");
  int pos2;
  try {
   if (pos != -1) {
    pos += "boundary=".length();
    boundary = "--" + contentType.substring(pos); // 解析出分界符
    lastboundary = boundary + "--"; // 獲得結束分界符
   }
   int state = NONE; // 起始狀態爲NONE
   // 獲得請求消息的數據輸入流
   DataInputStream in = new DataInputStream(request.getInputStream());
   in.readFully(dataOrigin); // 根據長度，將消息實體的內容讀入字節數組dataOrigin中
   in.close(); // 關閉數據流
   String reqcontent = new String(dataOrigin); // 從字節數組中獲得表示實體的字符串
   // 從字符串中獲得輸出緩衝流
   BufferedReader reqbuf = new BufferedReader(new StringReader(
     reqcontent));
   // 設置循環標誌
   boolean flag = true;
   while (flag == true) {
    String s = reqbuf.readLine();
    if (s == lastboundary || s == null)
     break;
    switch (state) {
    case NONE:
     if (s.startsWith(boundary)) {
      // 若是讀到分界符，則表示下一行一個頭信息
      state = DATAHEADER;
     }
     break;
    case DATAHEADER:
     pos = s.indexOf("filename=");
     // 先判斷出這是一個文本表單域的頭信息，仍是一個上傳文件的頭信息
     if (pos == -1) {
      // 若是是文本表單域的頭信息，解析出表單域的名稱---這個方法中什麼都沒有作
      state = NONE; // 設置狀態碼，準備讀取表單域的值
     } else {
      // 若是是文件數據的頭，先存儲這一行，用於在字節數組中定位
      // 這個方法是將文件數據直接進行存盤,下面讀取文件數據的基本上是沒多大用處的
      String temp = s;
      // 先解析出文件名
      pos = s.indexOf("name=");
      pos += "name=".length() + 1; // 1表示後面的"的佔位
      pos2 = s.indexOf("filename=");
      String s1 = s.substring(pos, pos2 - 3); // 3表示";加上一個空格,解析出來的是name的值
      fileFormName = s1;
      pos2 += "filename=".length() + 1; // 1表示後面的"的佔位
      s = s.substring(pos2);
      int l = s.length();
      s = s.substring(0, l - 1);// 解析出來的是filename的值
      pos2 = s.lastIndexOf("\\");// 若是filename中有/符號,須要進行的操做
      s = s.substring(pos2 + 1);
      fileRealName = s;
      System.out.println("fileRealName:" + fileRealName);
      if (fileRealName.length() != 0) { // 肯定有文件被上傳
       s = reqbuf.readLine();
       boolean isContent = true;
       //循環數據-將請求頭的數據過濾掉
       while(isContent){
        if(s.indexOf("Content") != -1){
         s = reqbuf.readLine();
        }else{
         isContent = false;
        }
       }
       //過濾掉請求頭下面的空行---每一個請求都有的
       s = reqbuf.readLine();
       //上傳文件輸出的地址文件
       file = new File(outFilePath + File.separator
         + fileRealName);
       DataOutputStream fileout = new DataOutputStream(
         new FileOutputStream(file));
       //循環寫入到輸出文件中
       while ((!s.startsWith(boundary))
         && (!s.startsWith(lastboundary))) {
        fileout.writeChars(s);
        fileout.writeChars("\r\n");
        s = reqbuf.readLine();
        //若是讀到分解符開始下一次的判斷
        if (s.startsWith(boundary)) {
         state = DATAHEADER;
         break;
        }
       }
      } 
     } 
    //結束switch
    break;
    }
   }
   return ReturnValue.getInstance(fileRealName, 0);
  } catch (Exception e) {
   e.printStackTrace();
   return ReturnValue.getInstance(1);
  }
 }

 /**
  * 在原始數據(b)中找到s數據在b中的位置數據
  *
  * @param b
  *            :原始數據
  * @param s
  *            :須要操做的數據
  * @param start
  *            :起始位置
  * @return
  */
 private static int byteIndexOf(byte[] b, String s, int start) {
  return byteIndexOf(b, s.getBytes(), start);
 }

 private static int byteIndexOf(byte[] b, byte[] s, int start) {
  int i;
  if (s.length == 0) {
   return 0;
  }
  int max = b.length - s.length;
  if (max < 0) {
   return -1;
  }
  if (start > max) {
   return -1;
  }
  if (start < 0) {
   start = 0;
  }
  // 在b中找到s的第一個元素
  search: for (i = start; i <= max; i++) {
   if (b[i] == s[0]) {
    // 找到了s中的第一個元素後，比較剩餘的部分是否相等
    int k = 1;
    while (k < s.length) {
     if (b[k + i] != s[k]) {
      continue search;
     }
     k++;
    }
    return i;
   }
  }
  return -1;
 }

 /**
  * 賦值數組
  *
  * @param b
  *            :源數組
  * @param from
  *            :起始位置
  * @param end
  *            :結束位置
  * @return
  */
 private static byte[] subBytes(byte[] b, int from, int end) {
  byte[] result = new byte[end - from];
  System.arraycopy(b, from, result, 0, end - from);
  return result;
 }

}