当前位置: 首页 > 编程笔记 >

Java 调用Restful API接口的几种方式(HTTPS)

勾裕
2023-03-14
本文向大家介绍Java 调用Restful API接口的几种方式(HTTPS),包括了Java 调用Restful API接口的几种方式(HTTPS)的使用技巧和注意事项,需要的朋友参考一下

摘要:最近有一个需求,为客户提供一些Restful API 接口,QA使用postman进行测试,但是postman的测试接口与java调用的相似但并不相同,于是想自己写一个程序去测试Restful API接口,由于使用的是HTTPS,所以还要考虑到对于HTTPS的处理。由于我也是首次使用Java调用restful接口,所以还要研究一番,自然也是查阅了一些资料。

分析:这个问题与模块之间的调用不同,比如我有两个模块front end 和back end,front end提供前台展示,back end提供数据支持。之前使用过Hession去把back end提供的服务注册成远程服务,在front end端可以通过这种远程服务直接调到back end的接口。但这对于一个公司自己的一个项目耦合性比较高的情况下使用,没有问题。但是如果给客户注册这种远程服务,似乎不太好,耦合性太高。所以就考虑用一下方式进行处理。

一、HttpClient

HttpClient大家也许比较熟悉但又比较陌生,熟悉是知道他可以远程调用比如请求一个URL,然后在response里获取到返回状态和返回信息,但是今天讲的稍微复杂一点,因为今天的主题是HTTPS,这个牵涉到证书或用户认证的问题。
确定使用HttpClient之后,查询相关资料,发现HttpClient的新版本与老版本不同,随然兼容老版本,但已经不提倡老版本是使用方式,很多都已经标记为过时的方法或类。今天就分别使用老版本4.2和最新版本4.5.3来写代码。

老版本4.2

需要认证

在准备证书阶段选择的是使用证书认证

package com.darren.test.https.v42; 
import java.io.File; 
import java.io.FileInputStream; 
import java.security.KeyStore; 
import org.apache.http.conn.ssl.SSLSocketFactory;  
public class HTTPSCertifiedClient extends HTTPSClient {  
  public HTTPSCertifiedClient() { 
 
  } 
 
  @Override 
  public void prepareCertificate() throws Exception { 
    // 获得密匙库 
    KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType()); 
    FileInputStream instream = new FileInputStream( 
        new File("C:/Users/zhda6001/Downloads/software/xxx.keystore")); 
    // FileInputStream instream = new FileInputStream(new File("C:/Users/zhda6001/Downloads/xxx.keystore")); 
    // 密匙库的密码 
    trustStore.load(instream, "password".toCharArray()); 
    // 注册密匙库 
    this.socketFactory = new SSLSocketFactory(trustStore); 
    // 不校验域名 
    socketFactory.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); 
  } 
} 

跳过认证

在准备证书阶段选择的是跳过认证

package com.darren.test.https.v42;  
import java.security.cert.CertificateException; 
import java.security.cert.X509Certificate; 
import javax.net.ssl.SSLContext; 
import javax.net.ssl.TrustManager; 
import javax.net.ssl.X509TrustManager;  
import org.apache.http.conn.ssl.SSLSocketFactory; 
public class HTTPSTrustClient extends HTTPSClient { 
  public HTTPSTrustClient() { 
 
  } 
 
  @Override 
  public void prepareCertificate() throws Exception { 
    // 跳过证书验证 
    SSLContext ctx = SSLContext.getInstance("TLS"); 
    X509TrustManager tm = new X509TrustManager() { 
      @Override 
      public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { 
      } 
 
      @Override 
      public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { 
      } 
 
      @Override 
      public X509Certificate[] getAcceptedIssuers() { 
        return null; 
      } 
    }; 
    // 设置成已信任的证书 
    ctx.init(null, new TrustManager[] { tm }, null); 
    // 穿件SSL socket 工厂,并且设置不检查host名称 
    this.socketFactory = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); 
  } 
} 

总结

现在发现这两个类都继承了同一个类HTTPSClient,并且HTTPSClient继承了DefaultHttpClient类,可以发现,这里使用了模板方法模式。

package com.darren.test.https.v42; 
import org.apache.http.conn.ClientConnectionManager; 
import org.apache.http.conn.scheme.Scheme; 
import org.apache.http.conn.scheme.SchemeRegistry; 
import org.apache.http.conn.ssl.SSLSocketFactory; 
import org.apache.http.impl.client.DefaultHttpClient;  
public abstract class HTTPSClient extends DefaultHttpClient {  
  protected SSLSocketFactory socketFactory; 
 
