我怎样才能使 HttpsURLConnection 和 SAX 解析器稳定工作?
How can I make it work HttpsURLConnection and SAX parser to be stable?
所以我使用了很好的 ol' HttpClient 没有问题,一切正常,直到 Android 6 次点击,然后我还必须添加一个 HttpsURLConnection,因为不幸的是我们的客户没有那么幸运拥有新的设备更新 Android,所以我将此代码添加到我已经开发的网络 class:
public static HashMap<String, Object> callSOAPServer(StringBuffer soap, String action) {
HttpsURLConnection urlConnection = null;
boolean download = true;
if (android.os.Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {
try {
CertificateFactory cf = CertificateFactory.getInstance("X.509");
InputStream caInput = IsakApp.appContext.getResources().openRawResource(R.raw.thawte);
Certificate ca;
try {
ca = cf.generateCertificate(caInput);
} finally {
caInput.close();
}
String keyStoreType = KeyStore.getDefaultType();
KeyStore keyStore = KeyStore.getInstance(keyStoreType);
keyStore.load(null, null);
keyStore.setCertificateEntry("ca", ca);
String tmfAlgorithm = TrustManagerFactory.getDefaultAlgorithm();
TrustManagerFactory tmf = TrustManagerFactory.getInstance(tmfAlgorithm);
tmf.init(keyStore);
SSLContext context = SSLContext.getInstance("TLS");
context.init(null, tmf.getTrustManagers(), null);
URL url = new URL("whateverPage.com");
urlConnection =
(HttpsURLConnection) url.openConnection();
urlConnection.setSSLSocketFactory(context.getSocketFactory());
urlConnection.setRequestMethod("POST");
urlConnection.setConnectTimeout(20000);
urlConnection.setReadTimeout(20000);
urlConnection.setDoInput(true);
urlConnection.setDoOutput(true);
urlConnection.setRequestProperty("Content-type", "text/xml; charset=utf-8");
urlConnection.setRequestProperty("SOAPAction", action);
OutputStream reqStream = urlConnection.getOutputStream();
reqStream.write(soap.toString().getBytes());
InputStream resStream = urlConnection.getInputStream();
byte[] data = new byte[1024 * 1024];
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
int count = urlConnection.getContentLength();
int total = 0;
int size = 0;
while ((count = resStream.read(data, 0, data.length)) != -1) {
buffer.write(data, 0, count);
}
buffer.flush();
String str = new String(buffer.toByteArray(), "UTF-8");
System.out.println("--------");
System.out.println(str);
String sn = str.replace("&", "AMP");
String[] stringArray = sn.split("\r?\n");
String soapNew = stringArray[1];
byte[] bytes = soapNew.getBytes("UTF-8");
HashMap<String, Object> xMap = new HashMap<String, Object>();
xMap.put(IsakApp.STATUS, "true");
xMap.put("soap", bytes);
resStream.close();
return xMap;
} catch (Exception e) {
e.printStackTrace();
} finally {
if( urlConnection != null) {
urlConnection.disconnect();
}
}
}
所以我的问题是这非常不可靠,并不总是下载我需要的所有数据,但是当我使用通过 HttpClient 工作的旧设备时,这个问题不存在。我的主要问题是:
System.err: org.apache.harmony.xml.ExpatParser$ParseException: At line 1, column 62973: no element found
System.err: at org.apache.harmony.xml.ExpatParser.finish(ExpatParser.java:545)
System.err: at org.apache.harmony.xml.ExpatParser.parseDocument(ExpatParser.java:475)
System.err: at org.apache.harmony.xml.ExpatReader.parse(ExpatReader.java:316)
System.err: at org.apache.harmony.xml.ExpatReader.parse(ExpatReader.java:279)
System.err: at com.czami.isakmobileapp.handling.XMLParser.parseSoap(XMLParser.java:153)
System.err: at com.czami.isakmobileapp.netInteraction.PostList.postList(PostList.java:44)
System.err: at com.czami.isakmobileapp.services.UpdateOneShot.onHandleIntent(UpdateOneShot.java:338)
问题是,那些 SOAP 消息,如果我将它们写入文件,它们会正常发送,没有任何问题。而且在 Android 版本小于 6 的情况下,它在 HttpClient 上工作正常,如果它被弃用则发生事件。现在我面临着相当大的问题,我不确定那有什么问题。某些 SOAP 消息可以毫无问题地通过,但似乎更大的消息不起作用。有人可以指出某个方向吗,我在这个应用程序上还有其他事情要做,这就像尝试了 2 天,但仍然没有成功。我可能会查看解释 HttpsURLConnection 的每个页面、此处的每个页面以及代码下方存在此问题的页面。我很绝望。感谢您的回答。
您仍然可以在新设备上使用旧的 Apache HTTP API。您只需在 gradle 文件中添加一个依赖项。将此添加到模块 build.gradle
文件的 android {}
块中:
android {
useLibrary 'org.apache.http.legacy'
}
完成后,您应该可以继续使用所有旧的 HttpClient
代码。
编辑
我想知道您是否因为请求大小或类似问题的性能问题而在传输过程中丢失数据。您可以尝试使用某些缓冲类型的阅读器。下面是我在我的一个应用程序中使用 HttpURLConnection
完成 SOAP 请求的一些代码。也许您可以尝试我使用的一些东西,看看它们是否有帮助,例如输入流的 BufferedReader
。
String result = null;
String requestInput = formatXmlRequest(input[0]); //returns a SOAP request String
URL url;
HttpURLConnection connection = null;
OutputStreamWriter out = null;
try {
url = new URL(WEB_SERVICE_URL);
connection = (HttpURLConnection) url.openConnection();
connection.setDoOutput(true);
connection.setDoInput(true);
connection.setRequestProperty("Content-Type", "application/soap+xml");
connection.setRequestProperty("Accept", "application/soap+xml");
out = new OutputStreamWriter(connection.getOutputStream());
out.write(requestInput);
out.flush();
StringBuilder stringBuilder = new StringBuilder();
int responseCode = connection.getResponseCode();
if(responseCode == HttpURLConnection.HTTP_OK) {
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"));
String line;
while((line = bufferedReader.readLine()) != null) {
stringBuilder.append(line).append("\n");
}
} else {
Log.d("BAD RESPONSE", "Response from server: "+responseCode);
}
result = stringBuilder.toString();
} catch (IOException ioe) {
ioe.printStackTrace();
} finally {
if(connection != null) connection.disconnect();
if(out != null) {
try {
out.close();
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
}
return result;
所以我使用了很好的 ol' HttpClient 没有问题,一切正常,直到 Android 6 次点击,然后我还必须添加一个 HttpsURLConnection,因为不幸的是我们的客户没有那么幸运拥有新的设备更新 Android,所以我将此代码添加到我已经开发的网络 class:
public static HashMap<String, Object> callSOAPServer(StringBuffer soap, String action) {
HttpsURLConnection urlConnection = null;
boolean download = true;
if (android.os.Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {
try {
CertificateFactory cf = CertificateFactory.getInstance("X.509");
InputStream caInput = IsakApp.appContext.getResources().openRawResource(R.raw.thawte);
Certificate ca;
try {
ca = cf.generateCertificate(caInput);
} finally {
caInput.close();
}
String keyStoreType = KeyStore.getDefaultType();
KeyStore keyStore = KeyStore.getInstance(keyStoreType);
keyStore.load(null, null);
keyStore.setCertificateEntry("ca", ca);
String tmfAlgorithm = TrustManagerFactory.getDefaultAlgorithm();
TrustManagerFactory tmf = TrustManagerFactory.getInstance(tmfAlgorithm);
tmf.init(keyStore);
SSLContext context = SSLContext.getInstance("TLS");
context.init(null, tmf.getTrustManagers(), null);
URL url = new URL("whateverPage.com");
urlConnection =
(HttpsURLConnection) url.openConnection();
urlConnection.setSSLSocketFactory(context.getSocketFactory());
urlConnection.setRequestMethod("POST");
urlConnection.setConnectTimeout(20000);
urlConnection.setReadTimeout(20000);
urlConnection.setDoInput(true);
urlConnection.setDoOutput(true);
urlConnection.setRequestProperty("Content-type", "text/xml; charset=utf-8");
urlConnection.setRequestProperty("SOAPAction", action);
OutputStream reqStream = urlConnection.getOutputStream();
reqStream.write(soap.toString().getBytes());
InputStream resStream = urlConnection.getInputStream();
byte[] data = new byte[1024 * 1024];
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
int count = urlConnection.getContentLength();
int total = 0;
int size = 0;
while ((count = resStream.read(data, 0, data.length)) != -1) {
buffer.write(data, 0, count);
}
buffer.flush();
String str = new String(buffer.toByteArray(), "UTF-8");
System.out.println("--------");
System.out.println(str);
String sn = str.replace("&", "AMP");
String[] stringArray = sn.split("\r?\n");
String soapNew = stringArray[1];
byte[] bytes = soapNew.getBytes("UTF-8");
HashMap<String, Object> xMap = new HashMap<String, Object>();
xMap.put(IsakApp.STATUS, "true");
xMap.put("soap", bytes);
resStream.close();
return xMap;
} catch (Exception e) {
e.printStackTrace();
} finally {
if( urlConnection != null) {
urlConnection.disconnect();
}
}
}
所以我的问题是这非常不可靠,并不总是下载我需要的所有数据,但是当我使用通过 HttpClient 工作的旧设备时,这个问题不存在。我的主要问题是:
System.err: org.apache.harmony.xml.ExpatParser$ParseException: At line 1, column 62973: no element found
System.err: at org.apache.harmony.xml.ExpatParser.finish(ExpatParser.java:545)
System.err: at org.apache.harmony.xml.ExpatParser.parseDocument(ExpatParser.java:475)
System.err: at org.apache.harmony.xml.ExpatReader.parse(ExpatReader.java:316)
System.err: at org.apache.harmony.xml.ExpatReader.parse(ExpatReader.java:279)
System.err: at com.czami.isakmobileapp.handling.XMLParser.parseSoap(XMLParser.java:153)
System.err: at com.czami.isakmobileapp.netInteraction.PostList.postList(PostList.java:44)
System.err: at com.czami.isakmobileapp.services.UpdateOneShot.onHandleIntent(UpdateOneShot.java:338)
问题是,那些 SOAP 消息,如果我将它们写入文件,它们会正常发送,没有任何问题。而且在 Android 版本小于 6 的情况下,它在 HttpClient 上工作正常,如果它被弃用则发生事件。现在我面临着相当大的问题,我不确定那有什么问题。某些 SOAP 消息可以毫无问题地通过,但似乎更大的消息不起作用。有人可以指出某个方向吗,我在这个应用程序上还有其他事情要做,这就像尝试了 2 天,但仍然没有成功。我可能会查看解释 HttpsURLConnection 的每个页面、此处的每个页面以及代码下方存在此问题的页面。我很绝望。感谢您的回答。
您仍然可以在新设备上使用旧的 Apache HTTP API。您只需在 gradle 文件中添加一个依赖项。将此添加到模块 build.gradle
文件的 android {}
块中:
android {
useLibrary 'org.apache.http.legacy'
}
完成后,您应该可以继续使用所有旧的 HttpClient
代码。
编辑
我想知道您是否因为请求大小或类似问题的性能问题而在传输过程中丢失数据。您可以尝试使用某些缓冲类型的阅读器。下面是我在我的一个应用程序中使用 HttpURLConnection
完成 SOAP 请求的一些代码。也许您可以尝试我使用的一些东西,看看它们是否有帮助,例如输入流的 BufferedReader
。
String result = null;
String requestInput = formatXmlRequest(input[0]); //returns a SOAP request String
URL url;
HttpURLConnection connection = null;
OutputStreamWriter out = null;
try {
url = new URL(WEB_SERVICE_URL);
connection = (HttpURLConnection) url.openConnection();
connection.setDoOutput(true);
connection.setDoInput(true);
connection.setRequestProperty("Content-Type", "application/soap+xml");
connection.setRequestProperty("Accept", "application/soap+xml");
out = new OutputStreamWriter(connection.getOutputStream());
out.write(requestInput);
out.flush();
StringBuilder stringBuilder = new StringBuilder();
int responseCode = connection.getResponseCode();
if(responseCode == HttpURLConnection.HTTP_OK) {
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"));
String line;
while((line = bufferedReader.readLine()) != null) {
stringBuilder.append(line).append("\n");
}
} else {
Log.d("BAD RESPONSE", "Response from server: "+responseCode);
}
result = stringBuilder.toString();
} catch (IOException ioe) {
ioe.printStackTrace();
} finally {
if(connection != null) connection.disconnect();
if(out != null) {
try {
out.close();
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
}
return result;