spring-state-machine使用redis持久化

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: spring-state-machine使用redis持久化

之前介绍过spring-state-machine持久化

今天使用redis实现

首先是需要一个RedisStateMachineRepository

import com.alibaba.nacos.common.utils.JacksonUtils;
import jakarta.annotation.Nonnull;
import jakarta.annotation.Resource;
import org.dromara.streamquery.stream.core.stream.Steam;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.statemachine.data.redis.RedisRepositoryStateMachine;
import org.springframework.statemachine.data.redis.RedisStateMachineRepository;
import org.springframework.stereotype.Repository;

import java.util.Optional;

@Repository
public class StateMachineRedisRepository implements RedisStateMachineRepository {


    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @Nonnull
    @Override
    public <S extends RedisRepositoryStateMachine> S save(@Nonnull S entity) {
        stringRedisTemplate.opsForHash()
                .put(SmCacheConst.STATE_MACHINE, entity.getId(), serialize(entity));
        return entity;
    }

    @Nonnull
    @Override
    public <S extends RedisRepositoryStateMachine> Iterable<S> saveAll(@Nonnull Iterable<S> entities) {
        var map = Steam.of(entities).toMap(RedisRepositoryStateMachine::getId, this::serialize);
        stringRedisTemplate.opsForHash().putAll(SmCacheConst.STATE_MACHINE, map);
        return Steam.of(entities).toList();
    }

    @Nonnull
    @Override
    public Optional<RedisRepositoryStateMachine> findById(@Nonnull String s) {
        return Optional.ofNullable(stringRedisTemplate.opsForHash().get(SmCacheConst.STATE_MACHINE, s)).map(this::deserialize);
    }

    @Override
    public boolean existsById(@Nonnull String s) {
        return stringRedisTemplate.opsForHash().hasKey(SmCacheConst.STATE_MACHINE, s);
    }

    @Nonnull
    @Override
    public Iterable<RedisRepositoryStateMachine> findAll() {
        return Steam.of(stringRedisTemplate.opsForHash().values(SmCacheConst.STATE_MACHINE)).map(this::deserialize).toList();
    }

    @Nonnull
    @Override
    public Iterable<RedisRepositoryStateMachine> findAllById(@Nonnull Iterable<String> strings) {
        var ids = Steam.<Object>of(strings).toList();
        var list = stringRedisTemplate.opsForHash().multiGet(SmCacheConst.STATE_MACHINE, ids);
        return Steam.of(list).map(this::deserialize).toList();
    }


    @Override
    public long count() {
        return stringRedisTemplate.opsForHash().size(SmCacheConst.STATE_MACHINE);
    }

    @Override
    public void deleteById(@Nonnull String s) {
        stringRedisTemplate.opsForHash().delete(SmCacheConst.STATE_MACHINE, s);
    }

    @Override
    public void delete(@Nonnull RedisRepositoryStateMachine entity) {
        stringRedisTemplate.opsForHash().delete(SmCacheConst.STATE_MACHINE, entity.getId());
    }

    @Override
    public void deleteAllById(@Nonnull Iterable<? extends String> strings) {
        var array = Steam.of(strings).toArray();
        stringRedisTemplate.opsForHash().delete(SmCacheConst.STATE_MACHINE, array);
    }

    @Override
    public void deleteAll(@Nonnull Iterable<? extends RedisRepositoryStateMachine> entities) {
        var ids = Steam.of(entities).map(RedisRepositoryStateMachine::getId).toArray();
        stringRedisTemplate.opsForHash().delete(SmCacheConst.STATE_MACHINE, ids);
    }

    @Override
    public void deleteAll() {
        stringRedisTemplate.opsForHash().delete(SmCacheConst.STATE_MACHINE);
    }

    private String serialize(Object entity) {
        return JacksonUtils.toJson(entity);
    }

    private RedisRepositoryStateMachine deserialize(Object obj) {
        if (obj instanceof String json) {
            return JacksonUtils.toObj(json, RedisRepositoryStateMachine.class);
        }
        return null;
    }
}

然后是配置:

@Bean
public StateMachineRuntimePersister<WordChainStateEnum, WordChainEventEnum, String>
stateMachineRuntimePersister(StateMachineRedisRepository stateMachineRedisRepository) {
    return new RedisPersistingStateMachineInterceptor<>(stateMachineRedisRepository);
}

@Bean
public StateMachineService<WordChainStateEnum, WordChainEventEnum>
stateMachineService(StateMachineFactory<WordChainStateEnum, WordChainEventEnum> stateMachineFactory,
                    StateMachineRuntimePersister<WordChainStateEnum, WordChainEventEnum, String> stateMachineRuntimePersister) {
    return new DefaultStateMachineService<>(stateMachineFactory, stateMachineRuntimePersister);
}

接下来是状态机处使用

StateMachineBuilder.Builder<WordChainStateEnum, WordChainEventEnum> builder = StateMachineBuilder.builder();

builder.configureConfiguration().withConfiguration().machineId(room);

builder.configureStates().withStates()
       .initial(STATE_WAITING_FOR_READY)
       .states(Set.of(WordChainStateEnum.values()));

builder.configureConfiguration().withPersistence().runtimePersister(stateMachineRuntimePersister);
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
1月前
|
NoSQL 安全 Java
Spring Boot3整合Redis
Spring Boot3整合Redis
59 1
|
1月前
|
存储 缓存 Java
【Spring原理高级进阶】有Redis为啥不用?深入剖析 Spring Cache:缓存的工作原理、缓存注解的使用方法与最佳实践
【Spring原理高级进阶】有Redis为啥不用?深入剖析 Spring Cache:缓存的工作原理、缓存注解的使用方法与最佳实践
|
1天前
|
存储 NoSQL Java
Redis奔溃了快看看有没开启持久化
Reis作为一个内存数据库,整个数据库状态都存储在内存里,如果在运行过程中发生崩溃,那整个数据库状态可就完全不见了,相当于整个服务器被初始化。Redis在这方面肯定有所作为,我们来看看它做了什么功夫~
15 0
Redis奔溃了快看看有没开启持久化
|
11天前
|
存储 NoSQL 算法
redis数据持久化
redis数据持久化
|
22天前
|
缓存 NoSQL Shell
【Redis深度专题】「核心技术提升」探究Redis服务启动的过程机制的技术原理和流程分析的指南(持久化功能分析)
【Redis深度专题】「核心技术提升」探究Redis服务启动的过程机制的技术原理和流程分析的指南(持久化功能分析)
25 0
|
1月前
|
缓存 NoSQL Java
spring cache整合redis实现springboot项目中的缓存功能
spring cache整合redis实现springboot项目中的缓存功能
45 1
|
1月前
|
缓存 NoSQL Redis
[Redis]——Redis持久化的两种方式RDB、AOF
[Redis]——Redis持久化的两种方式RDB、AOF
|
1月前
|
存储 NoSQL Java
[Redis]——Spring整合Redis(SpringDataRedis)
[Redis]——Spring整合Redis(SpringDataRedis)
|
1月前
|
监控 NoSQL Java
Spring Boot集成Redis启动失败【Caused by: java.lang.ClassNotFoundException: org.apache.commons.pool2.impl.G】
Spring Boot集成Redis启动失败【Caused by: java.lang.ClassNotFoundException: org.apache.commons.pool2.impl.G】
|
1月前
|
NoSQL Java 定位技术