详解Java发送HTTP请求

import java.net.httpurlconnection;

import java.net.uri;

import org.apache.http.httpresponse;

import org.apache.http.httpstatus;

import org.apache.http.client.methods.httpget;

import org.apache.http.client.methods.httppost;

import org.apache.http.client.utils.uribuilder;

import org.apache.http.entity.stringentity;

import org.apache.http.impl.client.closeablehttpclient;

import org.apache.http.impl.client.defaulthttpclient;

import org.apache.http.impl.client.httpclients;

import org.apache.http.util.entityutils;

import com.fasterxml.jackson.databind.objectmapper;

<dependency>

            <groupid>org.apache.httpcomponents</groupid>

            <artifactid>httpcore</artifactid>

            <version> 4.4 . 8 </version>

        </dependency>

        <dependency>

            <groupid>org.apache.httpcomponents</groupid>

            <artifactid>httpclient</artifactid>

            <version> 4.5 . 3 </version>

        </dependency>

public static string gethttpdata(string host, string servuri, string restring) throws exception {

         stringbuffer sb = new stringbuffer();

         sb.append( "gethttpdata:host:" + host + ",servuri:" + servuri + ",restring:" + restring);

         string strresp = null ;

         try {

             uri uri = new uribuilder().setscheme( "http" ).sethost(host).setpath(servuri)

                     .setparameter( "strinfo" , restring).build();

             httpget httpget = new httpget(uri);

             closeablehttpclient client3 = httpclients.createdefault();

             httpresponse resp;

             resp = client3.execute(httpget);

             if (resp.getstatusline().getstatuscode() == httpurlconnection.http_ok) {

                 strresp = entityutils.tostring(resp.getentity());

                 logger.info( "the return result:{}" , strresp);

             } else {

                 logger.info( "error response:" , resp.getstatusline().tostring());

                 throw new commonbusinessexception(commonconstants.task_release_wcf,

                         commonconstants.task_release_wcf_desc);

             }

         } catch (exception e) {

             logger.error(sb.tostring() + ":" + e.getmessage(), e.getcause());

             throw new commonbusinessexception(commonconstants.task_release_wcf, commonconstants.task_release_wcf_desc);

         }

         return strresp;

     }

public static string dopostdata(string url, string json) throws exception {

         defaulthttpclient client = new defaulthttpclient();

         httppost post = new httppost(url);

         string result = "" ;

         httpresponse res = null ;

         try {

             stringentity s = new stringentity(json.tostring(), "utf-8" );

             s.setcontenttype( "application/json" );

             post.setheader( "accept" , "application/json" );

             post.setheader( "content-type" , "application/json; charset=utf-8" );

             post.setentity(s);

             res = client.execute(post);

             if (res.getstatusline().getstatuscode() == httpstatus.sc_ok) {

                 result = entityutils.tostring(res.getentity());

                 return httpstatus.sc_ok + "" ;

             }

         } catch (exception e) {

             if (res == null ) {

                 return "httpresponse 为 null!" ;

             }

             throw new runtimeexception(e);

         }

         if (res == null || res.getstatusline() == null ) {

             return "无响应" ;

         }

         return res.getstatusline().getstatuscode() + "" ;

     }

@test

   public void test12() throws exception {

     string host = "http://eipwcf.aspirecn.com/svcef/service1.svc/wcf_ef_msa_getdatainfo_p" ;

     httpclient client = new httpclient();

     jsonobject json = new jsonobject();

     json.put( "msgid" , msgid);

     string reslut=client.dopostdata(host, json);

   }

public static string dohttppostdata(string url, taskreleaseapprovalmodel tram)

             throws exception {

         stringbuffer sb = new stringbuffer();

         sb.append( "dohttppostdata:url:" + url + ",tram:" + tram.tostring() + ",contenttype:" + contenttype);

         logger.info(sb.tostring());

         string tmpstring = "" ;

         httppost request = new httppost(url);

         request.setheader( "accept" , "application/json" );

         request.setheader( "content-type" , "application/json" );

         objectmapper mapper = new objectmapper();

         string jsonstring;

         try {

             jsonstring = mapper.writevalueasstring(tram);

             stringentity entity = new stringentity(jsonstring, "utf-8" );

             request.setentity(entity);

             closeablehttpclient client = httpclients.createdefault();

             httpresponse response = client.execute(request);

             if (response.getstatusline().getstatuscode() == httpurlconnection.http_ok) {

                 tmpstring = entityutils.tostring(response.getentity());

                 logger.info( "the post result:tmpstring:{}" , tmpstring);

             } else {

                 logger.info( "the post failure:tmpstring:" , tmpstring);

                 throw new commonbusinessexception(commonconstants.task_release_wcf,

                         commonconstants.task_release_wcf_desc);

             }

         } catch (exception e) {

             logger.error(sb.tostring() + ":" + e.getmessage(), e.getcause());

             throw new commonbusinessexception(commonconstants.task_release_postwcf,

                     commonconstants.task_release_postwcf_desc);

         }

         return tmpstring;

     }