1 package com.example.xubin.irrigation;
3 import android.util.Log;
5 import org.apache.http.HttpResponse;
6 import org.apache.http.HttpVersion;
7 import org.apache.http.client.HttpClient;
8 import org.apache.http.client.methods.HttpPost;
9 import org.apache.http.conn.ClientConnectionManager;
10 import org.apache.http.conn.scheme.PlainSocketFactory;
11 import org.apache.http.conn.scheme.Scheme;
12 import org.apache.http.conn.scheme.SchemeRegistry;
13 import org.apache.http.conn.ssl.SSLSocketFactory;
14 import org.apache.http.entity.StringEntity;
15 import org.apache.http.impl.client.DefaultHttpClient;
16 import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
17 import org.apache.http.params.BasicHttpParams;
18 import org.apache.http.params.CoreConnectionPNames;
19 import org.apache.http.params.CoreProtocolPNames;
20 import org.apache.http.params.HttpParams;
21 import org.apache.http.protocol.HTTP;
22 import org.json.JSONArray;
23 import org.json.JSONObject;
25 import java.io.BufferedReader;
26 import java.io.IOException;
27 import java.io.InputStream;
28 import java.io.InputStreamReader;
29 import java.io.BufferedInputStream;
30 import java.util.List;
31 import java.security.cert.CertificateFactory;
32 import java.security.cert.Certificate;
33 import java.security.cert.X509Certificate;
34 import java.security.KeyStore;
37 * Created by xubin on 4/26/16.
40 private static final int Driver_port = 8000;
41 private static final String Tag = "http";
42 private static final String KEYEXT = ".pem";
44 HttpClient httpclient;
46 void setConnection(String destIP) {
48 httpclient = createClient(destIP);
51 HttpClient createClient(String destIP) {
52 HttpParams params = new BasicHttpParams();
53 params.setParameter(CoreProtocolPNames.PROTOCOL_VERSION, HttpVersion.HTTP_1_1);
54 params.setParameter(CoreProtocolPNames.HTTP_CONTENT_CHARSET, HTTP.DEFAULT_CONTENT_CHARSET);
55 params.setBooleanParameter(CoreProtocolPNames.USE_EXPECT_CONTINUE, true);
56 params.setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 30 * 1000);
57 params.setParameter(CoreConnectionPNames.SO_TIMEOUT, 30 * 1000);
59 SchemeRegistry schReg = new SchemeRegistry();
60 schReg.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), Driver_port));
61 schReg.register(new Scheme("https", newSslSocketFactory(destIP), 443));
62 ClientConnectionManager conMgr = new ThreadSafeClientConnManager(params, schReg);
64 return new DefaultHttpClient(conMgr, params);
68 public void makeRequest(String destIP, List<Object> paramObjects, String methodName) {
69 String url = "https://"+ destIP + ":"+Driver_port+ "/"+methodName;
70 System.out.println("URL: " + url);
71 InputStream inputStream = null;
74 HttpPost httpPost = new HttpPost(url);
75 JSONArray params = new JSONArray();
77 JSONObject parent = new JSONObject();
78 for (int i = 0; i < paramObjects.size(); i++) {
79 JSONObject content = new JSONObject();
80 content.put("type", paramObjects.get(i).getClass().getName());
81 content.put("value", paramObjects.get(i));
82 params.put(i, content);
84 parent.put("params", params);
85 StringEntity se = new StringEntity(parent.toString());
86 httpPost.setEntity(se);
87 httpPost.setHeader("Accept", "application/json");
88 httpPost.setHeader("Content-type", "application/json");
89 HttpResponse httpResponse = httpclient.execute(httpPost);
90 // 9. receive response as inputStream
91 inputStream = httpResponse.getEntity().getContent();
93 // 10. convert inputstream to string
94 if(inputStream != null)
95 result = convertInputStreamToString(inputStream);
97 result = "Did not work!";
99 } catch (Exception ex) {
100 if (ex.getMessage() != null) {
101 Log.v(Tag, ex.getMessage());
103 ex.printStackTrace();
107 private SSLSocketFactory newSslSocketFactory(String destIP) {
109 // Load CAs from an InputStream
110 CertificateFactory cf = CertificateFactory.getInstance("X.509");
111 InputStream caInput = new
112 BufferedInputStream(MainActivity.context.getAssets().open(destIP + KEYEXT));
115 ca = cf.generateCertificate(caInput);
116 System.out.println("ca=" + ((X509Certificate) ca).getSubjectDN());
120 String keyStoreType = KeyStore.getDefaultType();
121 KeyStore keyStore = KeyStore.getInstance(keyStoreType);
122 keyStore.load(null, null);
123 keyStore.setCertificateEntry("ca", ca);
124 SSLSocketFactory socketFactory = new SSLSocketFactory(keyStore);
125 return socketFactory;
126 } catch (Exception e) {
127 throw new AssertionError(e);
131 private static String convertInputStreamToString(InputStream inputStream) throws IOException {
132 BufferedReader bufferedReader = new BufferedReader( new InputStreamReader(inputStream));
135 while((line = bufferedReader.readLine()) != null)