天天看點

SpringBoot 整合 oauth2(四)實作 token 持久化

為什麼需要給token做持久化,試想如果存儲token的伺服器當機後,使用者資訊也會伴随着失效,使用者需要重新登陸來擷取token,難免降低了使用者體驗,是以我們需要像處理session分布式一樣,将token持久化。

我的案例是将token存儲到redis裡。

其實springboot已經幫我們封裝了太多的東西了,在

上一章的基礎上

,我們隻需要添加不到10行代碼,就可以實作redis的持久化。

1. 新增 TokenStoreConfig.java

/**
 * 把token存到redis
 * Created by Fant.J.
 */
@Configuration
public class TokenStoreConfig {

    @Autowired
    private RedisConnectionFactory redisConnectionFactory;

    @Bean
    public TokenStore redisTokenStore(){
        return new RedisTokenStore(redisConnectionFactory);
    }
}
           

2. 新增 application.properties

spring.redis.database=0
# Redis伺服器位址
spring.redis.host=47.xx4.xx9.xx
# Redis伺服器連接配接端口
spring.redis.port=6379
# Redis伺服器連接配接密碼(預設為空)
spring.redis.password=root
# 連接配接池最大連接配接數(使用負值表示沒有限制)
spring.redis.pool.max-active=8
# 連接配接池最大阻塞等待時間(使用負值表示沒有限制)
spring.redis.pool.max-wait=-1
# 連接配接池中的最大空閑連接配接
spring.redis.pool.max-idle=8
# 連接配接池中的最小空閑連接配接
spring.redis.pool.min-idle=0
# 連接配接逾時時間(毫秒)
spring.redis.timeout=0
           

3. 修改 MyAuthorizationServerConfig.java

//新增一個注入
    @Autowired
    private TokenStore tokenStore;

     @Override
     public void configure(AuthorizationServerEndpointsConfigurer endpoints) throws Exception {
        endpoints
                .tokenStore(tokenStore)     //新增這一行
                .authenticationManager(authenticationManager)
                .userDetailsService(userDetailsService);
  }
           

好了,token在redis裡面的存儲就完成了。這麼簡單的嗎?對,就是這麼簡單,因為springboot包裝的很好了,如果檢測到認證服務,它會先從tokenStore擷取對應的token資料,如果tokenStore沒有,則新生成一個token并存入redis。

拓展

那redis是怎麼連接配接的呢?

我們在第一個類中注入了RedisConnectionFactory 這個工廠,它是個接口,裡面包含了關于redis連接配接的方法。隻要你按照spring提供的預設配置屬性來配置redis,成功連接配接是沒有問題的。貼一小段連接配接核心源碼證明一下

public RedisConnection getConnection() {

        if (cluster != null) {
            return getClusterConnection();
        }

        Jedis jedis = fetchJedisConnector();
        JedisConnection connection = (usePool ? new JedisConnection(jedis, pool, dbIndex, clientName)
                : new JedisConnection(jedis, null, dbIndex, clientName));
        connection.setConvertPipelineAndTxResults(convertPipelineAndTxResults);
        return postProcessConnection(connection);
    }
           

這是RedisConnectionFactory子類工廠JedisConnectionFactory中的getConnection方法。

redis屬性如何拿到的呢?

package org.springframework.boot.autoconfigure.data.redis;

import java.util.List;
import org.springframework.boot.context.properties.ConfigurationProperties;

@ConfigurationProperties(
    prefix = "spring.redis"
)
public class RedisProperties {
    private int database = 0;
    private String url;
    private String host = "localhost";
    private String password;
    private int port = 6379;
    private boolean ssl;
    private int timeout;
    private RedisProperties.Pool pool;
    private RedisProperties.Sentinel sentinel;
    private RedisProperties.Cluster cluster;

    public RedisProperties() {
    }

           

上面是springboot擷取屬性配置檔案的操作。

( 順便也帶給大家一個擷取application.properties 屬性的一個規範的方法。)

中間的裝配連接配接池啥的就不在這說了,有興趣的可以跟蹤源碼去看看大世界(不得不稱贊springboot的源碼寫的真是碉堡了,簡單粗暴Future 和 Callback用的也是流弊的很)。是以還得自己去看去琢磨。

介紹下我的所有文集:

流行架構

SpringCloud springboot nginx redis

底層實作原理:

Java NIO教程 Java reflection 反射詳解 Java并發學習筆錄 Java Servlet教程 jdbc元件詳解 Java語言/版本 研究