jinql
/
tomcat-cluster-redis-session-manager
mirror of https://github.com/ran-jit/tomcat-cluster-redis-session-manager
1
0
Fork 0
Code Issues Releases Wiki Activity

Bug fixes and added redis sentinel supportability changes.

pull/27/head
Ranjith Manickam 2018-12-04 03:17:42 +05:30
parent ecca5a5794
commit aac6ee85f9
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/tomcat/request/session/data/cache/impl/StandardDataCache.java vendored
View File

@ -108,7 +108,7 @@ public class StandardDataCache extends RedisCache {
/** Session data. */ /** Session data. */
private class SessionData implements Serializable { private class SessionData implements Serializable {
private byte[] value; private byte[] value;
private Date lastAccessedOn; private long lastAccessedOn;
SessionData(byte[] value) { SessionData(byte[] value) {
this.value = value; this.value = value;
@ -116,7 +116,7 @@ public class StandardDataCache extends RedisCache {
} }
void updatedLastAccessedOn() { void updatedLastAccessedOn() {
this.lastAccessedOn = new Date(); this.lastAccessedOn = new Date().getTime();
} }
byte[] getValue() { byte[] getValue() {
@ -124,7 +124,7 @@ public class StandardDataCache extends RedisCache {
return this.value; return this.value;
} }
Date getLastAccessedOn() { long getLastAccessedOn() {
return this.lastAccessedOn; return this.lastAccessedOn;
} }
} }
@ -189,12 +189,12 @@ public class StandardDataCache extends RedisCache {
private final Log LOGGER = LogFactory.getLog(SessionDataExpiryThread.class); private final Log LOGGER = LogFactory.getLog(SessionDataExpiryThread.class);
private final int sessionExpiryTime; private final long expiry;
private final Map<String, SessionData> sessionData; private final Map<String, SessionData> sessionData;
SessionDataExpiryThread(Map<String, SessionData> sessionData, int sessionExpiryTime) { SessionDataExpiryThread(Map<String, SessionData> sessionData, int sessionExpiryTime) {
this.sessionData = sessionData; this.sessionData = sessionData;
this.sessionExpiryTime = (sessionExpiryTime + 60) / 60; this.expiry = TimeUnit.SECONDS.toMillis(sessionExpiryTime + 60);
new Thread(this).start(); new Thread(this).start();
} }
@ -208,10 +208,8 @@ public class StandardDataCache extends RedisCache {
continue; continue;
} }
long diff = new Date().getTime() - data.getLastAccessedOn().getTime(); long difference = new Date().getTime() - data.getLastAccessedOn();
long diffMinutes = diff / (60 * 1000) % 60; if (difference >= this.expiry) {
if (diffMinutes > this.sessionExpiryTime) {
this.sessionData.remove(key); this.sessionData.remove(key);
} }
} }