HttpClient几种实现方式

1.使用java原生HttpURLConnection访问web服务。

public class RTBClient {
private String url = <a target=_blank href="http://localhost">http://localhost</a>;
private String port = "8080";
private String path = "/RTBServer/RTBServer";

public RTBClient() {}
public Result[] get(DspContext dc) {
if (null == dc ) {
return null;
}
URL url = null;
HttpURLConnection urlConn = null;
try {
url = new URL(this.url + ":" + this.port + this.path);
urlConn = (HttpURLConnection) url.openConnection();
urlConn.setDoOutput(true);
urlConn.setDoInput(true);
urlConn.setUseCaches(false);
urlConn.setRequestProperty("Content-type",
"application/x-java-serialized-object");
urlConn.setRequestMethod("POST");
urlConn.connect();
} catch (MalformedURLException e1) {
e1.printStackTrace();
} catch (ProtocolException e1) {
e1.printStackTrace();
} catch (IOException e1) {
e1.printStackTrace();
}

try {
OutputStream  outStrm = urlConn.getOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(outStrm);
oos.writeObject(dc);
oos.flush();
oos.close();
} catch (IOException e1) {
e1.printStackTrace();
}

Result[] result;
try {
InputStream inStrm = urlConn.getInputStream();
ObjectInputStream ois = new ObjectInputStream(inStrm);
result = (Result[]) (ois.readObject());
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (EOFException e) {
e.printStackTrace();
} catch (IOException e1) {
e1.printStackTrace();
}
urlConn.disconnect();
return null;
}
}

public class RtbClient {
private String address = null;
private int connReqTimeout = 5000;
private int connTimeout = 5000;
private int soTimeout = 5000;
private int maxConn = 100;
private HttpClient httpClient = null;
PoolingHttpClientConnectionManager connManager = null;

public RtbClient(String address, int connReqTimeout, int connTimeout, int soTimeout, int maxConn) {
this.address = address;
this.connReqTimeout = connReqTimeout;
this.connTimeout = connTimeout;
this.soTimeout = soTimeout;
this.maxConn = maxConn;
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(this.connTimeout)
.setConnectionRequestTimeout(this.connReqTimeout)
.setSocketTimeout(this.soTimeout).build();
this.connManager = new PoolingHttpClientConnectionManager();
this.connManager.setMaxTotal(this.maxConn);
this.httpClient = HttpClientBuilder.create()
.setConnectionManager(this.connManager).setDefaultRequestConfig(requestConfig).build();
}

public void sendReq(String str) {
HttpPost post = new HttpPost(address);

HttpEntity entity = new StringEntity(str);

post.setEntity(entity);

HttpResponse response;
try {
response = this.httpClient.execute(post);
if (null != response) {
System.out.println(response.getStatusLine().getStatusCode());
}
} catch (HttpHostConnectException e) {
logger.error("client can not connect server!", e);
e.printStackTrace();
} catch (Exception e) {
logger.error("rtb client get method invoke exception!", e);
e.printStackTrace();
}

return;
}

}