如何结合SpringSession与Google Cloud Datastore实现会话集群？

确实，Spring Session官方只给了Redis、Hazelcast这些主流存储的示例，Google Cloud Datastore的支持确实比较冷门，但其实我们可以借助Spring Session的扩展机制自己实现，我之前做过类似的配置，给你一步步梳理下：

1. 引入必要依赖 #

首先在你的pom.xml（Maven项目）里添加核心依赖：

<!-- Spring Session核心 -->
<dependency>
    <groupId>org.springframework.session</groupId>
    <artifactId>spring-session-core</artifactId>
</dependency>
<!-- Spring Data 整合Google Cloud Datastore -->
<dependency>
    <groupId>com.google.cloud</groupId>
    <artifactId>spring-cloud-gcp-starter-data-datastore</artifactId>
</dependency>
<!-- Spring Web（Web应用必备） -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

2. 定义Datastore会话实体 #

创建一个映射Datastore实体的类，用来存储会话的核心数据：

import com.google.cloud.spring.data.datastore.core.mapping.Entity;
import com.google.cloud.spring.data.datastore.core.mapping.Field;
import org.springframework.session.Session;
import java.time.Duration;
import java.time.Instant;
import java.util.HashMap;
import java.util.Map;

@Entity(name = "spring_session")
public class DatastoreSession implements Session {

    @com.google.cloud.spring.data.datastore.core.mapping.Id
    private String id;

    @Field(name = "creation_time")
    private Instant creationTime;

    @Field(name = "last_accessed_time")
    private Instant lastAccessedTime;

    @Field(name = "max_inactive_interval")
    private Duration maxInactiveInterval;

    @Field(name = "attributes")
    private Map<String, Object> attributes = new HashMap<>();

    // 实现Session接口的所有方法，示例核心方法：
    @Override
    public String getId() {
        return this.id;
    }

    @Override
    public void setId(String id) {
        this.id = id;
    }

    @Override
    public Instant getCreationTime() {
        return this.creationTime;
    }

    @Override
    public void setCreationTime(Instant creationTime) {
        this.creationTime = creationTime;
    }

    // 其余方法（getLastAccessedTime、setMaxInactiveInterval等）请根据Session接口规范补全
    // attributes的操作直接基于map实现即可，比如getAttribute(name)就是this.attributes.get(name)
}

3. 创建Datastore数据访问Repository #

用Spring Data Datastore的DatastoreRepository简化CRUD操作，同时定义过期会话查询方法：

import com.google.cloud.spring.data.datastore.repository.DatastoreRepository;
import java.time.Instant;
import java.util.List;

public interface DatastoreSessionDataRepository extends DatastoreRepository<DatastoreSession, String> {
    // 根据最后访问时间查询过期会话
    List<DatastoreSession> findByLastAccessedTimeBefore(Instant cutoffTime);
}

4. 实现Spring Session的SessionRepository #

封装上面的DatastoreRepository，实现Spring Session要求的SessionRepository接口：

import org.springframework.session.SessionRepository;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.Instant;
import java.time.Duration;
import java.util.UUID;

@Component
public class SpringDatastoreSessionRepository implements SessionRepository<DatastoreSession> {

    private final DatastoreSessionDataRepository datastoreRepo;

    public SpringDatastoreSessionRepository(DatastoreSessionDataRepository datastoreRepo) {
        this.datastoreRepo = datastoreRepo;
    }

    @Override
    public DatastoreSession createSession() {
        DatastoreSession session = new DatastoreSession();
        session.setId(UUID.randomUUID().toString());
        session.setCreationTime(Instant.now());
        session.setLastAccessedTime(Instant.now());
        session.setMaxInactiveInterval(Duration.ofMinutes(30)); // 默认30分钟过期
        return session;
    }

    @Override
    public void save(DatastoreSession session) {
        session.setLastAccessedTime(Instant.now()); // 更新最后访问时间
        datastoreRepo.save(session);
    }

    @Override
    public DatastoreSession findById(String id) {
        return datastoreRepo.findById(id).orElse(null);
    }

    @Override
    public void deleteById(String id) {
        datastoreRepo.deleteById(id);
    }

    // 定时清理过期会话，每天凌晨3点执行
    @Scheduled(cron = "0 0 3 * * ?")
    public void cleanupExpiredSessions() {
        Instant cutoff = Instant.now().minus(Duration.ofMinutes(30));
        datastoreRepo.deleteAll(datastoreRepo.findByLastAccessedTimeBefore(cutoff));
    }
}

5. 配置Spring Session与Datastore #

在配置类中启用Spring Session，并注册相关Bean：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.session.config.annotation.web.http.EnableSpringHttpSession;
import org.springframework.session.SessionRepository;
import org.springframework.session.web.http.CookieHttpSessionIdResolver;
import org.springframework.session.web.http.HttpSessionIdResolver;
import org.springframework.scheduling.annotation.EnableScheduling;

@Configuration
@EnableSpringHttpSession
@EnableScheduling // 启用定时任务，用于清理过期会话
public class SessionConfig {

    @Bean
    public HttpSessionIdResolver httpSessionIdResolver() {
        // 默认用Cookie存储会话ID，也可自定义为URL重写等方式
        return new CookieHttpSessionIdResolver();
    }

    @Bean
    public SessionRepository<DatastoreSession> sessionRepository(DatastoreSessionDataRepository datastoreRepo) {
        return new SpringDatastoreSessionRepository(datastoreRepo);
    }
}

最后在application.properties配置Datastore连接信息：

# Google Cloud项目ID
spring.cloud.gcp.datastore.project-id=your-gcp-project-id
# 本地开发可启用Datastore模拟器
# spring.cloud.gcp.datastore.emulator.enabled=true
# spring.cloud.gcp.datastore.host=localhost:8081

关键注意事项 #

• Datastore索引配置：因为用到了findByLastAccessedTimeBefore查询，需要在src/main/resources/datastore-indexes.xml定义索引：

<?xml version="1.0" encoding="UTF-8"?>
<datastore-indexes autoGenerate="false">
    <datastore-index kind="spring_session" ancestor="false">
        <property name="last_accessed_time" direction="desc"/>
    </datastore-index>
</datastore-indexes>

• 序列化问题：Datastore对存储类型有限制，若会话属性包含自定义对象，建议将attributes序列化为JSON字符串存储，或实现Datastore自定义转换器。

这样配置完成后，你的云应用就能基于Google Cloud Datastore实现会话集群共享了。

内容的提问来源于stack exchange，提问作者Ben Dol