jdk8-mips64-public/jaxws: src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/client/HttpClientTransport.java@9c07ef4934dd (annotated)

src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/client/HttpClientTransport.java@9c07ef4934dd (annotated)

src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/client/HttpClientTransport.java

Thu, 31 Aug 2017 15:18:52 +0800

author: aoqi
date: Thu, 31 Aug 2017 15:18:52 +0800
changeset 637: 9c07ef4934dd
parent 368: 0989ad8c0860
parent 0: 373ffda63c9a
permissions: -rw-r--r--

merge

 /*
  * Copyright (c) 1997, 2012, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 only, as
  * published by the Free Software Foundation.  Oracle designates this
  * particular file as subject to the "Classpath" exception as provided
  * by Oracle in the LICENSE file that accompanied this code.
  *
  * This code is distributed in the hope that it will be useful, but WITHOUT
  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  * version 2 for more details (a copy is included in the LICENSE file that
  * accompanied this code).
  *
  * You should have received a copy of the GNU General Public License version
  * 2 along with this work; if not, write to the Free Software Foundation,
  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  *
  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  * or visit www.oracle.com if you need additional information or have any
  * questions.
  */
 package com.sun.xml.internal.ws.transport.http.client;
 import com.sun.xml.internal.ws.api.EndpointAddress;
 import com.sun.xml.internal.ws.api.message.Packet;
 import com.sun.xml.internal.ws.client.BindingProviderProperties;
 import static com.sun.xml.internal.ws.client.BindingProviderProperties.*;
 import com.sun.xml.internal.ws.client.ClientTransportException;
 import com.sun.xml.internal.ws.resources.ClientMessages;
 import com.sun.xml.internal.ws.transport.Headers;
 import com.sun.xml.internal.ws.developer.JAXWSProperties;
 import com.sun.istack.internal.Nullable;
 import com.sun.istack.internal.NotNull;
 import javax.net.ssl.SSLSocketFactory;
 import javax.net.ssl.HttpsURLConnection;
 import javax.net.ssl.HostnameVerifier;
 import javax.net.ssl.SSLSession;
 import javax.xml.bind.JAXBContext;
 import javax.xml.bind.JAXBException;
 import javax.xml.ws.WebServiceException;
 import javax.xml.ws.handler.MessageContext;
 import java.io.FilterInputStream;
 import java.io.FilterOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.net.HttpURLConnection;
 import java.util.List;
 import java.util.Map;
 import java.util.zip.GZIPOutputStream;
 import java.util.zip.GZIPInputStream;
 /**
  *
  * @author WS Development Team
  */
 public class HttpClientTransport {
     private static final byte[] THROW_AWAY_BUFFER = new byte[8192];
     // Need to use JAXB first to register DatatypeConverter
     static {
         try {
             JAXBContext.newInstance().createUnmarshaller();
         } catch(JAXBException je) {
             // Nothing much can be done. Intentionally left empty
         }
     }
     /*package*/ int statusCode;
     /*package*/ String statusMessage;
     /*package*/ int contentLength;
     private final Map<String, List<String>> reqHeaders;
     private Map<String, List<String>> respHeaders = null;
     private OutputStream outputStream;
     private boolean https;
     private HttpURLConnection httpConnection = null;
     private final EndpointAddress endpoint;
     private final Packet context;
     private final Integer chunkSize;
     public HttpClientTransport(@NotNull Packet packet, @NotNull Map<String,List<String>> reqHeaders) {
         endpoint = packet.endpointAddress;
         context = packet;
         this.reqHeaders = reqHeaders;
         chunkSize = (Integer)context.invocationProperties.get(JAXWSProperties.HTTP_CLIENT_STREAMING_CHUNK_SIZE);
     }
     /*
      * Prepare the stream for HTTP request
      */
     OutputStream getOutput() {
         try {
             createHttpConnection();
             // for "GET" request no need to get outputStream
             if (requiresOutputStream()) {
                 outputStream = httpConnection.getOutputStream();
                 if (chunkSize != null) {
                     outputStream = new WSChunkedOuputStream(outputStream, chunkSize);
                 }
                 List<String> contentEncoding = reqHeaders.get("Content-Encoding");
                 // TODO need to find out correct encoding based on q value - RFC 2616
                 if (contentEncoding != null && contentEncoding.get(0).contains("gzip")) {
                     outputStream = new GZIPOutputStream(outputStream);
                 }
             }
             httpConnection.connect();
         } catch (Exception ex) {
             throw new ClientTransportException(
                 ClientMessages.localizableHTTP_CLIENT_FAILED(ex),ex);
         }
         return outputStream;
     }
     void closeOutput() throws IOException {
         if (outputStream != null) {
             outputStream.close();
             outputStream = null;
         }
     }
     /*
      * Get the response from HTTP connection and prepare the input stream for response
      */
     @Nullable InputStream getInput() {
         // response processing
         InputStream in;
         try {
             in = readResponse();
             if (in != null) {
                 String contentEncoding = httpConnection.getContentEncoding();
                 if (contentEncoding != null && contentEncoding.contains("gzip")) {
                     in = new GZIPInputStream(in);
                 }
             }
         } catch (IOException e) {
             throw new ClientTransportException(ClientMessages.localizableHTTP_STATUS_CODE(statusCode, statusMessage), e);
         }
         return in;
     }
     public Map<String, List<String>> getHeaders() {
         if (respHeaders != null) {
             return respHeaders;
         }
         respHeaders = new Headers();
         respHeaders.putAll(httpConnection.getHeaderFields());
         return respHeaders;
     }
     protected @Nullable InputStream readResponse() {
         InputStream is;
         try {
             is = httpConnection.getInputStream();
         } catch(IOException ioe) {
             is = httpConnection.getErrorStream();
         }
         if (is == null) {
             return is;
         }
         // Since StreamMessage doesn't read </s:Body></s:Envelope>, there
         // are some bytes left in the InputStream. This confuses JDK and may
         // not reuse underlying sockets. Hopefully JDK fixes it in its code !
         final InputStream temp = is;
         return new FilterInputStream(temp) {
             // Workaround for "SJSXP XMLStreamReader.next() closes stream".
             // So it doesn't read from the closed stream
             boolean closed;
             @Override
             public void close() throws IOException {
                 if (!closed) {
                     closed = true;
                     while(temp.read(THROW_AWAY_BUFFER) != -1);
                     super.close();
                 }
             }
         };
     }
     protected void readResponseCodeAndMessage() {
         try {
             statusCode = httpConnection.getResponseCode();
             statusMessage = httpConnection.getResponseMessage();
             contentLength = httpConnection.getContentLength();
         } catch(IOException ioe) {
             throw new WebServiceException(ioe);
         }
     }
     protected HttpURLConnection openConnection(Packet packet) {
         // default do nothing
         return null;
     }
     protected boolean checkHTTPS(HttpURLConnection connection) {
         if (connection instanceof HttpsURLConnection) {
             // TODO The above property needs to be removed in future version as the semantics of this property are not preoperly defined.
             // One should use JAXWSProperties.HOSTNAME_VERIFIER to control the behavior
             // does the client want client hostname verification by the service
             String verificationProperty =
                 (String) context.invocationProperties.get(HOSTNAME_VERIFICATION_PROPERTY);
             if (verificationProperty != null) {
                 if (verificationProperty.equalsIgnoreCase("true")) {
                     ((HttpsURLConnection) connection).setHostnameVerifier(new HttpClientVerifier());
                 }
             }
             // Set application's HostNameVerifier for this connection
             HostnameVerifier verifier =
                 (HostnameVerifier) context.invocationProperties.get(JAXWSProperties.HOSTNAME_VERIFIER);
             if (verifier != null) {
                 ((HttpsURLConnection) connection).setHostnameVerifier(verifier);
             }
             // Set application's SocketFactory for this connection
             SSLSocketFactory sslSocketFactory =
                 (SSLSocketFactory) context.invocationProperties.get(JAXWSProperties.SSL_SOCKET_FACTORY);
             if (sslSocketFactory != null) {
                 ((HttpsURLConnection) connection).setSSLSocketFactory(sslSocketFactory);
             }
             return true;
         }
         return false;
     }
     private void createHttpConnection() throws IOException {
         httpConnection = openConnection(context);
         if (httpConnection == null)
                 httpConnection = (HttpURLConnection) endpoint.openConnection();
         String scheme = endpoint.getURI().getScheme();
         if (scheme.equals("https")) {
             https = true;
         }
         if (checkHTTPS(httpConnection))
                 https = true;
         // allow interaction with the web page - user may have to supply
         // username, password id web page is accessed from web browser
         httpConnection.setAllowUserInteraction(true);
         // enable input, output streams
         httpConnection.setDoOutput(true);
         httpConnection.setDoInput(true);
         String requestMethod = (String) context.invocationProperties.get(MessageContext.HTTP_REQUEST_METHOD);
         String method = (requestMethod != null) ? requestMethod : "POST";
         httpConnection.setRequestMethod(method);
         //this code or something similiar needs t be moved elsewhere for error checking
         /*if (context.invocationProperties.get(BindingProviderProperties.BINDING_ID_PROPERTY).equals(HTTPBinding.HTTP_BINDING)){
             method = (requestMethod != null)?requestMethod:method;
         } else if
             (context.invocationProperties.get(BindingProviderProperties.BINDING_ID_PROPERTY).equals(SOAPBinding.SOAP12HTTP_BINDING) &&
             "GET".equalsIgnoreCase(requestMethod)) {
         }
        */
         Integer reqTimeout = (Integer)context.invocationProperties.get(BindingProviderProperties.REQUEST_TIMEOUT);
         if (reqTimeout != null) {
             httpConnection.setReadTimeout(reqTimeout);
         }
         Integer connectTimeout = (Integer)context.invocationProperties.get(JAXWSProperties.CONNECT_TIMEOUT);
         if (connectTimeout != null) {
             httpConnection.setConnectTimeout(connectTimeout);
         }
         Integer chunkSize = (Integer)context.invocationProperties.get(JAXWSProperties.HTTP_CLIENT_STREAMING_CHUNK_SIZE);
         if (chunkSize != null) {
             httpConnection.setChunkedStreamingMode(chunkSize);
         }
         // set the properties on HttpURLConnection
         for (Map.Entry<String, List<String>> entry : reqHeaders.entrySet()) {
             if ("Content-Length".equals(entry.getKey())) continue;
                 for(String value : entry.getValue()) {
                     httpConnection.addRequestProperty(entry.getKey(), value);
                 }
         }
     }
     boolean isSecure() {
         return https;
     }
     protected void setStatusCode(int statusCode) {
         this.statusCode = statusCode;
     }
     private boolean requiresOutputStream() {
         return !(httpConnection.getRequestMethod().equalsIgnoreCase("GET") ||
                 httpConnection.getRequestMethod().equalsIgnoreCase("HEAD") ||
                 httpConnection.getRequestMethod().equalsIgnoreCase("DELETE"));
     }
     @Nullable String getContentType() {
         return httpConnection.getContentType();
     }
     public int getContentLength() {
         return httpConnection.getContentLength();
     }
     // overide default SSL HttpClientVerifier to always return true
     // effectively overiding Hostname client verification when using SSL
     private static class HttpClientVerifier implements HostnameVerifier {
         public boolean verify(String s, SSLSession sslSession) {
             return true;
         }
     }
     private static class LocalhostHttpClientVerifier implements HostnameVerifier {
         public boolean verify(String s, SSLSession sslSession) {
             return "localhost".equalsIgnoreCase(s) || "127.0.0.1".equals(s);
         }
     }
     /**
      * HttpURLConnection.getOuputStream() returns sun.net.www.http.ChunkedOuputStream in chunked
      * streaming mode. If you call ChunkedOuputStream.write(byte[20MB], int, int), then the whole data
      * is kept in memory. This wraps the ChunkedOuputStream so that it writes only small
      * chunks.
      */
     private static final class WSChunkedOuputStream extends FilterOutputStream {
         final int chunkSize;
         WSChunkedOuputStream(OutputStream actual, int chunkSize) {
             super(actual);
             this.chunkSize = chunkSize;
         }
         @Override
         public void write(byte b[], int off, int len) throws IOException {
             while(len > 0) {
                 int sent = (len > chunkSize) ? chunkSize : len;
                 out.write(b, off, sent);        // don't use super.write() as it writes byte-by-byte
                 len -= sent;
                 off += sent;
             }
         }
     }
 }

Mercurial > jdk8-mips64-public > jaxws / annotate

src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/client/HttpClientTransport.java@9c07ef4934dd (annotated)

src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/client/HttpClientTransport.java