Spring Security源碼分析六：Spring Social社交登陸源碼解析
在Spring Security源碼分析三：Spring Social實現QQ社交登陸和Spring Security源碼分析四：Spring Social實現微信社交登陸這兩章中，咱們使用
Spring Social已經實現了國內最經常使用的微信社交登陸。本章咱們來簡單分析一下Spring Social在社交登陸的過程當中作了哪些事情？（微博社交登陸也已經實現，因爲已經連續兩篇介紹社交登陸，因此不在單開一章節描述）java
引言
OAuth2是一種受權協議，簡單理解就是它可讓用戶在不將用戶名密碼交給第三方應用的狀況下，第三方應用有權訪問用戶存在服務提供商上面的數據。git
Spring Social 基本原理
- 訪問第三方應用
- 將用戶請求導向服務提供商
- 用戶贊成受權
- 攜帶受權碼返回第三方瑩瑩
- 第三方應用攜帶受權碼到服務提供商申請令牌
- 服務提供商返回令牌
- 獲取用戶基本信息
- 根據用戶信息構建
Authentication放入SecurityContext中若是在SecurityContext中放入一個已經認證過的Authentication實例，那麼對於Spring Security來講，已經成功登陸
Spring Social就是爲咱們將OAuth2認證流程封裝到SocialAuthenticationFilter過濾器中，並根據返回的用戶信息構建Authentication。而後使用Spring Security的驗證邏輯從而實現使用社交登陸。github
啓動logback斷點調試；spring
ValidateCodeFilter校驗驗證碼過濾器SocialAuthenticationFilter社交登陸過濾器UsernamePasswordAuthenticationFilter用戶名密碼登陸過濾器SmsCodeAuthenticationFilter短信登陸過濾器AnonymousAuthenticationFilter前面過濾器都沒校驗時匿名驗證的過濾器ExceptionTranslationFilter處理FilterSecurityInterceptor受權失敗時的過濾器FilterSecurityInterceptor受權過濾器
本章咱們主要講解SocialAuthenticationFilter微信
SocialAuthenticationFilter
public Authentication attemptAuthentication(HttpServletRequest request, HttpServletResponse response) throws AuthenticationException {
//#1.判斷用戶是否容許受權
if (detectRejection(request)) {
if (logger.isDebugEnabled()) {
logger.debug("A rejection was detected. Failing authentication.");
}
throw new SocialAuthenticationException("Authentication failed because user rejected authorization.");
}
Authentication auth = null;
//#2.獲取全部的社交配置providerId(本項目中三個：qq,weixin,weibo)
Set<String> authProviders = authServiceLocator.registeredAuthenticationProviderIds();
//#3.根據請求獲取當前的是那種類型的社交登陸
String authProviderId = getRequestedProviderId(request);
//#4.判斷是否系統中是否配置當前社交providerId
if (!authProviders.isEmpty() && authProviderId != null && authProviders.contains(authProviderId)) {
//#5.獲取當前社交的處理類即OAuth2AuthenticationService用於獲取Authentication
SocialAuthenticationService<?> authService = authServiceLocator.getAuthenticationService(authProviderId);
//#6.獲取SocialAuthenticationToken
auth = attemptAuthService(authService, request, response);
if (auth == null) {
throw new AuthenticationServiceException("authentication failed");
}
}
return auth;
}
private Authentication attemptAuthService(final SocialAuthenticationService<?> authService, final HttpServletRequest request, HttpServletResponse response) throws SocialAuthenticationRedirectException, AuthenticationException {
//獲取SocialAuthenticationToken
final SocialAuthenticationToken token = authService.getAuthToken(request, response);
if (token == null) return null;
Assert.notNull(token.getConnection());
//#7.從SecurityContext獲取Authentication判斷是否定證
Authentication auth = getAuthentication();
if (auth == null || !auth.isAuthenticated()) {
//#8.進行認證
return doAuthentication(authService, request, token);
} else {
//#9.返回當前的登陸帳戶的一些信息
addConnection(authService, request, token, auth);
return null;
}
}
複製代碼
- 判斷用戶是否容許受權
- 獲取系統的容許的社交登陸配置信息
- 獲取當前的社交登陸信息
- 判斷當前的信息是否存在系統配置中
- 獲取處理社交的
OAuth2AuthenticationService（用於獲取SocialAuthenticationToken） - 從
SecurityContext獲取Authentication判斷是否受權
OAuth2AuthenticationService#getAuthToken
public SocialAuthenticationToken getAuthToken(HttpServletRequest request, HttpServletResponse response) throws SocialAuthenticationRedirectException {
//#1. 獲取code
String code = request.getParameter("code");
//#2. 判斷code值
if (!StringUtils.hasText(code)) {
//#3.若是code不存在則拋出SocialAuthenticationRedirectException
OAuth2Parameters params = new OAuth2Parameters();
params.setRedirectUri(buildReturnToUrl(request));
setScope(request, params);
params.add("state", generateState(connectionFactory, request));
addCustomParameters(params);
throw new SocialAuthenticationRedirectException(getConnectionFactory().getOAuthOperations().buildAuthenticateUrl(params));
} else if (StringUtils.hasText(code)) {
try {
//#4.若是code存在則根據code得到access_token
String returnToUrl = buildReturnToUrl(request);
AccessGrant accessGrant = getConnectionFactory().getOAuthOperations().exchangeForAccess(code, returnToUrl, null);
// TODO avoid API call if possible (auth using token would be fine)
//#5.用access_token獲取用戶的信息並返回spring Social標準信息模型
Connection<S> connection = getConnectionFactory().createConnection(accessGrant);
//#6.使用返回的用戶信息構建SocialAuthenticationToken
return new SocialAuthenticationToken(connection, null);
} catch (RestClientException e) {
logger.debug("failed to exchange for access", e);
return null;
}
} else {
return null;
}
}
複製代碼
- 獲取
code - 判斷當前
code是否存在值 - 若是不存在則將用戶導向受權的地址
- 若是存在則根據
code獲取access_token - 根據
access_token返回用戶信息（該信息爲Spring Social標準信息模型） - 使用用戶返回的信息構建
SocialAuthenticationToken
SocialAuthenticationFilter#doAuthentication
private Authentication doAuthentication(SocialAuthenticationService<?> authService, HttpServletRequest request, SocialAuthenticationToken token) {
try {
if (!authService.getConnectionCardinality().isAuthenticatePossible()) return null;
token.setDetails(authenticationDetailsSource.buildDetails(request));
//#重點熟悉的AuhenticationManage
Authentication success = getAuthenticationManager().authenticate(token);
Assert.isInstanceOf(SocialUserDetails.class, success.getPrincipal(), "unexpected principle type");
updateConnections(authService, token, success);
return success;
} catch (BadCredentialsException e) {
// connection unknown, register new user?
if (signupUrl != null) {
// store ConnectionData in session and redirect to register page
sessionStrategy.setAttribute(new ServletWebRequest(request), ProviderSignInAttempt.SESSION_ATTRIBUTE, new ProviderSignInAttempt(token.getConnection()));
throw new SocialAuthenticationRedirectException(buildSignupUrl(request));
}
throw e;
}
}
複製代碼
SocialAuthenticationProvider#authenticate
public Authentication authenticate(Authentication authentication) throws AuthenticationException {
//#1.一些判斷信息
Assert.isInstanceOf(SocialAuthenticationToken.class, authentication, "unsupported authentication type");
Assert.isTrue(!authentication.isAuthenticated(), "already authenticated");
SocialAuthenticationToken authToken = (SocialAuthenticationToken) authentication;
//#2.從SocialAuthenticationToken中獲取providerId（表示當前是那個第三方登陸）
String providerId = authToken.getProviderId();
//#3.從SocialAuthenticationToken中獲取獲取用戶信息 即ApiAdapter設置的用戶信息
Connection<?> connection = authToken.getConnection();
//#4.從UserConnection表中查詢數據
String userId = toUserId(connection);
//#5.若是不存在拋出BadCredentialsException異常
if (userId == null) {
throw new BadCredentialsException("Unknown access token");
}
//#6.調用咱們自定義的MyUserDetailsService查詢
UserDetails userDetails = userDetailsService.loadUserByUserId(userId);
if (userDetails == null) {
throw new UsernameNotFoundException("Unknown connected account id");
}
//#7.返回已經認證的SocialAuthenticationToken
return new SocialAuthenticationToken(connection, userDetails, authToken.getProviderAccountData(), getAuthorities(providerId, userDetails));
}
複製代碼
- 從SocialAuthenticationToken中獲取providerId（表示當前是那個第三方登陸）
- 從SocialAuthenticationToken中獲取獲取用戶信息 即ApiAdapter設置的用戶信息
- 從UserConnection表中查詢數據
- 調用咱們自定義的MyUserDetailsService查詢
- 都正常以後返回已經認證的SocialAuthenticationToken UserConnection表中是如何添加添加數據的？
JdbcUsersConnectionRepository#findUserIdsWithConnection
public List<String> findUserIdsWithConnection(Connection<?> connection) {
ConnectionKey key = connection.getKey();
List<String> localUserIds = jdbcTemplate.queryForList("select userId from " + tablePrefix + "UserConnection where providerId = ? and providerUserId = ?", String.class, key.getProviderId(), key.getProviderUserId());
//# 重點conncetionSignUp
if (localUserIds.size() == 0 && connectionSignUp != null) {
String newUserId = connectionSignUp.execute(connection);
if (newUserId != null)
{
createConnectionRepository(newUserId).addConnection(connection);
return Arrays.asList(newUserId);
}
}
return localUserIds;
}
複製代碼
所以咱們自定義MyConnectionSignUp實現ConnectionSignUp接口後，Spring Social會插入數據後返回userIdsession
@Component
public class MyConnectionSignUp implements ConnectionSignUp {
@Override
public String execute(Connection<?> connection) {
//根據社交用戶信息，默認建立用戶並返回用戶惟一標識
return connection.getDisplayName();
}
}
複製代碼
時序圖
至於OAuth2AuthenticationService中獲取code和AccessToken,Spring Social已經咱們提供了基本的實現。開發中，根據不通的服務提供商提供不通的實現，具體可參考如下類圖，代碼可參考logback項目social包下面的類。 ide
總結
以上即是使用Spring Social實現社交登陸的核心類，其實和用戶名密碼登陸，短信登陸原理同樣.都有Authentication，和實現認證的AuthenticationProvider。源碼分析
相關文章
- 1. Spring Security源碼分析三：Spring Social實現QQ社交登陸
- 2. Spring Security源碼分析十四：Spring Social社交登陸綁定與解綁
- 3. Spring Security源碼分析四：Spring Social實現微信社交登陸
- 4. Spring Security 登陸校驗 源碼解析
- 5. Spring Security源碼分析五：Spring Security實現短信登陸
- 6. spring security 源碼分析(1)
- 7. Spring Security OAuth2 源碼分析
- 8. 【Spring-Security源碼分析】AuthenticationManagerBuilder
- 9. Spring Security源碼解析
- 10. Spring Security 源碼解析(一)
- 更多相關文章...
- • XML DOM 解析器 - XML DOM 教程
- • TCP報文格式解析 - TCP/IP教程
- • 互聯網組織的未來：剖析GitHub員工的任性之源
- • Java Agent入門實戰（二）-Instrumentation源碼概述
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. Spring Security源碼分析三：Spring Social實現QQ社交登陸
- 2. Spring Security源碼分析十四：Spring Social社交登陸綁定與解綁
- 3. Spring Security源碼分析四：Spring Social實現微信社交登陸
- 4. Spring Security 登陸校驗 源碼解析
- 5. Spring Security源碼分析五：Spring Security實現短信登陸
- 6. spring security 源碼分析(1)
- 7. Spring Security OAuth2 源碼分析
- 8. 【Spring-Security源碼分析】AuthenticationManagerBuilder
- 9. Spring Security源碼解析
- 10. Spring Security 源碼解析(一)