Oauth2 Java demo

package com.test.client; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLConnection; import java.util.Map; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.SSLSession; import org.apache.oltu.oauth2.client.OAuthClient; import org.apache.oltu.oauth2.client.URLConnectionClient; import org.apache.oltu.oauth2.client.request.OAuthClientRequest; import org.apache.oltu.oauth2.client.request.OAuthClientRequest.OAuthRequestBuilder; import org.apache.oltu.oauth2.client.response.OAuthClientResponse; import org.apache.oltu.oauth2.client.response.OAuthClientResponseFactory; import org.apache.oltu.oauth2.client.response.OAuthResourceResponse; import org.apache.oltu.oauth2.common.OAuth; import org.apache.oltu.oauth2.common.exception.OAuthProblemException; import org.apache.oltu.oauth2.common.exception.OAuthSystemException; import org.apache.oltu.oauth2.common.utils.OAuthUtils; public class resourceClientTest { private static String url = "https://localhost:8443/TestServlet/resourceServlet"; private static String token = "111"; public static void main(String[] args) throws Exception { testRight(); } private static void testRight() throws OAuthSystemException, OAuthProblemException { ResourceClientRequest request = new ResourceClientRequest(url); request.setParameter("token", "111"); OAuthClientRequest req = request.buildHeaderMessage(); OAuthClient oAuthClient = new OAuthClient( new HTTPSURLConnectionClient()); OAuthResourceResponse response = oAuthClient.resource(req, null, OAuthResourceResponse.class); System.out.println(response.getBody()); } private static void testError() throws OAuthSystemException, OAuthProblemException { ResourceClientRequest request = new ResourceClientRequest(url); OAuthClientRequest req = request.buildQueryMessage(); OAuthClient oAuthClient = new OAuthClient( new HTTPSURLConnectionClient()); // OAuth.HttpMethod.GET OAuthResourceResponse response = oAuthClient.resource(req, null, OAuthResourceResponse.class); System.out.println(response.getResponseCode()); } } class ResourceClientRequest extends OAuthRequestBuilder { public ResourceClientRequest(String url) { super(url); } public ResourceClientRequest setParameter(String paramName, String paramValue) { this.parameters.put(paramName, paramValue); return this; } } class HTTPSURLConnectionClient extends URLConnectionClient { HostnameVerifier hv = new HostnameVerifier() { public boolean verify(String urlHostName, SSLSession session) { System.out.println("Warning: URL Host: " + urlHostName + " vs. " + session.getPeerHost()); return true; } }; @Override public <T extends OAuthClientResponse> T execute( OAuthClientRequest request, Map<String, String> headers, String requestMethod, Class<T> responseClass) throws OAuthSystemException, OAuthProblemException { String responseBody = null; URLConnection c = null; int responseCode = 0; try { URL url = new URL(request.getLocationUri()); c = url.openConnection(); responseCode = -1; if (c instanceof HttpURLConnection) { HttpsURLConnection httpURLConnection = (HttpsURLConnection) c; try { trustAllHttpsCertificates(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } httpURLConnection.setHostnameVerifier(hv); if (headers != null && !headers.isEmpty()) { for (Map.Entry<String, String> header : headers.entrySet()) { httpURLConnection.addRequestProperty(header.getKey(), header.getValue()); } } if (request.getHeaders() != null) { for (Map.Entry<String, String> header : request .getHeaders().entrySet()) { httpURLConnection.addRequestProperty(header.getKey(), header.getValue()); } } if (!OAuthUtils.isEmpty(requestMethod)) { httpURLConnection.setRequestMethod(requestMethod); if (requestMethod.equals(OAuth.HttpMethod.POST)) { httpURLConnection.setDoOutput(true); OutputStream ost = httpURLConnection.getOutputStream(); PrintWriter pw = new PrintWriter(ost); pw.print(request.getBody()); pw.flush(); pw.close(); } } else { httpURLConnection.setRequestMethod(OAuth.HttpMethod.GET); } httpURLConnection.connect(); InputStream inputStream; responseCode = httpURLConnection.getResponseCode(); if (responseCode == 400 || responseCode == 401) { inputStream = httpURLConnection.getErrorStream(); } else { inputStream = httpURLConnection.getInputStream(); } responseBody = OAuthUtils.saveStreamAsString(inputStream); } } catch (IOException e) { throw new OAuthSystemException(e); } return OAuthClientResponseFactory.createCustomResponse(responseBody, c.getContentType(), responseCode, responseClass); } private static void trustAllHttpsCertificates() throws Exception { javax.net.ssl.TrustManager[] trustAllCerts = new javax.net.ssl.TrustManager[1]; javax.net.ssl.TrustManager tm = new miTM(); trustAllCerts[0] = tm; javax.net.ssl.SSLContext sc = javax.net.ssl.SSLContext .getInstance("SSL"); sc.init(null, trustAllCerts, null); javax.net.ssl.HttpsURLConnection.setDefaultSSLSocketFactory(sc .getSocketFactory()); } static class miTM implements javax.net.ssl.TrustManager, javax.net.ssl.X509TrustManager { public java.security.cert.X509Certificate[] getAcceptedIssuers() { return null; } public boolean isServerTrusted( java.security.cert.X509Certificate[] certs) { return true; } public boolean isClientTrusted( java.security.cert.X509Certificate[] certs) { return true; } public void checkServerTrusted( java.security.cert.X509Certificate[] certs, String authType) throws java.security.cert.CertificateException { return; } public void checkClientTrusted( java.security.cert.X509Certificate[] certs, String authType) throws java.security.cert.CertificateException { return; } } }