java實現http協議發送和接收數據

public void sendMessage() throws Exception {
       System.out.println("調用servlet開始=================");
       StringBuffer sendStr = new StringBuffer();
       sendStr.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
       sendStr.append("<report_data>");
       sendStr.append("<request_req>953943547334</request_req>");
       sendStr.append("<request_time>2012040211394324</request_time>");
       sendStr.append("<request_param>");
       sendStr.append("<query_month>201203</query_month>");
       sendStr.append("</request_param>");
       sendStr.append("</report_data>");
  
       BufferedReader reader = null;
  
       try {
           String strMessage = "";
           StringBuffer buffer = new StringBuffer();
  
           // 接報文的地址
           URL uploadServlet = new URL(
                  "http://localhost:9090/TestTransfers");
  
           HttpURLConnection servletConnection = (HttpURLConnection) uploadServlet
                  .openConnection();
           // 設置連接參數
           servletConnection.setRequestMethod("POST");
           servletConnection.setDoOutput(true);
           servletConnection.setDoInput(true);
           servletConnection.setAllowUserInteraction(true);
  
           // 開啟流，寫入XML數據
           OutputStream output = servletConnection.getOutputStream();
           System.out.println("發送的報文：");
           System.out.println(sendStr.toString());
  
           output.write(sendStr.toString().getBytes());
           output.flush();
           output.close();
  
           // 獲取返回的數據
           InputStream inputStream = servletConnection.getInputStream();
           reader = new BufferedReader(new InputStreamReader(inputStream));
           while ((strMessage = reader.readLine()) != null) {
              buffer.append(strMessage);
           }
  
           System.out.println("接收返回值:" + buffer);
  
       } catch (java.net.ConnectException e) {
           throw new Exception();
       } finally {
           if (reader != null) {
              reader.close();
           }
  
       }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
public class TestTransfers extends HttpServlet {
  
    private static final long serialVersionUID = 1L;
  
    protected void doGet(HttpServletRequest request,
           HttpServletResponse response) throws ServletException, IOException {
    }
  
    protected void doPost(HttpServletRequest request,
           HttpServletResponse response) throws ServletException, IOException {
  
       //判斷請求報文是否來自代維系統的ip地址
       String ip = request.getRemoteHost();
 
// 獲取收到的報文
        BufferedReader reader = request.getReader();
         String line = "";
        StringBuffer inputString = new StringBuffer();
        while ((line = reader.readLine()) != null) {
        inputString.append(line);
        }
         
       //如有必要，可以在報文中增加其他驗證和加密的參數
       //解析獲取到的報文，根據ip地址、其他驗證、加密等等來判斷請求報文的服務器是否有權限
       
       //如果請求驗證合格，則根據請求的參數裝配返回的報文
  
       // 要返回的報文
       StringBuffer resultBuffer = new StringBuffer();
       resultBuffer.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
       resultBuffer.append("<report_data>");
       resultBuffer.append("<respon_req>953947334</respon_req>");
       resultBuffer.append("<respon_time>20120402113943</respon_time>");
       resultBuffer.append("<result>");
       resultBuffer.append("<id>0000</id>");
       resultBuffer.append("<comment>成功</comment>");
       resultBuffer.append("</result>");
       resultBuffer.append("<items>");
       resultBuffer.append("<item>");
       resultBuffer.append("<county>長治縣</county>");
       resultBuffer.append("<company>鐵通</company>");
       resultBuffer.append("<speciality>線路</speciality>");
       resultBuffer.append("<personnel>王加和</personnel>");
       resultBuffer.append("<begin_time>20120301000000</begin_time>");
       resultBuffer.append("<end_time>20120331235959</end_time>");
       resultBuffer.append("<plan_quantity>50</plan_quantity>");
       resultBuffer.append("<checkout_quantity>40</checkout_quantity>");
       resultBuffer.append("<patrol_rate>0.80</patrol_rate>");
       resultBuffer.append("</item>");
       //......
       //......
       //......
       //循環組裝響應的報文
       
       resultBuffer.append("</items>");
       resultBuffer.append("</report_data>");
  
       // 設置發送報文的格式
       response.setContentType("text/xml");
       response.setCharacterEncoding("UTF-8");
  
       PrintWriter out = response.getWriter();
       out.println(resultBuffer.toString());
       out.flush();
       out.close();
    }
}