spring-session-data-redis解決session共享的問題

分布式系統要做到用戶友好，需要對用戶的session進行存儲，存儲的方式有以下幾種：

1. 本地緩存

2. 數據庫

3. 文件

4. 緩存服務器

 

可以看一些不同方案的優缺點

    1.本地機器或者本地緩存。優點：速度快  缺點：服務宕機后重啟用戶信息丟失，用戶不優好

    2.數據庫。優點：技術棧簡單  缺點：速度慢

    3.文件。優點：技術棧簡單，速度適中 缺點：無災備或者災備方案成本高

    4.緩存服務器。一般是內存服務器，優點：速度快 可以和原有技術棧契合，有現成的解決方案。缺點：不明顯

如果使用java語言，並且緩存服務器為redis，可以使用開源的spring session項目來解決。

spring session項目現有三個自項目，分別是

spring-session-data-redis  使用redis方式

spring-session-hazelcast   使用hazelcast方式

spring-session-jdbc  使用jdbc方式

在這里我建議大家使用redis方式，它提供了注解式和編程式不同的方法。具體如何使用，網上有很多實例，我就不贅述。我想和大家一起深入內部看一下，spring-session項目的github地址為：https://github.com/spring-projects/spring-session.git

我們只看spring-session-data-redis，實現非常簡單。它總共只有12個類

 

核心類只有一個

RedisOperationsSessionRepository

這個類內部定義了session的實現

RedisSession

/**
 * A custom implementation of {@link Session} that uses a {@link MapSession} as the
 * basis for its mapping. It keeps track of any attributes that have changed. When
 * {@link org.springframework.session.data.redis.RedisOperationsSessionRepository.RedisSession#saveDelta()}
 * is invoked all the attributes that have been changed will be persisted.
 *
 * @author Rob Winch
 * @since 1.0
 */
 

final class RedisSession implements Session {
   private final MapSession cached;
   private Instant originalLastAccessTime;
   private Map<String, Object> delta = new HashMap<>();
   private boolean isNew;
   private String originalPrincipalName;
   private String originalSessionId;

注意：

delta 是增量 cached是存量

我們來看這個RedisSession的創建 銷毀及修改

RedisSession內部存儲如下(示例)

* <pre>* HMSET spring:session:sessions:33fdd1b6-b496-4b33-9f7d-df96679d32fe creationTime 1404360000000 maxInactiveInterval 1800 lastAccessedTime 1404360000000 sessionAttr:attrName someAttrValue sessionAttr2:attrName someAttrValue2
* EXPIRE spring:session:sessions:33fdd1b6-b496-4b33-9f7d-df96679d32fe 2100
* APPEND spring:session:sessions:expires:33fdd1b6-b496-4b33-9f7d-df96679d32fe ""
* EXPIRE spring:session:sessions:expires:33fdd1b6-b496-4b33-9f7d-df96679d32fe 1800
* SADD spring:session:expirations:1439245080000 expires:33fdd1b6-b496-4b33-9f7d-df96679d32fe
* EXPIRE spring:session:expirations1439245080000 2100
* </pre>

 

RedisSession的數據結構是Hash

* <p>* Each session is stored in Redis as a
* <a href="http://redis.io/topics/data-types#hashes">Hash</a>. Each session is set and
* updated using the <a href="http://redis.io/commands/hmset">HMSET command</a>. An
* example of how each session is stored can be seen below.
* </p>

RedisSession的失效

* <h3>Expiration</h3>*
* <p>* An expiration is associated to each session using the
* <a href="http://redis.io/commands/expire">EXPIRE command</a> based upon the
* {@link org.springframework.session.data.redis.RedisOperationsSessionRepository.RedisSession#getMaxInactiveInterval()}
* . For example:
* </p>

RedisSession的更新有一個比較重要的方法：

/**
 * Saves any attributes that have been changed and updates the expiration of this
 * session.
 */
private void saveDelta() {
   String sessionId = getId();
   saveChangeSessionId(sessionId);
   if (this.delta.isEmpty()) {
      return;
   }
   getSessionBoundHashOperations(sessionId).putAll(this.delta);
   String principalSessionKey = getSessionAttrNameKey(
         FindByIndexNameSessionRepository.PRINCIPAL_NAME_INDEX_NAME);
   String securityPrincipalSessionKey = getSessionAttrNameKey(
         SPRING_SECURITY_CONTEXT);
   if (this.delta.containsKey(principalSessionKey)
         || this.delta.containsKey(securityPrincipalSessionKey)) {
      if (this.originalPrincipalName != null) {
         String originalPrincipalRedisKey = getPrincipalKey(
               this.originalPrincipalName);
         RedisOperationsSessionRepository.this.sessionRedisOperations
               .boundSetOps(originalPrincipalRedisKey).remove(sessionId);
      }
      String principal = PRINCIPAL_NAME_RESOLVER.resolvePrincipal(this);
      this.originalPrincipalName = principal;
      if (principal != null) {
         String principalRedisKey = getPrincipalKey(principal);
         RedisOperationsSessionRepository.this.sessionRedisOperations
               .boundSetOps(principalRedisKey).add(sessionId);
      }
   }

   this.delta = new HashMap<>(this.delta.size());

   Long originalExpiration = (this.originalLastAccessTime != null)
         ? this.originalLastAccessTime.plus(getMaxInactiveInterval())
               .toEpochMilli()
         : null;
   RedisOperationsSessionRepository.this.expirationPolicy
         .onExpirationUpdated(originalExpiration, this);
}

小結：

1.session是鍵值對形式的，對應redis的數據結構hash

2.session的存儲形式使用redis非常方便