05.oauth2中RedisTokenStore使用redis cluster的问题

outlook

private static final String ACCESS = "access:";　　private static final String AUTH_TO_ACCESS = "auth_to_access:";
　　private static final String AUTH = "auth:";
　　private static final String REFRESH_AUTH = "refresh_auth:";
　　private static final String ACCESS_TO_REFRESH = "access_to_refresh:";
　　private static final String REFRESH = "refresh:";
　　private static final String REFRESH_TO_ACCESS = "refresh_to_access:";
　　private static final String CLIENT_ID_TO_ACCESS = "client_id_to_access:";
　　private static final String UNAME_TO_ACCESS = "uname_to_access:";
　　private RedisTemplate redisTemplate ;
　　public RedisTemplate getRedisTemplate() {
　　return redisTemplate;
　　}
　　public void setRedisTemplate(RedisTemplate redisTemplate) {
　　this.redisTemplate = redisTemplate;
　　}
　　private AuthenticationKeyGenerator authenticationKeyGenerator = new DefaultAuthenticationKeyGenerator();
　　public void setAuthenticationKeyGenerator(AuthenticationKeyGenerator authenticationKeyGenerator) {
　　this.authenticationKeyGenerator = authenticationKeyGenerator;
　　}
　　public OAuth2AccessToken getAccessToken(OAuth2Authentication authentication) {
　　String key = authenticationKeyGenerator.extractKey(authentication);
　　OAuth2AccessToken accessToken = (OAuth2AccessToken) redisTemplate.opsForValue().get(AUTH_TO_ACCESS+key);
　　if (accessToken != null
　　&& !key.equals(authenticationKeyGenerator.extractKey(readAuthentication(accessToken.getValue())))) {
　　// Keep the stores consistent (maybe the same user is represented by this authentication but the details
　　// have changed)
　　storeAccessToken(accessToken, authentication);
　　}
　　return accessToken;
　　}
　　public OAuth2Authentication readAuthentication(OAuth2AccessToken token) {
　　return readAuthentication(token.getValue());
　　}
　　public OAuth2Authentication readAuthentication(String token) {
　　return (OAuth2Authentication) this.redisTemplate.opsForValue().get(AUTH +  token);
　　}
　　public OAuth2Authentication readAuthenticationForRefreshToken(OAuth2RefreshToken token) {
　　return readAuthenticationForRefreshToken(token.getValue());
　　}
　　public OAuth2Authentication readAuthenticationForRefreshToken(String token) {
　　return (OAuth2Authentication) this.redisTemplate.opsForValue().get( REFRESH_AUTH+token);
　　}
　　public void storeAccessToken(OAuth2AccessToken token, OAuth2Authentication authentication) {
　　this.redisTemplate.opsForValue().set(ACCESS+ token.getValue(), token);
　　this.redisTemplate.opsForValue().set(AUTH +token.getValue(), authentication);
　　this.redisTemplate.opsForValue().set(AUTH_TO_ACCESS+authenticationKeyGenerator.extractKey(authentication), token);
　　if (!authentication.isClientOnly()) {
　　redisTemplate.opsForList().rightPush(UNAME_TO_ACCESS+getApprovalKey(authentication), token) ;
　　}
　　redisTemplate.opsForList().rightPush(CLIENT_ID_TO_ACCESS+authentication.getOAuth2Request().getClientId(), token) ;
　　if (token.getExpiration() != null) {
　　int seconds = token.getExpiresIn();
　　redisTemplate.expire(ACCESS+ token.getValue(), seconds, TimeUnit.SECONDS) ;
　　redisTemplate.expire(AUTH+ token.getValue(), seconds, TimeUnit.SECONDS) ;
　　redisTemplate.expire(AUTH_TO_ACCESS+ authenticationKeyGenerator.extractKey(authentication), seconds, TimeUnit.SECONDS) ;
　　redisTemplate.expire(CLIENT_ID_TO_ACCESS+authentication.getOAuth2Request().getClientId(), seconds, TimeUnit.SECONDS) ;
　　redisTemplate.expire(UNAME_TO_ACCESS+ getApprovalKey(authentication), seconds, TimeUnit.SECONDS) ;
　　}
　　if (token.getRefreshToken() != null && token.getRefreshToken().getValue() != null) {
　　this.redisTemplate.opsForValue().set( REFRESH_TO_ACCESS+   token.getRefreshToken().getValue(), token.getValue());
　　this.redisTemplate.opsForValue().set(ACCESS_TO_REFRESH+token.getValue(), token.getRefreshToken().getValue());
　　}
　　}
　　private String getApprovalKey(OAuth2Authentication authentication) {
　　String userName = authentication.getUserAuthentication() == null ? "" : authentication.getUserAuthentication()
　　.getName();
　　return getApprovalKey(authentication.getOAuth2Request().getClientId(), userName);
　　}
　　private String getApprovalKey(String clientId, String userName) {
　　return clientId + (userName==null ? "" : ":" + userName);
　　}
　　public void removeAccessToken(OAuth2AccessToken accessToken) {
　　removeAccessToken(accessToken.getValue());
　　}
　　public OAuth2AccessToken readAccessToken(String tokenValue) {
　　return (OAuth2AccessToken) this.redisTemplate.opsForValue().get(ACCESS+tokenValue);
　　}
　　public void removeAccessToken(String tokenValue) {
　　OAuth2AccessToken removed = (OAuth2AccessToken) redisTemplate.opsForValue().get(ACCESS+tokenValue);
　　// Don't remove the refresh token - it's up to the caller to do that
　　OAuth2Authentication authentication = (OAuth2Authentication) this.redisTemplate.opsForValue().get(AUTH+tokenValue);
　　this.redisTemplate.delete(AUTH+tokenValue);
　　redisTemplate.delete(ACCESS+tokenValue);
　　this.redisTemplate.delete(ACCESS_TO_REFRESH +tokenValue);
　　if (authentication != null) {
　　this.redisTemplate.delete(AUTH_TO_ACCESS+authenticationKeyGenerator.extractKey(authentication));
　　String clientId = authentication.getOAuth2Request().getClientId();