package smsbao.internal;
|
|
import java.net.Socket;
|
|
import org.apache.http.ConnectionReuseStrategy;
|
import org.apache.http.Header;
|
import org.apache.http.HeaderIterator;
|
import org.apache.http.HttpHost;
|
import org.apache.http.HttpRequestInterceptor;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.HttpVersion;
|
import org.apache.http.entity.ByteArrayEntity;
|
import org.apache.http.impl.DefaultConnectionReuseStrategy;
|
import org.apache.http.impl.DefaultHttpClientConnection;
|
import org.apache.http.message.BasicHttpEntityEnclosingRequest;
|
import org.apache.http.params.HttpParams;
|
import org.apache.http.params.HttpProtocolParams;
|
import org.apache.http.params.SyncBasicHttpParams;
|
import org.apache.http.protocol.BasicHttpContext;
|
import org.apache.http.protocol.ExecutionContext;
|
import org.apache.http.protocol.HttpContext;
|
import org.apache.http.protocol.HttpProcessor;
|
import org.apache.http.protocol.HttpRequestExecutor;
|
import org.apache.http.protocol.ImmutableHttpProcessor;
|
import org.apache.http.protocol.RequestConnControl;
|
import org.apache.http.protocol.RequestContent;
|
import org.apache.http.protocol.RequestExpectContinue;
|
import org.apache.http.protocol.RequestTargetHost;
|
import org.apache.http.protocol.RequestUserAgent;
|
import org.apache.http.util.EntityUtils;
|
|
|
public class HttpClientUtil {
|
|
HttpParams params;
|
HttpProcessor httpproc;
|
HttpRequestExecutor httpexecutor;
|
HttpContext context;
|
HttpHost host;
|
DefaultHttpClientConnection conn;
|
ConnectionReuseStrategy connStrategy;
|
|
String sendURL = "";
|
|
public HttpClientUtil(String ip, int port, String SendURL) {
|
this.sendURL = SendURL;
|
params = new SyncBasicHttpParams();
|
HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1);
|
HttpProtocolParams.setContentCharset(params, "GB2312");
|
HttpProtocolParams.setUserAgent(params, "HttpComponents/1.1");
|
HttpProtocolParams.setUseExpectContinue(params, true);
|
|
httpproc = new ImmutableHttpProcessor(new HttpRequestInterceptor[] {
|
// Required protocol interceptors
|
new RequestContent(), new RequestTargetHost(),
|
// Recommended protocol interceptors
|
new RequestConnControl(), new RequestUserAgent(), new RequestExpectContinue() });
|
|
httpexecutor = new HttpRequestExecutor();
|
context = new BasicHttpContext(null);
|
host = new HttpHost(ip, port);
|
|
conn = new DefaultHttpClientConnection();
|
connStrategy = new DefaultConnectionReuseStrategy();
|
context.setAttribute(ExecutionContext.HTTP_CONNECTION, conn);
|
context.setAttribute(ExecutionContext.HTTP_TARGET_HOST, host);
|
}
|
|
public String sendGetMessage(String user, String pwd, String ServiceID, String dest, String sender, String msg) {
|
String msgid = "";
|
try {
|
|
if (!conn.isOpen()) {
|
Socket socket = new Socket(host.getHostName(), host.getPort());
|
conn.bind(socket, params);
|
}
|
String par = sendURL.trim() + "?src=%s&pwd=%s&ServiceID=%s&dest=%s&sender=%s&msg=%s";
|
String url = String.format(par, user, pwd, ServiceID, dest, sender, msg);
|
// String url = String.format(par, user, pwd, ServiceID, dest, sender,
|
// URLEncoder.encode(msg, "GB2312"));
|
BasicHttpEntityEnclosingRequest request = new BasicHttpEntityEnclosingRequest("GET", url);
|
request.getRequestLine().getUri();
|
// System.out.println(">> Request URI: " + request.getRequestLine().getUri());
|
|
request.setParams(params);
|
httpexecutor.preProcess(request, httpproc, context);
|
HttpResponse response = httpexecutor.execute(request, conn, context);
|
response.setParams(params);
|
|
httpexecutor.postProcess(response, httpproc, context);
|
|
response.getStatusLine();
|
// DeBug("<< Response: " + response.getStatusLine());
|
msgid = EntityUtils.toString(response.getEntity());
|
// DeBug(msgid);
|
// DeBug("==============");
|
if (!connStrategy.keepAlive(response, context)) {
|
conn.close();
|
} else {
|
// System.out.println("Connection kept alive...");
|
conn.close();
|
}
|
|
} catch (Exception e) {
|
msgid = "";
|
} finally {
|
return msgid;
|
}
|
}
|
|
public String sendPostMessage(String user, String pwd, String ServiceID, String dest, String sender, String msg) {
|
String msgid = "";
|
try {
|
|
String parf = "src=%s&pwd=%s&ServiceID=%s&dest=%s&sender=%s&msg=%s";
|
String par = String.format(parf, user, pwd, ServiceID, dest, sender, msg);
|
// String url = String.format(par, user, pwd, ServiceID, dest, sender,
|
// URLEncoder.encode(msg, "GB2312"));
|
BasicHttpEntityEnclosingRequest request = new BasicHttpEntityEnclosingRequest("POST", sendURL.trim());
|
request.getRequestLine().getUri();
|
// System.out.println(">> Request URI: " + request.getRequestLine().getUri());
|
|
// System.out.println(">> Request URI:" + par);
|
byte[] data1 = par.getBytes("ASCII");
|
ByteArrayEntity entiy = new ByteArrayEntity(data1);
|
// hwRequest.ContentType = "application/x-www-form-urlencoded";
|
// hwRequest.ContentLength = bData.Length;
|
entiy.setContentType("application/x-www-form-urlencoded");
|
request.setEntity(entiy);
|
|
request.getRequestLine().getMethod();
|
// System.out.println(">> Request URI: " + request.getRequestLine().getMethod());
|
request.setParams(params);
|
|
if (!conn.isOpen()) {
|
Socket socket = new Socket(host.getHostName(), host.getPort());
|
conn.bind(socket, params);
|
}
|
|
HeaderIterator it = request.headerIterator();
|
while (it.hasNext()) {
|
Header hesd = it.nextHeader();
|
// System.out.println(">> Request Header: " + hesd.getName() + " : " + hesd.getValue());
|
}
|
|
httpexecutor.preProcess(request, httpproc, context);
|
HttpResponse response = httpexecutor.execute(request, conn, context);
|
response.setParams(params);
|
|
httpexecutor.postProcess(response, httpproc, context);
|
|
response.getStatusLine();
|
// DeBug("<< Response: " + response.getStatusLine());
|
msgid = EntityUtils.toString(response.getEntity());
|
// DeBug(msgid);
|
// DeBug("==============");
|
if (!connStrategy.keepAlive(response, context)) {
|
conn.close();
|
} else {
|
// System.out.println("Connection kept alive...");
|
conn.close();
|
}
|
conn.close();
|
|
} catch (Exception e) {
|
msgid = "";
|
} finally {
|
return msgid;
|
}
|
}
|
|
public static void DeBug(Object obj) {
|
System.out.println(obj);
|
}
|
|
}
|
