Web Service Connection Reset Problem

jay_goh

Dear All,
Sorry to write this in english because of my company PC is not able to write in chinese.
The scenario is I need to write a webservice client to send request to a third party server and the third party server will returns the result back to my server.
However, I got the connection reset error while trying to perform connection to the third party server.
I am using Java 1.5 IBM and our web server is running on Oracle iPlanet Web Server 7.0.13.
The code to send the request from my side

1. try
   
2.                 {
   
3.                         int intStatus;
   
4.                         String szResMsg;
   
5.                         String szResContent;
   
6.                        
   
7.                         HttpsURLConnectionFactory factory = new HttpsURLConnectionFactory("https://someuri", "someuri.com.my", path to the truststore", "password for the truststore");                       
   
8.                 
   
9.                         StringBuffer sbPost = new StringBuffer();
   
10.                         sbPost.append(jsonObject.toString());
    
11.                        
    
12.                 factory.setRequestContent(sbPost.toString().getBytes());
    
13.                 factory.setRequestMethod("POST");                
    
14.                 factory.setRequestProperty("content-type", "text/json");
    
15.                 
    
16.                 intStatus = factory.connect();
    
17.                         
    
18.                 szResMsg = factory.getResponseMessage();
    
19.                 szResContent = factory.getResponseContent();                
    
20.                 
    
21.                 logger.info("reading status: [" + intStatus + "]");
    
22.                 logger.info("reading reply msg: [" + szResMsg + "]");
    
23.                 logger.info("reading reply content: [" + szResContent + "]");
    
24.                 }
    
25.                 catch(Exception e)
    
26.                 {
    
27.                         logger.error("WSJsonParserServlet.sendJSONToWSServer: " + e.getMessage());
    
28.                         e.printStackTrace();
    
29.                         return false;
    
30.                 }

复制代码

The HttpsURLConnectionFactory code

1. public class HttpsURLConnectionFactory
   
2. {
   
3.     private static final String DEFAULT_KEYSTORE_TYPE   = "JKS";
   
4.     private static final String DEFAULT_ALGORITHM       = "SunX509";
   
5.     private static final String DEFAULT_SSL_PROTOCOL    = "TLS";
   
6.     private static final String DEFAULT_SSL_PROVIDER    = "SunJSSE";
   
7. 
   
8. 
   
9.     private String strURL                               = null;
   
10.     private HttpsURLConnection httpsURLConnection       = null;
    
11.     private String strTrustedHost                       = null;
    
12. 
    
13.     private String strKeyStore                          = null;
    
14.     private String strKeyStorePassword                  = null;
    
15.     private String strKeyPassword                       = null;
    
16. 
    
17.     private boolean bMutualAuth                         = false;
    
18.     private boolean bProxyExists                        = false;
    
19.     private String strProxyAuthCredential               = null;
    
20. 
    
21.     private String strRequestMethod                     = "GET";
    
22.     private Hashtable hRequestProperties                = null;
    
23. 
    
24.     private int intResponseCode                         = 0;
    
25.     private String strResponseContent                   = null;
    
26.     private String strResponseMessage                   = null;
    
27. 
    
28.     private Hashtable hResponseHeaders                  = new Hashtable();
    
29.     private byte[] bContent                             = null;
    
30.    
    
31.     private String strRequestPropertyKey                = null;
    
32.     private String strRequestPropertyValue              = null;
    
33. 
    
34.     private PBBLogger logger = PBBLogger.getInstance();
    
35. 
    
36. 
    
37.     public HttpsURLConnectionFactory(String strURL)
    
38.     {
    
39.         this.strURL = strURL;
    
40.     }
    
41. 
    
42.     public HttpsURLConnectionFactory(String strURL, String strTrustStore, String strTrustStorePassword)
    
43.             throws Exception
    
44.     {
    
45.         this.strURL = strURL;
    
46.         setSystemProperties();
    
47.         setTrustStore(strTrustStore, strTrustStorePassword);
    
48.     }
    
49. 
    
50.     public HttpsURLConnectionFactory(String strURL, String strTrustedHost, String strTrustStore,
    
51.             String strTrustStorePassword) throws Exception
    
52.     {
    
53.         this.strURL = strURL;
    
54.         this.strTrustedHost = strTrustedHost;
    
55.         setSystemProperties();
    
56.         setTrustStore(strTrustStore, strTrustStorePassword);
    
57.     }
    
58. 
    
59.     public HttpsURLConnectionFactory(String strURL, String strTrustStore, String strTrustStorePassword,
    
60.             String strKeyStore, String strKeyStorePassword, String strKeyPassword) throws Exception
    
61.     {
    
62.         this.strURL = strURL;
    
63.         this.strKeyStore = strKeyStore;
    
64.         this.strKeyStorePassword = strKeyStorePassword;
    
65.         this.strKeyPassword = strKeyPassword;
    
66.         this.bMutualAuth = true;
    
67.         setSystemProperties();
    
68.         setTrustStore(strTrustStore, strTrustStorePassword);
    
69.     }
    
70. 
    
71.     public HttpsURLConnectionFactory(String strURL, String strTrustedHost, String strTrustStore,
    
72.             String strTrustStorePassword, String strKeyStore, String strKeyStorePassword, String strKeyPassword)
    
73.             throws Exception
    
74.     {
    
75.         this.strURL = strURL;
    
76.         this.strTrustedHost = strTrustedHost;
    
77.         this.strKeyStore = strKeyStore;
    
78.         this.strKeyStorePassword = strKeyStorePassword;
    
79.         this.strKeyPassword = strKeyPassword;
    
80.         this.bMutualAuth = true;
    
81.         setSystemProperties();
    
82.         setTrustStore(strTrustStore, strTrustStorePassword);
    
83.     }
    
84. 
    
85. 
    
86.     /***************************************************************************
    
87.      * <p>
    
88.      * Set the system property for proxy.
    
89.      * </p>
    
90.      *
    
91.      * @Param String
    
92.      *            strProxyHost : Proxy host to tunnel through
    
93.      * @Param String
    
94.      *            strProxyPort : Proxy port to tunnel through
    
95.      **************************************************************************/
    
96.     public void setProxy(String strProxyHost, int intProxyPort)
    
97.     {
    
98.         System.setProperty("https.proxyHost", strProxyHost);
    
99.         System.setProperty("https.proxyPort", String.valueOf(intProxyPort));
    
100.         bProxyExists = true;
     
101. 
     
102.         logger.info("HttpsURLConnectionFactory.setProxy:Proxy Host is : [" + strProxyHost + "]");
     
103.         logger.info("HttpsURLConnectionFactory.setProxy:Proxy Port is : [" + intProxyPort + "]");
     
104.     }
     
105. 
     
106.     public void addProxyCredential(String strUsername, String strPassword)
     
107.     {
     
108.         String strUsernamePassword = strUsername + ":" + strPassword;
     
109.         strProxyAuthCredential = "Proxy-Authorization: Basic "
     
110.                 + new sun.misc.BASE64Encoder().encode(strUsernamePassword.getBytes());
     
111. 
     
112.         logger.info("HttpsURLConnectionFactory.addProxyCredential:Proxy Username is :[" + strUsername + "]");
     
113.         logger.info("HttpsURLConnectionFactory.addProxyCredential:Proxy Password is :[" + strPassword + "]");
     
114.     }
     
115. 
     
116.     public void setConnectionTimeout(int intConnectionTimeout)
     
117.     {
     
118.     }
     
119. 
     
120.     public void setRequestMethod(String strRequestMethod)
     
121.     {
     
122.         this.strRequestMethod = strRequestMethod;
     
123.         logger.info("HttpsURLConnectionFactory.setRequestMethod:Request Method is :[" + strRequestMethod + "]");
     
124.     }
     
125. 
     
126.     public void setRequestProperties(Hashtable hRequestProperties)
     
127.     {
     
128.         this.hRequestProperties = hRequestProperties;
     
129.     }
     
130.    
     
131.     public void setRequestContent(byte[] bContent)
     
132.     {
     
133.         this.bContent = bContent;
     
134.     }
     
135.    
     
136.     public void setRequestProperty(String strRequestPropertyKey, String strRequestPropertyValue)
     
137.     {
     
138.             this.strRequestPropertyKey = strRequestPropertyKey;
     
139.             this.strRequestPropertyValue = strRequestPropertyValue;
     
140.     }
     
141. 
     
142.     public HttpsURLConnection openConnection() throws Exception
     
143.     {
     
144.         try
     
145.         {
     
146.             logger.info("HttpsURLConnectionFactory.openConnection:Opening connection...");
     
147.             URL url = null;
     
148.             try
     
149.             {
     
150.                 url = new URL(getURL());
     
151.             }
     
152.             catch (MalformedURLException e)
     
153.             {
     
154.                 logger.error("HttpsURLConnectionFactory.openConnection:Exception - " + e.getMessage());
     
155.                 throw new Exception("HttpsURLConnectionFactory.openConnection:Invalid url address", e);
     
156.             }
     
157. 
     
158.             HttpsURLConnection httpsURLConnection = (HttpsURLConnection) url.openConnection();
     
159. 
     
160.             // Host name vs CN in certificate verification.If trusted host is
     
161.             // defined, HostNameVerifier will compare
     
162.             // trusted host against certificate host name, else host in url will
     
163.             // be compared against certificate host name.
     
164.             httpsURLConnection.setHostnameVerifier(new TrustedHostVerifier(strTrustedHost));
     
165. 
     
166.             // tunnel through proxy
     
167.             if (bProxyExists)
     
168.             {
     
169.                 if (strProxyAuthCredential == null)
     
170.                 {
     
171.                     httpsURLConnection.setSSLSocketFactory(new SSLTunnelSocketFactory(System
     
172.                             .getProperty("https.proxyHost"), System.getProperty("https.proxyPort")));
     
173.                 }
     
174.                 else
     
175.                 {
     
176.                     httpsURLConnection.setSSLSocketFactory(new SSLTunnelSocketFactory(System
     
177.                             .getProperty("https.proxyHost"), System.getProperty("https.proxyPort"),
     
178.                             strProxyAuthCredential));
     
179.                 }
     
180.             }
     
181. 
     
182.             // set mutual authentication if remote peer require client
     
183.             // authentication
     
184.             if (bMutualAuth)
     
185.             {
     
186.                 setMutualAuthentication(httpsURLConnection, strKeyStore, strKeyStorePassword, strKeyPassword);
     
187.             }
     
188. 
     
189.             // setting request method
     
190.             try
     
191.             {
     
192.                 httpsURLConnection.setRequestMethod(strRequestMethod);
     
193.             }
     
194.             catch (ProtocolException e)
     
195.             {
     
196.                 throw new Exception("HttpsURLConnectionFactory.openConnection:Set request method fail.", e);
     
197.             }
     
198. 
     
199.             // setting request property
     
200.             if (hRequestProperties != null)
     
201.             {
     
202.                 for (Enumeration e = hRequestProperties.keys(); e.hasMoreElements();)
     
203.                 {
     
204.                     String strRequestProperty = (String) e.nextElement();
     
205.                     httpsURLConnection.setRequestProperty(strRequestProperty, (String) hRequestProperties
     
206.                             .get(strRequestProperty));
     
207.                 }
     
208.             }
     
209.             
     
210.             // set single request property
     
211.             if(strRequestPropertyKey != null)
     
212.             {
     
213.                     httpsURLConnection.setRequestProperty(strRequestPropertyKey, strRequestPropertyValue);
     
214.             }
     
215.             
     
216.             httpsURLConnection.setDoInput(true);
     
217.             httpsURLConnection.setDoOutput(true);
     
218.             httpsURLConnection.setUseCaches(false);
     
219.             if (bContent != null)
     
220.             {
     
221.                 OutputStream out = httpsURLConnection.getOutputStream();
     
222.                 out.write(bContent);
     
223.                 out.flush();
     
224.                 out.close();
     
225.             }            
     
226.             setConnectionObject(httpsURLConnection);
     
227.         }
     
228.         catch (IOException e)
     
229.         {
     
230.             logger.error("HttpsURLConnectionFactory.openConnection:Exception - " + e.getMessage());
     
231.             throw new Exception("HttpsURLConnectionFactory.openConnection fail.", e);
     
232.         }
     
233.         return httpsURLConnection;
     
234.     }
     
235. 
     
236.     /***************************************************************************
     
237.      * <p>
     
238.      * Get reply message from remote peer.
     
239.      * </p>
     
240.      *
     
241.      * @return String : Reply message from remote peer
     
242.      **************************************************************************/
     
243.     public int connect() throws Exception
     
244.     {
     
245.         HttpsURLConnection httpsURLConnection = getConnectionObject();
     
246.         if (httpsURLConnection == null)
     
247.         {
     
248.             httpsURLConnection = openConnection();
     
249.         }
     
250. 
     
251.         // Connecting to url
     
252.         try
     
253.         {
     
254.             logger.info("HttpsURLConnectionFactory.connect:Connecting...");
     
255.             httpsURLConnection.connect();
     
256.         }
     
257.         catch (IOException e)
     
258.         {
     
259.             logger.error("HttpsURLConnectionFactory.connect:Exception - " + e.getMessage());
     
260.             throw new Exception("HttpsURLConnectionFactory:fail.", e);
     
261.         }
     
262. 
     
263.         // Reading reply from remote server
     
264.         try
     
265.         {
     
266.             logger.info("HttpsURLConnectionFactory.connect:Reading reply...");
     
267.             intResponseCode = httpsURLConnection.getResponseCode();
     
268.             setResponseMessage(httpsURLConnection.getResponseMessage());
     
269. 
     
270.             int i=1;
     
271.             while (httpsURLConnection.getHeaderField(i) != null)
     
272.             {
     
273.                 hResponseHeaders.put(httpsURLConnection.getHeaderFieldKey(i).toUpperCase(), httpsURLConnection.getHeaderField(i));
     
274.                 i++;
     
275.             }
     
276. 
     
277.             BufferedReader reader = new BufferedReader(new InputStreamReader(httpsURLConnection.getInputStream()));
     
278.             String strResponseContent = new String();
     
279.             for (String strTemp = null; (strTemp = reader.readLine()) != null;)
     
280.             {
     
281.                 strResponseContent += strTemp + "\n";
     
282.             }
     
283.             if (!strResponseContent.equals(""))
     
284.             {
     
285.                 strResponseContent = strResponseContent.substring(0, strResponseContent.lastIndexOf("\n"));
     
286.             }
     
287.             setResponseContent(strResponseContent);
     
288.             reader.close();
     
289.         }
     
290.         catch (IOException e)
     
291.         {
     
292.             logger.error("HttpsURLConnectionFactory.connect:Exception - " + e.getMessage());
     
293.             throw new Exception("HttpsURLConnectionFactory.connect:Fail to get reply from remote peer", e);
     
294.         }
     
295.         logger.info("HttpsURLConnectionFactory.connect:Disconnecting...");
     
296.         httpsURLConnection.disconnect();
     
297.         return intResponseCode;
     
298.     }
     
299. 
     
300.     public void setConnectionObject(HttpsURLConnection httpsURLConnection)
     
301.     {
     
302.         this.httpsURLConnection = httpsURLConnection;
     
303.     }
     
304. 
     
305.     public HttpsURLConnection getConnectionObject()
     
306.     {
     
307.         return this.httpsURLConnection;
     
308.     }
     
309. 
     
310.     public String getResponseMessage()
     
311.     {
     
312.         return this.strResponseMessage;
     
313.     }
     
314. 
     
315.     public String getResponseContent()
     
316.     {
     
317.         return this.strResponseContent;
     
318.     }
     
319. 
     
320.     public String getResponseHeader(String strHeader)
     
321.     {
     
322.         if (hResponseHeaders.containsKey(strHeader))
     
323.         {
     
324.             return (String)hResponseHeaders.get(strHeader);
     
325.         }
     
326.         else
     
327.         {
     
328.             return null;
     
329.         }
     
330.     }
     
331. 
     
332.     private String getURL()
     
333.     {
     
334.         return this.strURL;
     
335.     }
     
336. 
     
337.     private void setResponseMessage(String strResponseMessage)
     
338.     {
     
339.         this.strResponseMessage = strResponseMessage;
     
340.     }
     
341. 
     
342.     private void setResponseContent(String strResponseContent)
     
343.     {
     
344.         this.strResponseContent = strResponseContent;
     
345.     }
     
346. 
     
347.     /***************************************************************************
     
348.      * <p>
     
349.      * Set the related system properties values.
     
350.      * </p>
     
351.      **************************************************************************/
     
352.     private void setSystemProperties()
     
353.     {
     
354.         System.setProperty("javax.net.debug", "all");
     
355.         //System.setProperty("https.protocols", "TLSv1");
     
356. 
     
357.         // provider
     
358.         Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());
     
359.         System.setProperty("java.protocol.handler.pkgs","javax.net.ssl");
     
360.     }
     
361. 
     
362.     /***************************************************************************
     
363.      * <p>
     
364.      * Set truststore properties into system properties.
     
365.      * </p>
     
366.      *
     
367.      * @param String
     
368.      *            strtTrustStore : Truststore path
     
369.      * @param String
     
370.      *            strTrustStorePassword : Truststore password
     
371.      **************************************************************************/
     
372.     private void setTrustStore(String strTrustStore, String strTrustStorePassword) throws Exception
     
373.     {
     
374.         if (strTrustStore == null)
     
375.         {
     
376.             throw new Exception("Setting truststore fail due to null truststore path");
     
377.         }
     
378.         else if (strTrustStorePassword == null)
     
379.         {
     
380.             throw new Exception("Setting truststore fail due to null truststore password");
     
381.         }
     
382. 
     
383.         // set the truststore containing client trusted certificates into system properties.
     
384.         System.setProperty("javax.net.ssl.trustStore", strTrustStore);
     
385.         System.setProperty("javax.net.ssl.trustStorePassword", strTrustStorePassword);
     
386.     }
     
387. 
     
388.     /***************************************************************************
     
389.      * <p>
     
390.      * Set mutual authentication if the remote server required client
     
391.      * authentication.
     
392.      * </p>
     
393.      *
     
394.      * @param String
     
395.      *            strKeyStore : keystore path
     
396.      * @param String
     
397.      *            strKeyStorePassword : keystore password
     
398.      * @param String
     
399.      *            strKeyPassword : key password
     
400.      **************************************************************************/
     
401.     private void setMutualAuthentication(HttpsURLConnection httpsURLConnection, String strKeyStore,
     
402.             String strKeyStorePassword, String strKeyPassword) throws Exception
     
403.     {
     
404.         SSLContext sslContext = null;
     
405.         if (strKeyStore == null)
     
406.         {
     
407.             throw new Exception("Setting mutual authentication fail due to null keystore path");
     
408.         }
     
409.         else if (strKeyStorePassword == null)
     
410.         {
     
411.             throw new Exception("Setting mutual authentication fail due to null keystore password");
     
412.         }
     
413.         else if (strKeyPassword == null)
     
414.         {
     
415.             throw new Exception("Setting mutual authentication fail due to null key password");
     
416.         }
     
417. 
     
418.         try
     
419.         {
     
420.             sslContext = SSLContext.getInstance(DEFAULT_SSL_PROTOCOL, DEFAULT_SSL_PROVIDER);
     
421. 
     
422.         }
     
423.         catch (Exception e)
     
424.         {
     
425.             logger.error("HttpsURLConnectionFactory.setMutualAuthentication:Exception - " + e.getMessage());
     
426.             throw new Exception("HttpsURLConnectionFactory.setMutualAuthentication fail.", e);
     
427.         }
     
428. 
     
429.         try
     
430.         {
     
431.             // Load keystore containing server certificate.
     
432.             KeyStore keyStore = KeyStore.getInstance(DEFAULT_KEYSTORE_TYPE);
     
433.             char[] chKeyStorePassword = strKeyStorePassword.toCharArray();
     
434.             keyStore.load(new FileInputStream(strKeyStore), chKeyStorePassword);
     
435. 
     
436.             // Create specific Key Manager for mutual authentication.
     
437.             KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance(DEFAULT_ALGORITHM);
     
438.             char[] chKeyPassword = strKeyPassword.toCharArray();
     
439.             keyManagerFactory.init(keyStore, chKeyPassword);
     
440. 
     
441.             // Initialize the SSLContext with the created KeyManager.
     
442.             sslContext.init(keyManagerFactory.getKeyManagers(), null, null);
     
443.             SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
     
444. 
     
445.             // Set the sslSocketFactory into httpsURLConnection.
     
446.             httpsURLConnection.setSSLSocketFactory(sslSocketFactory);
     
447. 
     
448.         }
     
449.         catch (Exception e)
     
450.         {
     
451.             logger.error("HttpsURLConnectionFactory.setMutualAuthentication:Exception - " + e.getMessage());
     
452.             throw new Exception("HttpsURLConnectionFactory.setMutualAuthentication fail.", e);
     
453.         }
     
454.     }
     
455. }

