java Web第三方登录实现（基于OAuth2.0，包含Github和QQ登录，附源码）完整源码

package com.github.jitwxs.sample.oauth.utils; import org.apache.http.*; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.HttpRequestRetryHandler; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.config.Registry; import org.apache.http.config.RegistryBuilder; import org.apache.http.config.SocketConfig; import org.apache.http.conn.ConnectTimeoutException; import org.apache.http.conn.routing.HttpRoute; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.LayeredConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.NoopHostnameVerifier; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.entity.ContentType; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.pool.PoolStats; import org.apache.http.protocol.HTTP; import org.apache.http.protocol.HttpContext; import org.apache.http.util.EntityUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.net.ssl.*; import java.io.IOException; import java.io.InterruptedIOException; import java.net.SocketTimeoutException; import java.net.UnknownHostException; import java.nio.charset.Charset; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.HashMap; import java.util.Map; import java.util.Set; public class HttpClientUtils { private static Logger logger = LoggerFactory.getLogger(HttpClientUtils.class); private final static int CONNECT_TIMEOUT = 4000;// 连接超时毫秒 private final static int SOCKET_TIMEOUT = 10000;// 传输超时毫秒 private final static int REQUESTCONNECT_TIMEOUT = 3000;// 获取请求超时毫秒 private final static int CONNECT_TOTAL = 200;// 最大连接数 private final static int CONNECT_ROUTE = 20;// 每个路由基础的连接数 private final static String ENCODE_CHARSET = "utf-8";// 响应报文解码字符集 private final static String RESP_CONTENT = "通信失败"; private static PoolingHttpClientConnectionManager connManager = null; private static CloseableHttpClient httpClient = null; static { ConnectionSocketFactory plainsf = PlainConnectionSocketFactory.getSocketFactory(); LayeredConnectionSocketFactory sslsf = createSSLConnSocketFactory(); Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create() .register("http", plainsf).register("https", sslsf).build(); connManager = new PoolingHttpClientConnectionManager(registry); // 将最大连接数增加到200 connManager.setMaxTotal(CONNECT_TOTAL); // 将每个路由基础的连接增加到20 connManager.setDefaultMaxPerRoute(CONNECT_ROUTE); // 可用空闲连接过期时间,重用空闲连接时会先检查是否空闲时间超过这个时间，如果超过，释放socket重新建立 connManager.setValidateAfterInactivity(30000); // 设置socket超时时间 SocketConfig socketConfig = SocketConfig.custom().setSoTimeout(SOCKET_TIMEOUT).build(); connManager.setDefaultSocketConfig(socketConfig); RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(REQUESTCONNECT_TIMEOUT) .setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build(); HttpRequestRetryHandler httpRequestRetryHandler = new HttpRequestRetryHandler() { public boolean retryRequest(IOException exception, int executionCount, HttpContext context) { if (executionCount >= 3) {// 如果已经重试了3次，就放弃 return false; } if (exception instanceof NoHttpResponseException) {// 如果服务器丢掉了连接，那么就重试 return true; } if (exception instanceof SSLHandshakeException) {// 不要重试SSL握手异常 return false; } if (exception instanceof InterruptedIOException) {// 超时 return true; } if (exception instanceof UnknownHostException) {// 目标服务器不可达 return false; } if (exception instanceof ConnectTimeoutException) {// 连接被拒绝 return false; } if (exception instanceof SSLException) {// ssl握手异常 return false; } HttpClientContext clientContext = HttpClientContext.adapt(context); HttpRequest request = clientContext.getRequest(); // 如果请求是幂等的，就再次尝试 if (request instanceof HttpEntityEnclosingRequest) { return false; } return false; } }; httpClient = HttpClients.custom().setConnectionManager(connManager).setDefaultRequestConfig(requestConfig) .setRetryHandler(httpRequestRetryHandler).build(); if (connManager != null && connManager.getTotalStats() != null) { logger.info("now client pool " + connManager.getTotalStats().toString()); } } /** * 发送HTTP_GET请求 * * @param reqURL 请求地址 * @param param 请求参数 * @return 远程主机响应正文 * @see 1)该方法会自动关闭连接,释放资源 * @see 2)方法内设置了连接和读取超时时间,单位为毫秒,超时或发生其它异常时方法会自动返回"通信失败"字符串 * @see 3)请求参数含中文时,经测试可直接传入中文,HttpClient会自动编码发给Server,应用时应根据实际效果决 * 定传入前是否转码 * @see 4)该方法会自动获取到响应消息头中[Content-Type:text/html; charset=GBK]的charset值作为响应报文的 * 解码字符集 * @see 5)若响应消息头中无Content-Type属性,则会使用HttpClient内部默认的ISO-8859-1作为响应报文的解码字符 * 集 */ public static String sendGetRequest(String reqURL, String param) { if (null != param) { reqURL += "?" + param; } String respContent = RESP_CONTENT; // 响应内容 // reqURL = URLDecoder.decode(reqURL, ENCODE_CHARSET); HttpGet httpget = new HttpGet(reqURL); CloseableHttpResponse response = null; try { response = httpClient.execute(httpget, HttpClientContext.create()); // 执行GET请求 HttpEntity entity = response.getEntity(); // 获取响应实体 if (null != entity) { Charset respCharset = ContentType.getOrDefault(entity).getCharset(); respContent = EntityUtils.toString(entity, respCharset); EntityUtils.consume(entity); } } catch (ConnectTimeoutException cte) { logger.error("请求通信[" + reqURL + "]时连接超时,堆栈轨迹如下", cte); } catch (SocketTimeoutException ste) { logger.error("请求通信[" + reqURL + "]时读取超时,堆栈轨迹如下", ste); } catch (ClientProtocolException cpe) { // 该异常通常是协议错误导致:比如构造HttpGet对象时传