  /** 
   * 初始化HTTPSClient 
   * 
   * @return 返回当前实例 
   * @throws Exception 
   */ 
  public HTTPSClient init() throws Exception { 
    this.prepareCertificate(); 
    this.regist(); 
 
    return this; 
  }  
  /** 
   * 准备证书验证 
   * 
   * @throws Exception 
   */ 
  public abstract void prepareCertificate() throws Exception; 
 
  /** 
   * 注册协议和端口, 此方法也可以被子类重写 
   */ 
  protected void regist() { 
    ClientConnectionManager ccm = this.getConnectionManager(); 
    SchemeRegistry sr = ccm.getSchemeRegistry(); 
    sr.register(new Scheme("https", 443, socketFactory)); 
  } 
} 

下边是工具类

package com.darren.test.https.v42;  
import java.util.ArrayList; 
import java.util.List; 
import java.util.Map; 
import java.util.Set; 
import org.apache.http.HttpEntity; 
import org.apache.http.HttpResponse; 
import org.apache.http.NameValuePair; 
import org.apache.http.client.entity.UrlEncodedFormEntity; 
import org.apache.http.client.methods.HttpGet; 
import org.apache.http.client.methods.HttpPost; 
import org.apache.http.client.methods.HttpRequestBase; 
import org.apache.http.message.BasicNameValuePair; 
import org.apache.http.util.EntityUtils;  
public class HTTPSClientUtil { 
  private static final String DEFAULT_CHARSET = "UTF-8";  
  public static String doPost(HTTPSClient httpsClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody) throws Exception { 
    return doPost(httpsClient, url, paramHeader, paramBody, DEFAULT_CHARSET); 
  } 
 
  public static String doPost(HTTPSClient httpsClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody, String charset) throws Exception { 
 
    String result = null; 
    HttpPost httpPost = new HttpPost(url); 
    setHeader(httpPost, paramHeader); 
    setBody(httpPost, paramBody, charset); 
 
    HttpResponse response = httpsClient.execute(httpPost); 
    if (response != null) { 
      HttpEntity resEntity = response.getEntity(); 
      if (resEntity != null) { 
        result = EntityUtils.toString(resEntity, charset); 
      } 
    } 
 
    return result; 
  } 
   
  public static String doGet(HTTPSClient httpsClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody) throws Exception { 
    return doGet(httpsClient, url, paramHeader, paramBody, DEFAULT_CHARSET); 
  } 
 
  public static String doGet(HTTPSClient httpsClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody, String charset) throws Exception { 
 
    String result = null; 
    HttpGet httpGet = new HttpGet(url); 
    setHeader(httpGet, paramHeader); 
 
    HttpResponse response = httpsClient.execute(httpGet); 
    if (response != null) { 
      HttpEntity resEntity = response.getEntity(); 
      if (resEntity != null) { 
        result = EntityUtils.toString(resEntity, charset); 
      } 
    } 
 
    return result; 
  } 
 
  private static void setHeader(HttpRequestBase request, Map<String, String> paramHeader) { 
    // 设置Header 
    if (paramHeader != null) { 
      Set<String> keySet = paramHeader.keySet(); 
      for (String key : keySet) { 
        request.addHeader(key, paramHeader.get(key)); 
      } 
    } 
  } 
 
  private static void setBody(HttpPost httpPost, Map<String, String> paramBody, String charset) throws Exception { 
    // 设置参数 
    if (paramBody != null) { 
      List<NameValuePair> list = new ArrayList<NameValuePair>(); 
      Set<String> keySet = paramBody.keySet(); 
      for (String key : keySet) { 
        list.add(new BasicNameValuePair(key, paramBody.get(key))); 
      } 
 
      if (list.size() > 0) { 
        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list, charset); 
        httpPost.setEntity(entity); 
      } 
    } 
  } 
} 

然后是测试类:

