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

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

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

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

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

merge

 /*
  * Copyright (c) 1997, 2013, 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.istack.internal.NotNull;
 import com.sun.xml.internal.ws.api.SOAPVersion;
 import com.sun.xml.internal.ws.api.WSBinding;
 import com.sun.xml.internal.ws.api.ha.StickyFeature;
 import com.sun.xml.internal.ws.api.message.Packet;
 import com.sun.xml.internal.ws.api.pipe.*;
 import com.sun.xml.internal.ws.api.pipe.helper.AbstractTubeImpl;
 import com.sun.xml.internal.ws.client.ClientTransportException;
 import com.sun.xml.internal.ws.developer.HttpConfigFeature;
 import com.sun.xml.internal.ws.resources.ClientMessages;
 import com.sun.xml.internal.ws.resources.WsservletMessages;
 import com.sun.xml.internal.ws.transport.Headers;
 import com.sun.xml.internal.ws.transport.http.HttpAdapter;
 import com.sun.xml.internal.ws.util.ByteArrayBuffer;
 import com.sun.xml.internal.ws.util.RuntimeVersion;
 import com.sun.xml.internal.ws.util.StreamUtils;
 import javax.xml.bind.DatatypeConverter;
 import javax.xml.ws.BindingProvider;
 import javax.xml.ws.WebServiceException;
 import javax.xml.ws.WebServiceFeature;
 import javax.xml.ws.handler.MessageContext;
 import javax.xml.ws.soap.SOAPBinding;
 import java.io.*;
 import java.net.CookieHandler;
 import java.net.HttpURLConnection;
 import java.util.*;
 import java.util.Map.Entry;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 /**
  * {@link Tube} that sends a request to a remote HTTP server.
  *
  * TODO: need to create separate HTTP transport pipes for binding. SOAP1.1, SOAP1.2,
  * TODO: XML/HTTP differ in handling status codes.
  *
  * @author Jitendra Kotamraju
  */
 public class HttpTransportPipe extends AbstractTubeImpl {
     private static final List<String> USER_AGENT = Collections.singletonList(RuntimeVersion.VERSION.toString());
     private static final Logger LOGGER = Logger.getLogger(HttpTransportPipe.class.getName());
     /**
      * Dumps what goes across HTTP transport.
      */
     public static boolean dump;
     private final Codec codec;
     private final WSBinding binding;
     private final CookieHandler cookieJar;      // shared object among the tubes
     private final boolean sticky;
     static {
         boolean b;
         try {
             b = Boolean.getBoolean(HttpTransportPipe.class.getName()+".dump");
         } catch( Throwable t ) {
             b = false;
         }
         dump = b;
     }
     public HttpTransportPipe(Codec codec, WSBinding binding) {
         this.codec = codec;
         this.binding = binding;
         this.sticky = isSticky(binding);
         HttpConfigFeature configFeature = binding.getFeature(HttpConfigFeature.class);
         if (configFeature == null) {
             configFeature = new HttpConfigFeature();
         }
         this.cookieJar = configFeature.getCookieHandler();
     }
     private static boolean isSticky(WSBinding binding) {
         boolean tSticky = false;
         WebServiceFeature[] features = binding.getFeatures().toArray();
         for(WebServiceFeature f : features) {
             if (f instanceof StickyFeature) {
                 tSticky = true;
                 break;
             }
         }
         return tSticky;
     }
     /*
      * Copy constructor for {@link Tube#copy(TubeCloner)}.
      */
     private HttpTransportPipe(HttpTransportPipe that, TubeCloner cloner) {
         this(that.codec.copy(), that.binding);
         cloner.add(that,this);
     }
     @Override
     public NextAction processException(@NotNull Throwable t) {
         return doThrow(t);
     }
     @Override
     public NextAction processRequest(@NotNull Packet request) {
         return doReturnWith(process(request));
     }
     @Override
     public NextAction processResponse(@NotNull Packet response) {
         return doReturnWith(response);
     }
     protected HttpClientTransport getTransport(Packet request, Map<String, List<String>> reqHeaders) {
         return new HttpClientTransport(request, reqHeaders);
     }
     @Override
     public Packet process(Packet request) {
         HttpClientTransport con;
         try {
             // get transport headers from message
             Map<String, List<String>> reqHeaders = new Headers();
             @SuppressWarnings("unchecked")
             Map<String, List<String>> userHeaders = (Map<String, List<String>>) request.invocationProperties.get(MessageContext.HTTP_REQUEST_HEADERS);
             boolean addUserAgent = true;
             if (userHeaders != null) {
                 // userHeaders may not be modifiable like SingletonMap, just copy them
                 reqHeaders.putAll(userHeaders);
                 // application wants to use its own User-Agent header
                 if (userHeaders.get("User-Agent") != null) {
                     addUserAgent = false;
                 }
             }
             if (addUserAgent) {
                 reqHeaders.put("User-Agent", USER_AGENT);
             }
             addBasicAuth(request, reqHeaders);
             addCookies(request, reqHeaders);
             con = getTransport(request, reqHeaders);
             request.addSatellite(new HttpResponseProperties(con));
             ContentType ct = codec.getStaticContentType(request);
             if (ct == null) {
                 ByteArrayBuffer buf = new ByteArrayBuffer();
                 ct = codec.encode(request, buf);
                 // data size is available, set it as Content-Length
                 reqHeaders.put("Content-Length", Collections.singletonList(Integer.toString(buf.size())));
                 reqHeaders.put("Content-Type", Collections.singletonList(ct.getContentType()));
                 if (ct.getAcceptHeader() != null) {
                     reqHeaders.put("Accept", Collections.singletonList(ct.getAcceptHeader()));
                 }
                 if (binding instanceof SOAPBinding) {
                     writeSOAPAction(reqHeaders, ct.getSOAPActionHeader());
                 }
                 if (dump || LOGGER.isLoggable(Level.FINER)) {
                     dump(buf, "HTTP request", reqHeaders);
                 }
                 buf.writeTo(con.getOutput());
             } else {
                 // Set static Content-Type
                 reqHeaders.put("Content-Type", Collections.singletonList(ct.getContentType()));
                 if (ct.getAcceptHeader() != null) {
                     reqHeaders.put("Accept", Collections.singletonList(ct.getAcceptHeader()));
                 }
                 if (binding instanceof SOAPBinding) {
                     writeSOAPAction(reqHeaders, ct.getSOAPActionHeader());
                 }
                 if(dump || LOGGER.isLoggable(Level.FINER)) {
                     ByteArrayBuffer buf = new ByteArrayBuffer();
                     codec.encode(request, buf);
                     dump(buf, "HTTP request - "+request.endpointAddress, reqHeaders);
                     OutputStream out = con.getOutput();
                     if (out != null) {
                         buf.writeTo(out);
                     }
                 } else {
                     OutputStream os = con.getOutput();
                     if (os != null) {
                         codec.encode(request, os);
                     }
                 }
             }
             con.closeOutput();
             return createResponsePacket(request, con);
         } catch(WebServiceException wex) {
             throw wex;
         } catch(Exception ex) {
             throw new WebServiceException(ex);
         }
     }
     private Packet createResponsePacket(Packet request, HttpClientTransport con) throws IOException {
         con.readResponseCodeAndMessage();   // throws IOE
         recordCookies(request, con);
         InputStream responseStream = con.getInput();
         if (dump || LOGGER.isLoggable(Level.FINER)) {
             ByteArrayBuffer buf = new ByteArrayBuffer();
             if (responseStream != null) {
                 buf.write(responseStream);
                 responseStream.close();
             }
             dump(buf,"HTTP response - "+request.endpointAddress+" - "+con.statusCode, con.getHeaders());
             responseStream = buf.newInputStream();
         }
         // Check if stream contains any data
         int cl = con.contentLength;
         InputStream tempIn = null;
         if (cl == -1) {                     // No Content-Length header
             tempIn = StreamUtils.hasSomeData(responseStream);
             if (tempIn != null) {
                 responseStream = tempIn;
             }
         }
         if (cl == 0 || (cl == -1 && tempIn == null)) {
             if(responseStream != null) {
                 responseStream.close();         // No data, so close the stream
                 responseStream = null;
             }
         }
         // Allows only certain http status codes for a binding. For all
         // other status codes, throws exception
         checkStatusCode(responseStream, con); // throws ClientTransportException
         Packet reply = request.createClientResponse(null);
         reply.wasTransportSecure = con.isSecure();
         if (responseStream != null) {
             String contentType = con.getContentType();
             if (contentType != null && contentType.contains("text/html") && binding instanceof SOAPBinding) {
                 throw new ClientTransportException(ClientMessages.localizableHTTP_STATUS_CODE(con.statusCode, con.statusMessage));
             }
             codec.decode(responseStream, contentType, reply);
         }
         return reply;
     }
     /*
      * Allows the following HTTP status codes.
      * SOAP 1.1/HTTP - 200, 202, 500
      * SOAP 1.2/HTTP - 200, 202, 400, 500
      * XML/HTTP - all
      *
      * For all other status codes, it throws an exception
      */
     private void checkStatusCode(InputStream in, HttpClientTransport con) throws IOException {
         int statusCode = con.statusCode;
         String statusMessage = con.statusMessage;
         // SOAP1.1 and SOAP1.2 differ here
         if (binding instanceof SOAPBinding) {
             if (binding.getSOAPVersion() == SOAPVersion.SOAP_12) {
                 //In SOAP 1.2, Fault messages can be sent with 4xx and 5xx error codes
                 if (statusCode == HttpURLConnection.HTTP_OK || statusCode == HttpURLConnection.HTTP_ACCEPTED || isErrorCode(statusCode)) {
                     // acceptable status codes for SOAP 1.2
                     if (isErrorCode(statusCode) && in == null) {
                         // No envelope for the error, so throw an exception with http error details
                         throw new ClientTransportException(ClientMessages.localizableHTTP_STATUS_CODE(statusCode, statusMessage));
                     }
                     return;
                 }
             } else {
                 // SOAP 1.1
                 if (statusCode == HttpURLConnection.HTTP_OK || statusCode == HttpURLConnection.HTTP_ACCEPTED || statusCode == HttpURLConnection.HTTP_INTERNAL_ERROR) {
                     // acceptable status codes for SOAP 1.1
                     if (statusCode == HttpURLConnection.HTTP_INTERNAL_ERROR && in == null) {
                         // No envelope for the error, so throw an exception with http error details
                         throw new ClientTransportException(ClientMessages.localizableHTTP_STATUS_CODE(statusCode, statusMessage));
                     }
                     return;
                 }
             }
             if (in != null) {
                 in.close();
             }
             throw new ClientTransportException(ClientMessages.localizableHTTP_STATUS_CODE(statusCode, statusMessage));
         }
         // Every status code is OK for XML/HTTP
     }
     private boolean isErrorCode(int code) {
         //if(code/100 == 5/*Server-side error*/ || code/100 == 4 /*client error*/ ) {
         return code == 500 || code == 400;
     }
     private void addCookies(Packet context, Map<String, List<String>> reqHeaders) throws IOException {
         Boolean shouldMaintainSessionProperty =
                 (Boolean) context.invocationProperties.get(BindingProvider.SESSION_MAINTAIN_PROPERTY);
         if (shouldMaintainSessionProperty != null && !shouldMaintainSessionProperty) {
             return;         // explicitly turned off
         }
         if (sticky || (shouldMaintainSessionProperty != null && shouldMaintainSessionProperty)) {
             Map<String, List<String>> rememberedCookies = cookieJar.get(context.endpointAddress.getURI(), reqHeaders);
             processCookieHeaders(reqHeaders, rememberedCookies, "Cookie");
             processCookieHeaders(reqHeaders, rememberedCookies, "Cookie2");
         }
     }
     private void processCookieHeaders(Map<String, List<String>> requestHeaders, Map<String, List<String>> rememberedCookies, String cookieHeader) {
         List<String> jarCookies = rememberedCookies.get(cookieHeader);
         if (jarCookies != null && !jarCookies.isEmpty()) {
             List<String> resultCookies = mergeUserCookies(jarCookies, requestHeaders.get(cookieHeader));
             requestHeaders.put(cookieHeader, resultCookies);
         }
     }
     private List<String> mergeUserCookies(List<String> rememberedCookies, List<String> userCookies) {
         // nothing to merge
         if (userCookies == null || userCookies.isEmpty()) {
             return rememberedCookies;
         }
         Map<String, String> map = new HashMap<String, String>();
         cookieListToMap(rememberedCookies, map);
         cookieListToMap(userCookies, map);
         return new ArrayList<String>(map.values());
     }
     private void cookieListToMap(List<String> cookieList, Map<String, String> targetMap) {
         for(String cookie : cookieList) {
             int index = cookie.indexOf("=");
             String cookieName = cookie.substring(0, index);
             targetMap.put(cookieName, cookie);
         }
     }
     private void recordCookies(Packet context, HttpClientTransport con) throws IOException {
         Boolean shouldMaintainSessionProperty =
                 (Boolean) context.invocationProperties.get(BindingProvider.SESSION_MAINTAIN_PROPERTY);
         if (shouldMaintainSessionProperty != null && !shouldMaintainSessionProperty) {
             return;         // explicitly turned off
         }
         if (sticky || (shouldMaintainSessionProperty != null && shouldMaintainSessionProperty)) {
             cookieJar.put(context.endpointAddress.getURI(), con.getHeaders());
         }
     }
     private void addBasicAuth(Packet context, Map<String, List<String>> reqHeaders) {
         String user = (String) context.invocationProperties.get(BindingProvider.USERNAME_PROPERTY);
         if (user != null) {
             String pw = (String) context.invocationProperties.get(BindingProvider.PASSWORD_PROPERTY);
             if (pw != null) {
                 StringBuilder buf = new StringBuilder(user);
                 buf.append(":");
                 buf.append(pw);
                 String creds = DatatypeConverter.printBase64Binary(buf.toString().getBytes());
                 reqHeaders.put("Authorization", Collections.singletonList("Basic "+creds));
             }
         }
     }
     /*
      * write SOAPAction header if the soapAction parameter is non-null or BindingProvider properties set.
      * BindingProvider properties take precedence.
      */
     private void writeSOAPAction(Map<String, List<String>> reqHeaders, String soapAction) {
         //dont write SOAPAction HTTP header for SOAP 1.2 messages.
         if(SOAPVersion.SOAP_12.equals(binding.getSOAPVersion())) {
             return;
         }
         if (soapAction != null) {
             reqHeaders.put("SOAPAction", Collections.singletonList(soapAction));
         } else {
             reqHeaders.put("SOAPAction", Collections.singletonList("\"\""));
         }
     }
     @Override
     public void preDestroy() {
         // nothing to do. Intentionally left empty.
     }
     @Override
     public HttpTransportPipe copy(TubeCloner cloner) {
         return new HttpTransportPipe(this,cloner);
     }
     private void dump(ByteArrayBuffer buf, String caption, Map<String, List<String>> headers) throws IOException {
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
         PrintWriter pw = new PrintWriter(baos, true);
         pw.println("---["+caption +"]---");
         for (Entry<String,List<String>> header : headers.entrySet()) {
             if(header.getValue().isEmpty()) {
                 // I don't think this is legal, but let's just dump it,
                 // as the point of the dump is to uncover problems.
                 pw.println(header.getValue());
             } else {
                 for (String value : header.getValue()) {
                     pw.println(header.getKey()+": "+value);
                 }
             }
         }
         if (buf.size() > HttpAdapter.dump_threshold) {
             byte[] b = buf.getRawData();
             baos.write(b, 0, HttpAdapter.dump_threshold);
             pw.println();
             pw.println(WsservletMessages.MESSAGE_TOO_LONG(HttpAdapter.class.getName() + ".dumpTreshold"));
         } else {
             buf.writeTo(baos);
         }
         pw.println("--------------------");
         String msg = baos.toString();
         if (dump) {
             System.out.println(msg);
         }
         if (LOGGER.isLoggable(Level.FINER)) {
             LOGGER.log(Level.FINER, msg);
         }
     }
 }

Mercurial > jdk8-mips64-public > jaxws / annotate

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

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