org.xdi.oxauth.service.net.HttpService クラス

org.xdi.oxauth.service.net.HttpService の継承関係図

org.xdi.oxauth.service.net.HttpService 連携図

公開メンバ関数
void	init ()
HttpClient	getHttpsClientTrustAll ()
HttpClient	getHttpsClient ()
HttpClient	getHttpsClient (String trustStoreType, String trustStorePath, String trustStorePassword)
HttpClient	getHttpsClient (String trustStoreType, String trustStorePath, String trustStorePassword, String keyStoreType, String keyStorePath, String keyStorePassword)
HttpServiceResponse	executePost (HttpClient httpClient, String uri, String authData, Map< String, String > headers, String postData, ContentType contentType)
HttpServiceResponse	executePost (HttpClient httpClient, String uri, String authData, Map< String, String > headers, String postData)
HttpServiceResponse	executePost (HttpClient httpClient, String uri, String authData, String postData, ContentType contentType)
String	encodeBase64 (String value)
String	encodeUrl (String value)
HttpServiceResponse	executeGet (HttpClient httpClient, String requestUri, Map< String, String > headers)
HttpServiceResponse	executeGet (HttpClient httpClient, String requestUri) throws ClientProtocolException, IOException
byte []	getResponseContent (HttpResponse httpResponse) throws IOException
void	consume (HttpResponse httpResponse) throws IOException
String	convertEntityToString (byte[] responseBytes)
String	convertEntityToString (byte[] responseBytes, Charset charset)
String	convertEntityToString (byte[] responseBytes, String charsetName) throws UnsupportedEncodingException
boolean	isResponseStastusCodeOk (HttpResponse httpResponse)
boolean	isContentTypeXml (HttpResponse httpResponse)
String	constructServerUrl (final HttpServletRequest request)

非公開変数類
Logger	log
Base64	base64

静的非公開変数類
static final long	serialVersionUID = -2398422090669045605L

詳解

Provides operations with http requests

著者

Yuriy Movchan Date: 02/05/2013

関数詳解

constructServerUrl()

String org.xdi.oxauth.service.net.HttpService.constructServerUrl ( final HttpServletRequest  request )

inline

                                                                           {
        int serverPort = request.getServerPort();

        String redirectUrl;
        if ((serverPort == 80) || (serverPort == 443)) {
                redirectUrl = String.format("%s://%s%s", request.getScheme(), request.getServerName(), request.getContextPath());
        } else {
                redirectUrl = String.format("%s://%s:%s%s", request.getScheme(), request.getServerName(), request.getServerPort(), request.getContextPath());
        }
        
        return redirectUrl.toLowerCase();
    }

consume()

void org.xdi.oxauth.service.net.HttpService.consume ( HttpResponse  httpResponse ) throws IOException

inline

                                                                          {
        if ((httpResponse == null) || (httpResponse.getStatusLine().getStatusCode() != HttpResponseCodes.SC_OK)) {
                return;
        }

        // Consume response content
        HttpEntity entity = httpResponse.getEntity();
                if (entity != null) {
                        EntityUtils.consume(entity);
                }
        }

convertEntityToString() [1/3]

String org.xdi.oxauth.service.net.HttpService.convertEntityToString ( byte []  responseBytes )

inline

                                                                  {
                if (responseBytes == null) {
                        return null;
                }

                return new String(responseBytes);
        }

convertEntityToString() [2/3]

String org.xdi.oxauth.service.net.HttpService.convertEntityToString ( byte []  responseBytes, Charset  charset  )

inline

                                                                                   {
                if (responseBytes == null) {
                        return null;
                }

                return new String(responseBytes, charset);
        }

convertEntityToString() [3/3]

String org.xdi.oxauth.service.net.HttpService.convertEntityToString ( byte []  responseBytes, String  charsetName  ) throws UnsupportedEncodingException

inline

                                                                                                                          {
                if (responseBytes == null) {
                        return null;
                }

                return new String(responseBytes, charsetName);
        }

encodeBase64()

String org.xdi.oxauth.service.net.HttpService.encodeBase64 ( String  value )

inline

                                                 {
                try {
                        return new String(base64.encode((value).getBytes(Util.UTF8)), Util.UTF8);
                } catch (UnsupportedEncodingException ex) {
                log.error("Failed to convert '{}' to base64", value, ex);
                }

                return null;
        }

encodeUrl()

String org.xdi.oxauth.service.net.HttpService.encodeUrl ( String  value )

inline

                                              {
                try {
                        return URLEncoder.encode(value, Util.UTF8);
                } catch (UnsupportedEncodingException ex) {
                log.error("Failed to encode url '{}'", value, ex);
                }

                return null;
        }

executeGet() [1/2]

HttpServiceResponse org.xdi.oxauth.service.net.HttpService.executeGet ( HttpClient  httpClient, String  requestUri, Map< String, String >  headers  )

inline

                                                                                                                     {
                HttpGet httpGet = new HttpGet(requestUri);
        
        if (headers != null) {
                for (Entry<String, String> headerEntry : headers.entrySet()) {
                        httpGet.setHeader(headerEntry.getKey(), headerEntry.getValue());
                }
        }

                try {
                        HttpResponse httpResponse = httpClient.execute(httpGet);

                        return new HttpServiceResponse(httpGet, httpResponse);
                } catch (IOException ex) {
                log.error("Failed to execute get request", ex);
                }

                return null;
        }

executeGet() [2/2]

HttpServiceResponse org.xdi.oxauth.service.net.HttpService.executeGet ( HttpClient  httpClient, String  requestUri  ) throws ClientProtocolException, IOException

inline

                                                                                                                                    {
                return executeGet(httpClient, requestUri, null);
        }

executePost() [1/3]

