Java模拟HTTP发送请求

package com.hp.pn.service;

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * This Class to test the PrintNet processing the snapshot performance.
 * It's mainly to solve the out of memory issue.
 * 
 * @author  
 */
public class PnSnapshotPerformanceTest extends Thread {
  
  private static final int threadNumber = 70;
  
  private static final int perThreadCreatSnpNumber = 1;
  
  private static final SimpleDateFormat dateFomat =
      new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:ms");
  
  public PnSnapshotPerformanceTest() {
    super();
  }

  public PnSnapshotPerformanceTest(String name) {
    super(name);
  }

  @Override
  public void run() {
    for (int i = 1; i <= perThreadCreatSnpNumber; i++) {
      long startTime = System.currentTimeMillis();
      System.out.println(getCurrDateStr() + " " + this.getName() + "_" + i + ": Start to handle the snapshot <<<<<<<<<<<<<<<<<<<<<<<<<<");
      
      try {
        doPost();// send post request
      } catch (Exception e) {
        e.printStackTrace();
      }
      
      long useTime = System.currentTimeMillis() - startTime;
      System.out.println(getCurrDateStr() + " " +this.getName() + "_" + i + ": Handle the snapshot end >>>>>>>>>>>>>>>>>>>>>>>>>>>>use time: " + useTime/60000 + ":" + useTime%60000/1000 + ":" + useTime%60000%1000);
    }
  }
  
  public void doPost() {
    // 发送
    HttpURLConnection conn = null;
    try {
      URL url = new URL("http://localhost:8080/pnet.web/pn_entry.jsp");
      conn = (HttpURLConnection) url.openConnection();//新建连接实例
      conn.setDoOutput(true);//是否打开输出流 true|false
      conn.setRequestMethod("POST");//提交方法POST|GET
      //conn.setUseCaches(false);//是否缓存true|false
    
      //TODO test
      String snapshotStr = readFile("C:/bill/HP/eclipse_workspace/DailyPractice/src/d20130304/snapshot.xml");
      //String snapshotStr = readFile("C:/bill/HP/eclipse_workspace/DailyPractice/src/d20130304/snapshot_2.xml");
      StringBuffer sb = new StringBuffer();
      addPair(sb, "XML_string", snapshotStr);
      String parametersStr = sb.substring(0, sb.length() - 1);
      //System.out.println("parametersStr: \n" + parametersStr.substring(0, 1000));
      
      OutputStreamWriter out = new OutputStreamWriter(conn.getOutputStream()); //打开输出流往对端服务器写数据
      out.write(parametersStr);//写数据,也就是提交你的表单 name=xxx&pwd=xxx
      out.flush();//刷新
      out.close();//关闭输出流
      
      conn.getInputStream();
      //BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
      /*String line = null;
      sb = new StringBuffer();*/
      /*while ((line = reader.readLine()) != null) {
        sb.append(line);
      }*/
      //line = sb.toString();
      // 处理返回的字符串line
      //System.out.println("return line: " + line);
      //System.out.println(">>>>>>>>>>>>>>>>>>>>>>>Send request end. ");
    } catch (IOException e) {
      // handle e
      System.out.println(">>>>>>>>>>>>>>IOException: " + e);
    } finally {
      if (conn != null) {
        conn.disconnect();
        //System.out.println("Disconnect successfully. ");
      }
    }
    //发送结束
  }
  
  private String readFile(String filePath) {
    FileReader fr = null;
    BufferedReader br = null;
    StringBuffer sBuffer = new StringBuffer();

    try {
      fr = new FileReader(filePath);// d20130304/snapshot.xml
    } catch (FileNotFoundException e) {
      e.printStackTrace();
    }

    br = new BufferedReader(fr);// 建立BufferedReader对象，并实例化为br
    String tempLine;
    try {
      // 从文件读取一行字符串
      tempLine = br.readLine();
      // 判断读取到的字符串是否不为空
      while (tempLine != null) {
        sBuffer.append(tempLine);
        sBuffer.append("\n");
        tempLine = br.readLine();// 从文件中继续读取一行数据
      }
      //System.out.println("sBuffer: \n" + sBuffer);
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        if (br != null)
          br.close();// 关闭BufferedReader对象
        if (fr != null)
          fr.close();// 关闭文件
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
    
    return sBuffer.toString().trim();
  }
  
  public static void addPair(StringBuffer sb, String name, String value)
      throws UnsupportedEncodingException {
    if (value == null) {
      return;
    }
    sb.append(name);
    sb.append("=");
    sb.append(java.net.URLEncoder.encode(value, "UTF-8"));
    sb.append("&");
  }
  
  public static String getCurrDateStr() {
    Date date = new Date();
    return dateFomat.format(date);
  }

  public static void main(String[] args) {
    for (int i = 1; i <= threadNumber; i++) {
      PnSnapshotPerformanceTest pspt = new PnSnapshotPerformanceTest("Thread_" + i);
      pspt.start();
    }
  }
  
}