Spring/spring-session
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Do not block when generating redis session id

Browse Source 
Closes gh-2393
This commit is contained in:
Marcus Da Coregio
2023-08-10 11:54:42 -03:00
parent 2d4233fcfd
commit 21ab473b2a
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisSessionRepository.java
View File

@@ -24,6 +24,7 @@ import java.util.Set;
import org.reactivestreams.Publisher;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
import org.springframework.core.NestedExceptionUtils;
import org.springframework.data.redis.core.ReactiveRedisOperations;
@@ -123,12 +124,16 @@ public class ReactiveRedisSessionRepository
@Override
public Mono<RedisSession> createSession() {
return Mono.defer(() -> {
MapSession cached = new MapSession(this.sessionIdGenerator);
cached.setMaxInactiveInterval(this.defaultMaxInactiveInterval);
RedisSession session = new RedisSession(cached, true);
return Mono.just(session);
});
// @formatter:off
return Mono.fromSupplier(() -> this.sessionIdGenerator.generate())
.subscribeOn(Schedulers.boundedElastic())
.publishOn(Schedulers.parallel())
.map((sessionId) -> {
MapSession cached = new MapSession(sessionId);
cached.setMaxInactiveInterval(this.defaultMaxInactiveInterval);
return new RedisSession(cached, true);
});
// @formatter:on
}
@Override