package com.darren.test.https.v42; 
import java.util.HashMap; 
import java.util.Map;  
public class HTTPSClientTest {  
  public static void main(String[] args) throws Exception { 
    HTTPSClient httpsClient = null; 
 
    httpsClient = new HTTPSTrustClient().init(); 
    //httpsClient = new HTTPSCertifiedClient().init(); 
 
    String url = "https://1.2.6.2:8011/xxx/api/getToken"; 
    //String url = "https://1.2.6.2:8011/xxx/api/getHealth"; 
 
    Map<String, String> paramHeader = new HashMap<>(); 
    //paramHeader.put("Content-Type", "application/json"); 
    paramHeader.put("Accept", "application/xml"); 
    Map<String, String> paramBody = new HashMap<>(); 
    paramBody.put("client_id", "ankur.tandon.ap@xxx.com"); 
    paramBody.put("client_secret", "P@ssword_1"); 
    String result = HTTPSClientUtil.doPost(httpsClient, url, paramHeader, paramBody); 
     
    //String result = HTTPSClientUtil.doGet(httpsClient, url, null, null); 
     
    System.out.println(result); 
  }  
} 

返回信息:

<?xml version="1.0" encoding="utf-8"?>   
<token>jkf8RL0sw+Skkflj8RbKI5hP1bEQK8PrCuTZPpBINqMYKRMxY1kWCjmCfT191Zpp88VV1aGHW8oYNWjEYS0axpLuGAX89ejCoWNbikCc1UvfyesXHLktcJqyUFiVjevhrEQxJPHncLQYWP+Xse5oD9X8vKFKk7InNTMRzQK7YBTZ/e3U7gswM/5cvAHFl6o9rEq9cWPXavZNohyvnXsohSzDo+BXAtXxa1xpEDLy/8h/UaP4n4dlZDJJ3B8t1Xh+CRRIoMOPxf7c5wKhHtOkEOeXW+xoPQKKSx5CKWwJpPuGIIFWF/PaqWg+JUOsVT7QGdPv8PMWJ9DwEwjTdxguDg==</token> 

新版本4.5.3

需要认证

package com.darren.test.https.v45;  
import java.io.File; 
import java.io.FileInputStream; 
import java.security.KeyStore; 
import javax.net.ssl.SSLContext; 
import org.apache.http.conn.ssl.SSLConnectionSocketFactory; 
import org.apache.http.conn.ssl.TrustSelfSignedStrategy; 
import org.apache.http.ssl.SSLContexts;  
public class HTTPSCertifiedClient extends HTTPSClient {  
  public HTTPSCertifiedClient() { 
 
  } 
 
  @Override 
  public void prepareCertificate() throws Exception { 
    // 获得密匙库 
    KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType()); 
    FileInputStream instream = new FileInputStream( 
        new File("C:/Users/zhda6001/Downloads/software/xxx.keystore")); 
    // FileInputStream instream = new FileInputStream(new File("C:/Users/zhda6001/Downloads/xxx.keystore")); 
    try { 
      // 密匙库的密码 
      trustStore.load(instream, "password".toCharArray()); 
    } finally { 
      instream.close(); 
    }  
    SSLContext sslcontext = SSLContexts.custom().loadTrustMaterial(trustStore, TrustSelfSignedStrategy.INSTANCE) 
        .build(); 
    this.connectionSocketFactory = new SSLConnectionSocketFactory(sslcontext); 
  }  
} 

跳过认证

package com.darren.test.https.v45;  
import java.security.cert.CertificateException; 
import java.security.cert.X509Certificate; 
import javax.net.ssl.SSLContext; 
import javax.net.ssl.TrustManager; 
import javax.net.ssl.X509TrustManager; 
import org.apache.http.conn.ssl.SSLConnectionSocketFactory; 
public class HTTPSTrustClient extends HTTPSClient { 
  public HTTPSTrustClient() {  
  } 
 
  @Override 
  public void prepareCertificate() throws Exception { 
    // 跳过证书验证 
    SSLContext ctx = SSLContext.getInstance("TLS"); 
    X509TrustManager tm = new X509TrustManager() { 
      @Override 
      public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { 
      } 
 
      @Override 
      public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { 
      } 
 
      @Override 
      public X509Certificate[] getAcceptedIssuers() { 
        return null; 
      } 
    }; 
    // 设置成已信任的证书 
    ctx.init(null, new TrustManager[] { tm }, null); 
    this.connectionSocketFactory = new SSLConnectionSocketFactory(ctx); 
  } 
} 

总结

package com.darren.test.https.v45;  
import org.apache.http.config.Registry; 
import org.apache.http.config.RegistryBuilder; 
import org.apache.http.conn.socket.ConnectionSocketFactory; 
import org.apache.http.conn.socket.PlainConnectionSocketFactory; 
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.impl.conn.PoolingHttpClientConnectionManager;  
public abstract class HTTPSClient extends HttpClientBuilder { 
  private CloseableHttpClient client; 
  protected ConnectionSocketFactory connectionSocketFactory; 
 
