Http 远程调用

冷不防 2022-08-24 06:15 223阅读 0赞

Http 远程调用

1.HttpResquestProxy.java类。

package com.cassandra.http.common;
    
    
    import java.io.UnsupportedEncodingException;
    import java.net.URLEncoder;
    import java.util.HashMap;
    import java.util.Map;
    
    import net.sf.json.JSONObject;
    
    import org.apache.commons.httpclient.HttpClient;
    import org.apache.commons.httpclient.methods.PostMethod;
    import org.apache.commons.lang.StringUtils;
    import org.apache.commons.logging.Log;
    import org.apache.commons.logging.LogFactory;
    
    import com.cassandra.http.bean.Response;
    
    public class HttpRequestProxy
    {
      private Log logger = LogFactory.getLog(HttpRequestProxy.class);
      
      private String connectionUrl;
      private Map<String,String>  paramMap = new HashMap<String,String>();
      private Map<String, String> headMap = new HashMap<String,String>();
      private HttpClient httpClient;
      
      
      public HttpRequestProxy()
      {
    	  httpClient = new HttpClient();
    	  httpClient.getParams().setContentCharset("utf-8");
      }
          
      public HttpRequestProxy(String connectionUrl) {
    	httpClient = new HttpClient();  
        setConnectionUrl(connectionUrl);
      }
      
      public void clearHttpRequest(){
    	  paramMap.clear();
    	  headMap.clear();
      }
      public void appendParam(String key, String value) {
    	  try {
    		  if (StringUtils.isEmpty(value)) {
    			  return;
    		  }
    	      paramMap.put(key, URLEncoder.encode(value, "utf-8"));
    		} catch (UnsupportedEncodingException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
      }
    
      public void appendParam(Map<String, String> params) {
        if ((params == null) || (params.isEmpty())) {
          return;
        }   
        for (Map.Entry entry : params.entrySet()) {
          paramMap.put((String)entry.getKey(),(String)entry.getValue());
        }
      }
    
      public void setHead(Map<String, String> params) {
        this.headMap.putAll(params);
      }
    
      private String getConnectionUrl() {
        return this.connectionUrl;
      }
    
      public void setConnectionUrl(String connectionUrl) {
        this.connectionUrl = connectionUrl;
      }
    
      public String sendRequest()
      {
        if (StringUtils.isBlank(getConnectionUrl())) {
        	Response res = new Response();
        	res.setStatus(-1);
        	res.setMessage("用户中心地址异常！");
    	    return JSONObject.fromObject(res).toString();
         }
        logger.debug("sendRequest start!");
         try {
        	 PostMethod postMethod = new PostMethod(getConnectionUrl());  
          
         if (!(this.headMap.isEmpty())) {
        	for (Map.Entry head : this.headMap.entrySet()) {
              postMethod.addRequestHeader((String)head.getKey(), (String)head.getValue());  
            }
         }
         
         if (!(this.paramMap.isEmpty())) {
         	for (Map.Entry head : this.paramMap.entrySet()) {
               postMethod.addParameter((String)head.getKey(), (String)head.getValue());  
             }
          }      
          httpClient.executeMethod(postMethod);
          
          int code = postMethod.getStatusCode();
          if (code != 200) {
        	logger.debug("$$$$$$$$$$$$$$ code" + code);
            throw new Exception();
          }
          logger.debug("$$$$$$$$$$$$$$ code" + code);
          String result =  postMethod.getResponseBodyAsString();
          postMethod = null;
         /* InputStream in = postMethod.getResponseBodyAsStream();
          BufferedReader breader = new BufferedReader(
            new InputStreamReader(in, "gbk"));
          StringBuffer strResult = new StringBuffer();
          String strLine = breader.readLine();
          while(strLine != null){
        	  strResult.append(strLine);
        	  strResult.append("\n");
        	  strLine = breader.readLine();
          }
          */
          logger.debug("sendRequest end!");
          logger.info("请求结束，返回result= "+result);
          return result;
        } catch (Exception e) {
        	logger.debug("$$$$$$$$$$$$$$$$$$$ e" + e.getMessage());
        	Response res = new Response();
        	res.setStatus(-1);
        	res.setMessage("网络异常！");
    	    return JSONObject.fromObject(res).toString();
        } finally {
          
        }
      }
    }

2.方法调用示例

public JSONObject remarkEdit(String memberId, String comment, String token){
    		logger.info("HttpRequestUtils.remarkEdit() start");
    		long startTime = System.currentTimeMillis();
    		JSONObject jsonResult = new JSONObject();
    		HttpRequestProxy httpProxy = new HttpRequestProxy(ENT_ACCOUNT_CENTER_URL);
    		JSONObject json = new JSONObject();
    		json.put("memberId", memberId);
    		json.put("comment", comment);
    		httpProxy.appendParam(SERVICE_KEY,UPDATE_ENTERPRISE_MEMBER);
    		httpProxy.appendParam(PARAMS_KEY,JSONConverter.convertToString(json));
    		httpProxy.appendParam(TOKEN, token);
    		
    		String result = httpProxy.sendRequest();
    		jsonResult = JSONObject.fromObject(result);
    		
    		long costTime = System.currentTimeMillis() - startTime;
    		logger.info("HttpRequestUtils.remarkEdit() cost time:"+ costTime);
    		logger.info("HttpRequestUtils.remarkEdit() end");
    		return jsonResult;
    	}