Fixed - Spring session ID change doesn't work in Redis cluster #1897

6 years ago · 8610d60b0c
parent 584cb7c151
commit 8610d60b0c
1 changed files with 8 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/spring/session/RedissonSessionRepository.java
+++ b/redisson/src/main/java/org/redisson/spring/session/RedissonSessionRepository.java
@ -216,7 +216,14 @@ public class RedissonSessionRepository implements FindByIndexNameSessionReposito
        @Override
        public String changeSessionId() {
            String id = delegate.changeSessionId();
+            if (redisson.getConfig().isClusterConfig()) {
+                Map<String, Object> oldState = map.readAllMap();
+                map.delete();
+                map = redisson.getMap(keyPrefix + id, map.getCodec());
+                map.putAll(oldState);
+            } else {
                map.rename(keyPrefix + id);
+            }
            return id;
        }