  /** 
   * 初始化HTTPSClient 
   * 
   * @return 返回当前实例 
   * @throws Exception 
   */ 
  public CloseableHttpClient init() throws Exception { 
    this.prepareCertificate(); 
    this.regist(); 
 
    return this.client; 
  } 
 
  /** 
   * 准备证书验证 
   * 
   * @throws Exception 
   */ 
  public abstract void prepareCertificate() throws Exception; 
 
  /** 
   * 注册协议和端口, 此方法也可以被子类重写 
   */ 
  protected void regist() { 
    // 设置协议http和https对应的处理socket链接工厂的对象 
    Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create() 
        .register("http", PlainConnectionSocketFactory.INSTANCE) 
        .register("https", this.connectionSocketFactory) 
        .build(); 
    PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry); 
    HttpClients.custom().setConnectionManager(connManager); 
 
    // 创建自定义的httpclient对象 
    this.client = HttpClients.custom().setConnectionManager(connManager).build(); 
    // CloseableHttpClient client = HttpClients.createDefault(); 
  } 
} 

工具类:

package com.darren.test.https.v45;  
import java.util.ArrayList; 
import java.util.List; 
import java.util.Map; 
import java.util.Set;  
import org.apache.http.HttpEntity; 
import org.apache.http.HttpResponse; 
import org.apache.http.NameValuePair; 
import org.apache.http.client.HttpClient; 
import org.apache.http.client.entity.UrlEncodedFormEntity; 
import org.apache.http.client.methods.HttpGet; 
import org.apache.http.client.methods.HttpPost; 
import org.apache.http.client.methods.HttpRequestBase; 
import org.apache.http.message.BasicNameValuePair; 
import org.apache.http.util.EntityUtils;  
public class HTTPSClientUtil { 
  private static final String DEFAULT_CHARSET = "UTF-8";  
  public static String doPost(HttpClient httpClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody) throws Exception { 
    return doPost(httpClient, url, paramHeader, paramBody, DEFAULT_CHARSET); 
  } 
 
  public static String doPost(HttpClient httpClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody, String charset) throws Exception { 
 
    String result = null; 
    HttpPost httpPost = new HttpPost(url); 
    setHeader(httpPost, paramHeader); 
    setBody(httpPost, paramBody, charset);  
    HttpResponse response = httpClient.execute(httpPost); 
    if (response != null) { 
      HttpEntity resEntity = response.getEntity(); 
      if (resEntity != null) { 
        result = EntityUtils.toString(resEntity, charset); 
      } 
    } 
 
    return result; 
  } 
   
  public static String doGet(HttpClient httpClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody) throws Exception { 
    return doGet(httpClient, url, paramHeader, paramBody, DEFAULT_CHARSET); 
  } 
 
  public static String doGet(HttpClient httpClient, String url, Map<String, String> paramHeader, 
      Map<String, String> paramBody, String charset) throws Exception { 
 
    String result = null; 
    HttpGet httpGet = new HttpGet(url); 
    setHeader(httpGet, paramHeader); 
 
    HttpResponse response = httpClient.execute(httpGet); 
    if (response != null) { 
      HttpEntity resEntity = response.getEntity(); 
      if (resEntity != null) { 
        result = EntityUtils.toString(resEntity, charset); 
      } 
    } 
 
    return result; 
  } 
 
  private static void setHeader(HttpRequestBase request, Map<String, String> paramHeader) { 
    // 设置Header 
    if (paramHeader != null) { 
      Set<String> keySet = paramHeader.keySet(); 
      for (String key : keySet) { 
        request.addHeader(key, paramHeader.get(key)); 
      } 
    } 
  } 
 
  private static void setBody(HttpPost httpPost, Map<String, String> paramBody, String charset) throws Exception { 
    // 设置参数 
    if (paramBody != null) { 
      List<NameValuePair> list = new ArrayList<NameValuePair>(); 
      Set<String> keySet = paramBody.keySet(); 
      for (String key : keySet) { 
        list.add(new BasicNameValuePair(key, paramBody.get(key))); 
      } 
 
      if (list.size() > 0) { 
        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list, charset); 
        httpPost.setEntity(entity); 
      } 
    } 
  } 
} 

测试类:

