Redis基本操作及下载安装包（Redis及可视化工具），都在我的上一篇文章：Redis基本知识及简单操作，这里不再赘述

店铺营业状态修改功能

（1）需求分析与设计

（2）SpringDataRedisTest修改：

位置：sky-server/src/test/java/com/sky/SpringDataRedisTest.java

注意：把测试类的@SpringBootTest注解注释掉

//@SpringBootTest //不注解的话，每次启动项目都会重新运行一下的测试用例，导致测试时间过长

（3）RedisConfiguration创建

位置：sky-server/src/main/java/com/sky/config/RedisConfiguration.java

完整代码：

package com.sky.config;import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
@Slf4j
public class RedisConfiguration {@Bean//@Bean的作用是将方法的返回值注入到spring容器中，这里创建了一个RedisTemplate对象public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {log.info("初始化创建Redis模板对象...");// 创建RedisTemplate对象RedisTemplate redisTemplate = new RedisTemplate();// 设置连接工厂redisTemplate.setConnectionFactory(redisConnectionFactory);// 设置key和value的序列化方式,否则会Redis数据库中key和value会出现乱码问题redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(new StringRedisSerializer());return redisTemplate;}
}

示意图：

（4）配置文件完善：

1、添加Redis服务配置，Redis数据库没有设置密码的需要注释掉或删掉“password”字段

2、Redis密码查看方式

查看有没有设置密码的方式如下，找到你的Redis安装目录

打开redis.windows.conf文件，Ctrl+F键打开查找功能，输入“pass ”,注意后面跟一个空格，即可看到有没有设置密码

3、图中密码已注释，表示没有设置密码，取消注释则“foobared”为数据库密码，可更改

1、application.yml完善

位置：sky-server/src/main/resources/application.yml

添加的代码为：

spring:redis:host: ${sky.redis.host}port: ${sky.redis.port}#redis密码，如果没有则不用设置
#    password: ${sky.redis.password}#redis数据库索引（默认为0）database: ${sky.redis.database}
#    timeout: 10000  #连接超时时间（毫秒）
#    lettuce:   #Lettuce客户端配置
#      pool: #连接池配置
#        max-active: 8 #最大连接数
#        max-idle: 8  #最大空闲连接数
#        min-idle: 0  #最小空闲连接数
#        max-wait: -1ms  #最大等待时间（毫秒），-1表示无限等待

文件完整代码：

server:port: 8080spring:profiles:active: devmain:allow-circular-references: truedatasource:druid:driver-class-name: ${sky.datasource.driver-class-name}url: jdbc:mysql://${sky.datasource.host}:${sky.datasource.port}/${sky.datasource.database}?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=trueusername: ${sky.datasource.username}password: ${sky.datasource.password}redis:host: ${sky.redis.host}port: ${sky.redis.port}#redis密码，如果没有则不用设置
#    password: ${sky.redis.password}#redis数据库索引（默认为0）database: ${sky.redis.database}
#    timeout: 10000  #连接超时时间（毫秒）
#    lettuce:   #Lettuce客户端配置
#      pool: #连接池配置
#        max-active: 8 #最大连接数
#        max-idle: 8  #最大空闲连接数
#        min-idle: 0  #最小空闲连接数
#        max-wait: -1ms  #最大等待时间（毫秒），-1表示无限等待mybatis:#mapper配置文件mapper-locations: classpath:mapper/*.xmltype-aliases-package: com.sky.entityconfiguration:#开启驼峰命名map-underscore-to-camel-case: truelogging:level:com:sky:mapper: debugservice: infocontroller: infosky:jwt:# 设置jwt签名加密时使用的秘钥admin-secret-key: itcast# 设置jwt过期时间admin-ttl: 72000002222# 设置前端传递过来的令牌名称admin-token-name: tokenalioss:endpoint: ${sky.alioss.endpoint}access-key-id: ${sky.alioss.access-key-id}access-key-secret: ${sky.alioss.access-key-secret}bucket-name: ${sky.alioss.bucket-name}

示意图：

2、application-dev.yml完善

Redis数据库没有设置密码的需要注释掉或删掉“password”字段

位置：sky-server/src/main/resources/application-dev.yml

添加的代码：

sky:redis:host: localhostport: 6379
#    password: 123456database: 1

文件完整代码：

