SpringWebFlux支持与Spring Session项目无缝集成，它对于Session的支持是通过WebSession对象实现的，这篇笔记我们简单介绍SpringWebFlux中Session的使用方式。
Spring Session是个很强大的Session管理框架，在SpringMVC和SpringWebFlux中都可以使用，它支持很多细致的自定义Session配置，同时支持多种后端存储类型。引入Spring Session需要添加以下依赖项。
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
Spring Session默认将Session信息存储在内存中，我们也可以引入spring-boot-starter-data-redis，使其支持Redis作为存储后端。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
在application.properties中，我们可以按如下配置Spring Session以及Redis数据库的连接信息。
spring.session.store-type=redis
spring.session.timeout=3600
spring.redis.host=localhost
spring.redis.port=6379
spring.redis.database=0
有关Spring Session更多的内容这里不展开介绍，具体可以参考Java/Java企业级应用框架/Spring/SpringSession章节。
SpringWebFlux中，我们可以基于ServerWebExchange对象获取Mono<WebSession>，基于它我们可以进行后续的响应式操作。下面例子代码演示了如何读写Session数据。
package com.gacfox.demo.controller;
import com.gacfox.demo.model.ApiResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController {
@GetMapping("/writeSession")
public Mono<ApiResult<?>> writeSession(ServerWebExchange exchange) {
return exchange.getSession()
.flatMap(session -> {
session.getAttributes().put("user", "汤姆");
return session.save();
}).then(Mono.just(ApiResult.success()));
}
@GetMapping("/readSession")
public Mono<ApiResult<?>> readSession(ServerWebExchange exchange) {
return exchange.getSession()
.flatMap(session -> {
String user = (String) session.getAttributes().get("user");
return Mono.just(ApiResult.success(user));
});
}
}
注意对于Session的写操作，我们必须明确调用session.save()方法来持久化会话数据，这和SpringMVC不同。