复制代码

and the error returned
java.lang.Exception: HttpsURLConnectionFactory.openConnection fail.
      at com.pbb.mobile.common.net.HttpsURLConnectionFactory.openConnection(HttpsURLConnectionFactory.java:300)
      at com.pbb.mobile.common.net.HttpsURLConnectionFactory.connect(HttpsURLConnectionFactory.java:317)
       at WSJsonParserServlet.sendJSONToWSServer(WSJsonParserServlet.java:268)
       at WSJsonParserServlet.service(WSJsonParserServlet.java:164)
       at javax.servlet.http.HttpServlet.service(HttpServlet.java:915)
       at org.apache.catalina.servlets.InvokerServlet.serveRequest(InvokerServlet.java:459)
       at org.apache.catalina.servlets.InvokerServlet.doPost(InvokerServlet.java:180)
       at javax.servlet.http.HttpServlet.service(HttpServlet.java:814)
       at javax.servlet.http.HttpServlet.service(HttpServlet.java:915)
       at org.apache.catalina.core.ApplicationFilterChain.servletService(ApplicationFilterChain.java:398)
       at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:277)
       at org.apache.catalina.core.StandardContextValve.invokeInternal(StandardContextValve.java:255)
       at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:188)
       at org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.java:586)
       at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:556)
       at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:187)
       at org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.java:586)
       at org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.java:556)
       at com.sun.webserver.connector.nsapi.NSAPIProcessor.service(NSAPIProcessor.java:160)
Caused by: java.net.SocketException: Connection reset
       at java.net.SocketInputStream.read(SocketInputStream.java:168)
       at com.sun.net.ssl.internal.ssl.InputRecord.readFully(InputRecord.java:293)
       at com.sun.net.ssl.internal.ssl.InputRecord.read(InputRecord.java:331)
       at com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:798)
       at com.sun.net.ssl.internal.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1138)
       at com.sun.net.ssl.internal.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1165)
       at com.sun.net.ssl.internal.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1149)
       at sun.net.www.protocol.https.HttpsClient.afterConnect(HttpsClient.java:434)
       at sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:166)
       at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1014)
       at sun.net.www.protocol.https.HttpsURLConnectionImpl.getOutputStream(HttpsURLConnectionImpl.java:230)
       at com.pbb.mobile.common.net.HttpsURLConnectionFactory.openConnection(HttpsURLConnectionFactory.java:290)
       ... 18 more

Does anyone has any idea what possibly that could cause this error?
Appreciate very much for the help.
Thank you!

xtjj

It will be quicker if you post this question to stackoverflow.

samyong-wscreen

Handshake error. You were not able to start handshake due to your client certificate must be in the web service server for authentication.