0415_【掌握】响应式数据操作.pptx

《Redis开发实战》响应式数据操作

RedisAutoConfiguration提供的Redis模版类在使用SpringBoot集成SpringDataRedis组件时，会在spring-boot-starter-data-redis依赖中提供RedisAutoConfiguration自动装配类，而该装配类默认会提供RedisTemplate与StringRedisTemplate两个数据操作模版类

创建“reactor”子模块project(:reactor){

dependencies{ //根据需要进行依赖配置

implementation(org.springframework.boot:spring-boot-starter-webflux:3.0.0)

testImplementation(org.springframework.boot:spring-boot-starter-test:3.0.0)

compileOnly(jectlombok:lombok:1.18.24)//lombok组件

annotationProcessorjectlombok:lombok:1.18.24//注解处理支持

implementation(org.springframework.boot:spring-boot-starter-data-redis:3.0.0)

}

}

LettuceConfig配置类packagecom.yootk.config;

@Configuration

publicclassLettuceConfig{

@Bean

publicReactiveRedisTemplateString,StringreactiveRedisTemplate(

ReactiveRedisConnectionFactoryreactiveRedisConnectionFactory){

returnnewReactiveRedisTemplate(reactiveRedisConnectionFactory,

RedisSerializationContext.string());

}

}

创建控制器类，基于响应式操作实现Redis数据操作packagecom.yootk.action;

@RestController //直接相应

@RequestMapping(/reactor)

publicclassLettuceAction{

@Autowired //注入响应式Redis操作模版

privateReactiveRedisTemplateString,StringreactiveRedisTemplate;

@RequestMapping(/add_value)

publicMonoBooleansetValue(Stringkey,Stringvalue){

returnthis.reactiveRedisTemplate.opsForValue().set(key,value);

}

@RequestMapping(/get_value)

publicMonoStringgetValue(Stringkey){

returnthis.reactiveRedisTemplate.opsForValue().get(key);

}

@RequestMapping(/set_hash)

publicMonoBooleansetHash(Stringkey,Stringfield,Stringvalue){

returnthis.reactiveRedisTemplate.opsForHash().put(key,field,value);

}

@RequestMapping(/get_hash)

publicFluxMap.EntryObject,ObjectgetHash(Stringkey){

returnthis.reactiveRedisTemplate.opsForHash().entries(key);

}

}

创建应用程序启动类packagecom.yootk;

@SpringBootApp