JAVA工具类 [ 调用HTTP 请求 ]

  

   

    

     

    
    

     

      /*
     
    
   

    

     

    
    

     

       * Licensed to the Apache Software Foundation (ASF) under one or more
     
    
   

    

     

    
    

     

       * contributor license agreements. See the NOTICE file distributed with
     
    
   

    

     

    
    

     

       * this work for additional information regarding copyright ownership.
     
    
   

    

     

    
    

     

       * The ASF licenses this file to You under the Apache License, Version 2.0
     
    
   

    

     

    
    

     

       * (the "License"); you may not use this file except in compliance with
     
    
   

    

     

    
    

     

       * the License. You may obtain a copy of the License at
     
    
   

    

     

    
    

     

       *
     
    
   

    

     

    
    

     

       * http://www.apache.org/licenses/LICENSE-2.0
     
    
   

    

     

    
    

     

       *
     
    
   

    

     

    
    

     

       * Unless required by applicable law or agreed to in writing, software
     
    
   

    

     

    
    

     

       * distributed under the License is distributed on an "AS IS" BASIS,
     
    
   

    

     

    
    

     

       * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     
    
   

    

     

    
    

     

       * See the License for the specific language governing permissions and
     
    
   

    

     

    
    

     

       * limitations under the License.
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      package org.apache.dolphinscheduler.common.utils;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import org.apache.commons.io.Charsets;
     
    
   

    

     

    
    

     

      import org.apache.dolphinscheduler.common.Constants;
     
    
   

    

     

    
    

     

      import org.apache.http.HttpEntity;
     
    
   

    

     

    
    

     

      import org.apache.http.client.config.RequestConfig;
     
    
   

    

     

    
    

     

      import org.apache.http.client.methods.CloseableHttpResponse;
     
    
   

    

     

    
    

     

      import org.apache.http.client.methods.HttpUriRequest;
     
    
   

    

     

    
    

     

      import org.apache.http.client.methods.RequestBuilder;
     
    
   

    

     

    
    

     

      import org.apache.http.entity.StringEntity;
     
    
   

    

     

    
    

     

      import org.apache.http.impl.client.CloseableHttpClient;
     
    
   

    

     

    
    

     

      import org.apache.http.impl.client.HttpClientBuilder;
     
    
   

    

     

    
    

     

      import org.apache.http.impl.client.HttpClients;
     
    
   

    

     

    
    

     

      import org.apache.http.util.EntityUtils;
     
    
   

    

     

    
    

     

      import org.slf4j.Logger;
     
    
   

    

     

    
    

     

      import org.slf4j.LoggerFactory;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import java.io.IOException;
     
    
   

    

     

    
    

     

      import java.nio.charset.StandardCharsets;
     
    
   

    

     

    
    

     

      import java.util.Map;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import com.alibaba.fastjson.JSONObject;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      /**
     
    
   

    

     

    
    

     

       * http utils
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      public 
      class HttpUtils {
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      /**
     
    
   

    

     

    
    

     

       * application json
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      	protected 
      static final 
      String APPLICATION_JSON = 
      "application/json";
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     

      	public 
      static final Logger logger = LoggerFactory.getLogger(HttpUtils.class);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      /**
     
    
   

    

     

    
    

     

       * get http request content
     
    
   

    

     

    
    

     

       * @param url url
     
    
   

    

     

    
    

     

       * @return http get request response content
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      	public 
      static 
      String get(
      String url){
     
    
   

    

     

    
    

     
		
      String responseContent  = 
      null;
     
    
   

    

     

    
    

     
		
      try {
     
    
   

    

     

    
    

     

      			responseContent = request(
      "GET",url,
      null,
      null,
      null);
     
    
   

    

     

    
    

     

      		} 
      catch (IOException e) {
     
    
   

    

     

    
    

     

      			e.printStackTrace();
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		
      return responseContent;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      /**
     
    
   

    

     

    
    

     

       *
     
    
   

    

     

    
    

     

       * @param method : GET PUT HEAD PUT DELETE
     
    
   

    

     

    
    

     

       * @param url
     
    
   

    

     

    
    

     

       * @param headerParams
     
    
   

    

     

    
    

     

       * @param parameterParams
     
    
   

    

     

    
    

     

       * @param bodyParams
     
    
   

    

     

    
    

     

       * @return
     
    
   

    

     

    
    

     

       * @throws IOException
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      	public 
      static 
      String request(
      String method ,
     
    
   

    

     

    
    

     
												
      String url ,
     
    
   

    

     

    
    

     
												
      Map<
      String,
      String > headerParams,
     
    
   

    

     

    
    

     
												
      Map<
      String,
      String > parameterParams ,
     
    
   

    

     

    
    

     
												
      Map<
      String,
      String > bodyParams) throws IOException {
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
		
      String responseContent = 
      null;
     
    
   

    

     

    
    

     

      		CloseableHttpResponse response = 
      null;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      		RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(Constants.HTTP_CONNECT_TIMEOUT)
     
    
   

    

     

    
    

     

      				.setConnectionRequestTimeout(Constants.HTTP_CONNECTION_REQUEST_TIMEOUT)
     
    
   

    

     

    
    

     

      				.setSocketTimeout(Constants.SOCKET_TIMEOUT)
     
    
   

    

     

    
    

     

      				.setRedirectsEnabled(
      true)
     
    
   

    

     

    
    

     

      				.build();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      		HttpClientBuilder httpClientBuilder = HttpClients.custom().
     
    
   

    

     

    
    

     

      				setDefaultRequestConfig(requestConfig);
     
    
   

    

     

    
    

     

      		CloseableHttpClient client =  httpClientBuilder.build();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      		RequestBuilder builder = RequestBuilder.create(method) ;
     
    
   

    

     

    
    

     

      		JSONObject jsonParam = 
      new JSONObject();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
		
      if(
      null != parameterParams && parameterParams.size() > 
      0){
     
    
   

    

     

    
    

     
			
      for (
      String key : parameterParams.keySet()) {
     
    
   

    

     

    
    

     

      				builder.addParameter(key, parameterParams.get(key));
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
		
      if(
      null != bodyParams && bodyParams.size() > 
      0){
     
    
   

    

     

    
    

     
			
      for (
      String key : bodyParams.keySet()) {
     
    
   

    

     

    
    

     

      				jsonParam.put(key, bodyParams.get(key));
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      		StringEntity postingString = 
      new StringEntity(jsonParam.toString(), Charsets.UTF_8);
     
    
   

    

     

    
    

     

      		postingString.setContentEncoding(StandardCharsets.UTF_8.name());
     
    
   

    

     

    
    

     

      		postingString.setContentType(APPLICATION_JSON);
     
    
   

    

     

    
    

     

      		builder.setEntity(postingString);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      		HttpUriRequest request = builder.setUri(url).build();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
		
      if(
      null != headerParams && headerParams.size() > 
      0){
     
    
   

    

     

    
    

     
			
      for (
      String key : headerParams.keySet()) {
     
    
   

    

     

    
    

     

      				request.addHeader(key, headerParams.get(key));
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
		
      try {
     
    
   

    

     

    
    

     

      			response = client.execute(request);
     
    
   

    

     

    
    

     

      			HttpEntity entity = response.getEntity();
     
    
   

    

     

    
    

     
			
      if (entity != 
      null) {
     
    
   

    

     

    
    

     

      				responseContent = EntityUtils.toString(entity, Constants.UTF_8);
     
    
   

    

     

    
    

     

      			}
      else{
     
    
   

    

     

    
    

     

      				logger.warn(
      "http entity is null");
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

      		}
      catch (Exception e){
     
    
   

    

     

    
    

     

      			logger.error(e.getMessage(),e);
     
    
   

    

     

    
    

     

      		}
      finally {
     
    
   

    

     

    
    

     
			
      try {
     
    
   

    

     

    
    

     
				
      if (response != 
      null) {
     
    
   

    

     

    
    

     

      					EntityUtils.consume(response.getEntity());
     
    
   

    

     

    
    

     

      					response.close();
     
    
   

    

     

    
    

     

      				}
     
    
   

    

     

    
    

     

      			} 
      catch (IOException e) {
     
    
   

    

     

    
    

     

      				logger.error(e.getMessage(),e);
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
			
      if (!request.isAborted()) {
     
    
   

    

     

    
    

     

      				request.abort();
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
			
      try {
     
    
   

    

     

    
    

     

      				client.close();
     
    
   

    

     

    
    

     

      			} 
      catch (IOException e) {
     
    
   

    

     

    
    

     

      				logger.error(e.getMessage(),e);
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		
      return responseContent;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }