HttpClient发送Post请求,内容格式为xml,并获取响应内容

ChannelDistributor.xml 内容如下：

<?xml version="1.0" encoding="UTF-8"?>
<request>
 <userName>yisou</userName>
 <pwd>abcd1234</pwd>
 <channelCode>10010000</channelCode>
 <insertType>00</insertType>
</request>

 

1).HttpClient发送Post请求,内容格式为xml,并获取响应内容

 

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.StringRequestEntity;
import org.apache.log4j.Logger;

public class ServiceValidate extends HttpServlet{
 private Logger log = Logger.getLogger(ServiceValidate.class);
 private static final long serialVersionUID = -6995391540735187530L;

 @Override
 protected void doGet(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  this.doPost(req, resp);
 }

    /**
     * 发送xml数据请求到服务器端
     * @param url xml请求数据地址
     * @param xmlString 发送的xml数据流
     * @return null发送失败，否则返回响应内容
     */
 @Override
 protected void doPost(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  System.setProperty("org.apache.commons.logging.Log", "org.apache.commons.logging.impl.SimpleLog");  
        System.setProperty("org.apache.commons.logging.simplelog.showdatetime", "true");  
        System.setProperty("org.apache.commons.logging.simplelog.log.org.apache.commons.httpclient", "stdout"); 
       
        String url = "http://localhost:8080/game/testServlet";
       
        String xmlString = getXmlString();
       
        HttpClient client = new HttpClient(); 
        PostMethod myPost = new PostMethod(url); 
        client.getParams().setSoTimeout(300*1000); 
        String responseString = null; 
        try{ 
            myPost.setRequestEntity(new StringRequestEntity(xmlString,"text/xml","utf-8")); 
            int statusCode = client.executeMethod(myPost); 
            if(statusCode == HttpStatus.SC_OK){ 
                BufferedInputStream bis = new BufferedInputStream(myPost.getResponseBodyAsStream()); 
                byte[] bytes = new byte[1024]; 
                ByteArrayOutputStream bos = new ByteArrayOutputStream(); 
                int count = 0; 
                while((count = bis.read(bytes))!= -1){ 
                    bos.write(bytes, 0, count); 
                } 
                byte[] strByte = bos.toByteArray(); 
                responseString = new String(strByte,0,strByte.length,"utf-8"); 
                bos.close(); 
                bis.close(); 
            } 
        }catch (Exception e) { 
         log.error(e.getMessage(), e);
        } 
        myPost.releaseConnection(); 
        client.getHttpConnectionManager().closeIdleConnections(0);
        System.out.println("responseString:"+responseString);
 }

 /**
  * 读取xml内容,将请求的xml
  * 保存成字符串 进行post发送  
  * @return
  */
 private String getXmlString() {
  StringBuilder sb=new StringBuilder();  
        try {  
         InputStream inputStream =ServiceValidate.class.getResourceAsStream("/ChannelDistributor.xml");
            BufferedReader br=new BufferedReader(new InputStreamReader(inputStream));  
            String line="";  
            for(line=br.readLine();line!=null;line=br.readLine()) {  
                sb.append(line+"\n");  
            }  
        } catch (FileNotFoundException e) {  
         log.error(e.getMessage(), e);
        } catch (IOException e) {  
         log.error(e.getMessage(), e); 
        }  
        return sb.toString();  
 }

 @Override
 protected void doPut(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  this.doPost(req, resp);
 }

}

2).获取HttpClient Post请求数据并响应内容

import org.apache.log4j.Logger;

public class TestServlet extends HttpServlet{
 private static final long serialVersionUID = -6175353394519367540L;
 private Logger log = Logger.getLogger(TestServlet.class);

 @Override
 protected void doGet(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  this.doPost(req, resp);
 }
 
 @Override
 protected void doPost(HttpServletRequest request, HttpServletResponse response)
   throws ServletException, IOException {
  try {
   int len = request.getContentLength();
         System.out.println("数据流长度:" +len);
         //获取HTTP请求的输入流
         InputStream is = request.getInputStream();
         //已HTTP请求输入流建立一个BufferedReader对象
         BufferedReader br = new BufferedReader(new InputStreamReader(is,"UTF-8"));
         //读取HTTP请求内容
         String buffer = null;
         StringBuffer sb = new StringBuffer();
         while ((buffer = br.readLine()) != null) {
         //在页面中显示读取到的请求参数
             sb.append(buffer+"\n");
         }
        System.out.println("接收post发送数据:\n"+sb.toString().trim());
       
        PrintWriter out = response.getWriter();
        StringBuffer stringBuffer = new StringBuffer("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
        stringBuffer.append("<response>");
          stringBuffer.append("<status>800</status>");
          stringBuffer.append("<tokenPwd>jkuiowerncxuidafjkfdaouifdaljkn</tokenPwd>");
        stringBuffer.append("</response>");
        out.write(stringBuffer.toString());
        out.flush();
        out.close();
  } catch (Exception e) {
   log.error(e.getMessage(), e);
  }
 }
}

 

控制台输出如下：

数据流长度:175
接收post发送数据:
<?xml version="1.0" encoding="UTF-8"?>
<request>
 <userName>yisou</userName>
 <pwd>abcd1234</pwd>
 <channelCode>10010000</channelCode>
 <insertType>00</insertType>
</request>
responseString:<?xml version="1.0" encoding="UTF-8"?><response><status>800</status><tokenPwd>jkuiowerncxuidafjkfdaouifdaljkn</tokenPwd></response>