2019独角兽企业重金招聘Python工程师标准>>>

/*** Saves any attributes that have been changed and updates the expiration of this* session.*/private void saveDelta() {if (this.delta.isEmpty()) {return;}String sessionId = getId();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<String, Object>(this.delta.size());Long originalExpiration = this.originalLastAccessTime == null ? null: this.originalLastAccessTime + TimeUnit.SECONDS.toMillis(getMaxInactiveIntervalInSeconds());RedisOperationsSessionRepository.this.expirationPolicy.onExpirationUpdated(originalExpiration, this);}}

public void onExpirationUpdated(Long originalExpirationTimeInMilli,ExpiringSession session) {String keyToExpire = "expires:" + session.getId();long toExpire = roundUpToNextMinute(expiresInMillis(session));if (originalExpirationTimeInMilli != null) {long originalRoundedUp = roundUpToNextMinute(originalExpirationTimeInMilli);if (toExpire != originalRoundedUp) {String expireKey = getExpirationKey(originalRoundedUp);this.redis.boundSetOps(expireKey).remove(keyToExpire);}}long sessionExpireInSeconds = session.getMaxInactiveIntervalInSeconds();String sessionKey = getSessionKey(keyToExpire);if (sessionExpireInSeconds < 0) {this.redis.boundValueOps(sessionKey).append("");this.redis.boundValueOps(sessionKey).persist();this.redis.boundHashOps(getSessionKey(session.getId())).persist();return;}String expireKey = getExpirationKey(toExpire);BoundSetOperations<Object, Object> expireOperations = this.redis.boundSetOps(expireKey);expireOperations.add(keyToExpire);long fiveMinutesAfterExpires = sessionExpireInSeconds+ TimeUnit.MINUTES.toSeconds(5);expireOperations.expire(fiveMinutesAfterExpires, TimeUnit.SECONDS);if (sessionExpireInSeconds == 0) {this.redis.delete(sessionKey);}else {this.redis.boundValueOps(sessionKey).append("");this.redis.boundValueOps(sessionKey).expire(sessionExpireInSeconds,TimeUnit.SECONDS);}this.redis.boundHashOps(getSessionKey(session.getId())).expire(fiveMinutesAfterExpires, TimeUnit.SECONDS);}