sky:datasource:driver-class-name: com.mysql.cj.jdbc.Driverhost: localhostport: 3306database: sky_take_outusername: rootpassword: rootalioss:endpoint: oss-cn-beijing.aliyuncs.comaccess-key-id: LTAI5tPjjUp2rSRyizZtYX4yaccess-key-secret: eMbPCYCwdl4h9GVAROmgsH6mjZnylYbucket-name: sky-itcast-txredis:host: localhostport: 6379
#    password: 123456database: 1

示意图：

（5）admin的ShopController创建

位置：sky-server/src/main/java/com/sky/controller/admin/ShopController.java

完整代码：

package com.sky.controller.admin;import com.sky.config.RedisConfiguration;
import com.sky.result.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;@RestController("adminShopController")
@RequestMapping("/admin/shop")
@Api(tags = "后台-商铺管理相关接口")
@Slf4j
public class ShopController {public static final String key = "shop_status";@Autowiredprivate RedisTemplate redisTemplate;/*** 设置商铺营业状态* @param status* @return*/@PutMapping("/{status}")@ApiOperation(("设置商铺营业状态"))public Result setStatus(@PathVariable Integer status){log.info("设置商铺状态为：{}", status == 1 ? "营业中" : "打烊中");redisTemplate.opsForValue().set(key, status);return Result.success();}@GetMapping("/status")@ApiOperation(("获取商铺营业状态"))public Result<Integer> getStatus(){Integer status = (Integer) redisTemplate.opsForValue().get(key);log.info("商铺营业状态为：{}", status == 1 ? "营业中" : "打烊中");return Result.success(status);}}

示意图：

（6）user的ShopController创建

在Controller目录下创建user包，创建的输入“com.sky.controller.user”

位置：sky-server/src/main/java/com/sky/controller/user/ShopController.java

完整代码：

package com.sky.controller.user;import com.sky.result.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;@RestController("userShopController")
@RequestMapping("/user/shop")
@Api(tags = "后台-商铺管理相关接口")
@Slf4j
public class ShopController {public static final String key = "shop_status";@Autowiredprivate RedisTemplate redisTemplate;@GetMapping("/status")@ApiOperation(("获取商铺营业状态"))public Result<Integer> getStatus(){Integer status = (Integer) redisTemplate.opsForValue().get(key);log.info("商铺营业状态为：{}", status == 1 ? "营业中" : "打烊中");return Result.success(status);}}

示意图：

注意：由于admin包下的和user包下ShopController同名，导致他们在spring容器中的Bean名也一样即开头首字母变小写（shopController），直接启动项目汇报错，所以要自定义Bean名(如user表改为"userShopController")

代码分别如下：

ShopController：

@RestController("userShopController")

AdminController:

@RestController("adminShopController")

示意图：

（7）功能测试

（1）swagger接口文档测试：苍穹外卖项目接口文档

出现错误：响应码为500，控制台显示

“class java.lang.Integer cannot be cast to class java.lang.String (java.lang.Integer and java.lang.String are in module java.base of loader 'bootstrap')”

原因：问题出在 RedisTemplate 的值序列化器设置上。老师当前使用了 StringRedisSerializer 作为值序列化器，而我们的是Integer,所以老师没对value序列化，但却尝试存储 Integer 类型的数据，导致类型转换异常。或者我们把value序列化设置成指定Integer类型序列化，需要修改的地方是 值的序列化器，将其改为能处理多种类型的序列化器。

解决：对RedisConfiguration进行修改，使其支持Integer等多种类型数据的序列化

位置：sky-server/src/main/java/com/sky/config/RedisConfiguration.java

完整代码：

package com.sky.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
@Slf4j
public class RedisConfiguration {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {log.info("初始化创建Redis模板对象...");// 创建RedisTemplate对象，并指定泛型为<String, Object>RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();// 设置连接工厂redisTemplate.setConnectionFactory(redisConnectionFactory);// 创建Jackson2JsonRedisSerializer序列化器Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);// 配置ObjectMapper，让Jackson能序列化更多类型ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.activateDefaultTyping(objectMapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);// 设置key的序列化方式为StringRedisSerializerredisTemplate.setKeySerializer(new StringRedisSerializer());// 设置value的序列化方式为Jackson2JsonRedisSerializer（支持多种类型）redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);// 同时设置hash类型的key和value的序列化器redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}
}

测试