HttpServiceResponse org.xdi.oxauth.service.net.HttpService.executePost ( HttpClient  httpClient, String  uri, String  authData, Map< String, String >  headers, String  postData, ContentType  contentType  )

inline

                                                                                                                                                                          {
        HttpPost httpPost = new HttpPost(uri);
        if (StringHelper.isNotEmpty(authData)) {
                httpPost.setHeader("Authorization", "Basic " + authData);
        }
        
        if (headers != null) {
                for (Entry<String, String> headerEntry : headers.entrySet()) {
                httpPost.setHeader(headerEntry.getKey(), headerEntry.getValue());
                }
        }

        StringEntity stringEntity = new StringEntity(postData, contentType);
                httpPost.setEntity(stringEntity);
                
        try {
                HttpResponse httpResponse = httpClient.execute(httpPost);

                return new HttpServiceResponse(httpPost, httpResponse);
                } catch (IOException ex) {
                log.error("Failed to execute post request", ex);
                }
        
        return null;
        }

executePost() [2/3]

HttpServiceResponse org.xdi.oxauth.service.net.HttpService.executePost ( HttpClient  httpClient, String  uri, String  authData, Map< String, String >  headers, String  postData  )

inline

                                                                                                                                                 {
                return executePost(httpClient, uri, authData, headers, postData, null);
        }

executePost() [3/3]

HttpServiceResponse org.xdi.oxauth.service.net.HttpService.executePost ( HttpClient  httpClient, String  uri, String  authData, String  postData, ContentType  contentType  )

inline

                                                                                                                                             {
        return executePost(httpClient, uri, authData, null, postData, contentType);
        }

getHttpsClient() [1/3]

HttpClient org.xdi.oxauth.service.net.HttpService.getHttpsClient ( )

inline

                                           {
                HttpClient httpClient = new SslDefaultHttpClient();

                return httpClient;
        }

getHttpsClient() [2/3]

HttpClient org.xdi.oxauth.service.net.HttpService.getHttpsClient ( String  trustStoreType, String  trustStorePath, String  trustStorePassword  )

inline

                                                                                                                  {
                HttpClient httpClient = new SslDefaultHttpClient(trustStoreType, trustStorePath, trustStorePassword);

                return httpClient;
        }

getHttpsClient() [3/3]

HttpClient org.xdi.oxauth.service.net.HttpService.getHttpsClient ( String  trustStoreType, String  trustStorePath, String  trustStorePassword, String  keyStoreType, String  keyStorePath, String  keyStorePassword  )

inline

                                                                                           {
                HttpClient httpClient = new SslDefaultHttpClient(trustStoreType, trustStorePath, trustStorePassword,
                                keyStoreType, keyStorePath, keyStorePassword);

                return httpClient;
        }

getHttpsClientTrustAll()

HttpClient org.xdi.oxauth.service.net.HttpService.getHttpsClientTrustAll ( )

inline

                                                   {
            try {
                SSLSocketFactory sf = new SSLSocketFactory(new TrustStrategy(){
                    @Override
                    public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
                        return true;
                    }
                }, new AllowAllHostnameVerifier());

                PlainSocketFactory psf = PlainSocketFactory.getSocketFactory();

                SchemeRegistry registry = new SchemeRegistry();
                registry.register(new Scheme("http", 80, psf));
                registry.register(new Scheme("https", 443, sf));
                ClientConnectionManager ccm = new PoolingClientConnectionManager(registry);
                return new DefaultHttpClient(ccm);
            } catch (Exception ex) {
                log.error("Failed to create TrustAll https client", ex);
                return new DefaultHttpClient();
            }
        }

getResponseContent()

byte [] org.xdi.oxauth.service.net.HttpService.getResponseContent ( HttpResponse  httpResponse ) throws IOException

inline

                                                                                       {
        if ((httpResponse == null) || (httpResponse.getStatusLine().getStatusCode() != HttpResponseCodes.SC_OK)) {
                return null;
        }

        HttpEntity entity = httpResponse.getEntity();
                byte[] responseBytes = new byte[0];
                if (entity != null) {
                        responseBytes = EntityUtils.toByteArray(entity);
                }

        // Consume response content
                if (entity != null) {
                        EntityUtils.consume(entity);
                }

        return responseBytes;
        }

init()

void org.xdi.oxauth.service.net.HttpService.init ( )

inline

                           {
                this.base64 = new Base64();
        }

isContentTypeXml()

boolean org.xdi.oxauth.service.net.HttpService.isContentTypeXml ( HttpResponse  httpResponse )

inline

                                                                   {
                Header contentType = httpResponse.getEntity().getContentType();
                if (contentType == null) {
                        return false;
                }

                String contentTypeValue = contentType.getValue();
                if (StringHelper.equals(contentTypeValue, ContentType.APPLICATION_XML.getMimeType()) || StringHelper.equals(contentTypeValue, ContentType.TEXT_XML.getMimeType())) {
                        return true;
                }
                
                return false;
        }

isResponseStastusCodeOk()

boolean org.xdi.oxauth.service.net.HttpService.isResponseStastusCodeOk ( HttpResponse  httpResponse )

inline

                                                                          {
                int responseStastusCode = httpResponse.getStatusLine().getStatusCode();
                if (responseStastusCode == HttpStatus.SC_OK) {
                        return true;
                }
                
                return false;
        }

メンバ詳解

base64

Base64 org.xdi.oxauth.service.net.HttpService.base64

private

log

Logger org.xdi.oxauth.service.net.HttpService.log

private

serialVersionUID

final long org.xdi.oxauth.service.net.HttpService.serialVersionUID = -2398422090669045605L

staticprivate

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxAuth/Server/src/main/java/org/xdi/oxauth/service/net/HttpService.java