package com.darren.test.https.v45;  
import java.util.HashMap; 
import java.util.Map; 
import org.apache.http.client.HttpClient;  
public class HTTPSClientTest {  
  public static void main(String[] args) throws Exception { 
    HttpClient httpClient = null; 
 
    //httpClient = new HTTPSTrustClient().init(); 
    httpClient = new HTTPSCertifiedClient().init(); 
 
    String url = "https://1.2.6.2:8011/xxx/api/getToken"; 
    //String url = "https://1.2.6.2:8011/xxx/api/getHealth"; 
 
    Map<String, String> paramHeader = new HashMap<>(); 
    paramHeader.put("Accept", "application/xml"); 
    Map<String, String> paramBody = new HashMap<>(); 
    paramBody.put("client_id", "ankur.tandon.ap@xxx.com"); 
    paramBody.put("client_secret", "P@ssword_1"); 
    String result = HTTPSClientUtil.doPost(httpClient, url, paramHeader, paramBody); 
     
    //String result = HTTPSClientUtil.doGet(httpsClient, url, null, null); 
     
    System.out.println(result); 
  } 
 
} 

结果:

<?xml version="1.0" encoding="utf-8"?>   
<token>RxitF9//7NxwXJS2cjIjYhLtvzUNvMZxxEQtGN0u07sC9ysJeIbPqte3hCjULSkoXPEUYGUVeyI9jv7/WikLrzxYKc3OSpaTSM0kCbCKphu0TB2Cn/nfzv9fMLueOWFBdyz+N0sEiI9K+0Gp7920DFEncn17wUJVmC0u2jwvM5FAjQKmilwodXZ6a0Dq+D7dQDJwVcwxBvJ2ilhyIb3pr805Vppmi9atXrVAKO0ODa006wEJFOfcgyG5p70wpJ5rrBL85vfy9WCvkd1R7j6NVjhXgH2gNimHkjEJorMjdXW2gKiUsiWsELi/XPswao7/CTWNwTnctGK8PX2ZUB0ZfA==</token> 

二、HttpURLConnection

三、Spring的RestTemplate

其它方式以后补充

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持小牛知识库。

 类似资料:
  • 本文向大家介绍Java调用CXF WebService接口的两种方式实例,包括了Java调用CXF WebService接口的两种方式实例的使用技巧和注意事项,需要的朋友参考一下 通过http://localhost:7002/card/services/HelloWorld?wsdl访问到xml如下,说明接口写对了。 1.静态调用 2.动态调用: 区别: 静态调用需要依赖service类,因为客

  • 本文向大家介绍python调用接口的4种方式代码实例,包括了python调用接口的4种方式代码实例的使用技巧和注意事项,需要的朋友参考一下 这篇文章主要介绍了python调用接口的4种方式代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 python中调用API的几种方式: - urllib2 - httplib2 - pycurl - r

  • 本文向大家介绍详解Java 连接MongoDB集群的几种方式,包括了详解Java 连接MongoDB集群的几种方式的使用技巧和注意事项,需要的朋友参考一下 先决条件 先运行mongodb肯定是必须的,然后导入以下包: MongoClient MongoClient()实例表示到数据库的连接池; 你将只需要MongoClient类的一个实例,即使有多个线程也是一样。 重要: 通常,您只能为给定的Mo

  • 本文向大家介绍用 Python 连接 MySQL 的几种方式详解,包括了用 Python 连接 MySQL 的几种方式详解的使用技巧和注意事项,需要的朋友参考一下 尽管很多 NoSQL 数据库近几年大放异彩,但是像 MySQL 这样的关系型数据库依然是互联网的主流数据库之一,每个学 Python 的都有必要学好一门数据库,不管你是做数据分析,还是网络爬虫,Web 开发、亦或是机器学习,你都离不开要

  • 本文向大家介绍C#调用JS的几种方法,包括了C#调用JS的几种方法的使用技巧和注意事项,需要的朋友参考一下 cmd调用phantomjs 官方资料:http://phantomjs.org/quick-start.html 手动执行 从官方下载phantomjs.exe,拷贝它与要执行的js同目录 打开cmd,输入命令行(参考官方资料的命令行) 获得结果 使用C#执行 示例代码:https://g

  • 本文向大家介绍java 创建线程的几种方式,包括了java 创建线程的几种方式的使用技巧和注意事项,需要的朋友参考一下 说道线程,肯定会想到使用 java.lang.Thread.java这个类 那么创建线程也主要有2种方式 第一种方式: 然后在调用处,执行start方法即可: 第二种方式实现Runnable接口: 同样在执行的地方直接生命这个MyRunnable,再直接丢进线程start即可: