当前位置：首页 > news >正文

苍穹外卖项目实战（day-5完整版）-记录实战教程及问题的解决方法

news 2025/9/7 5:15:24

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）配置文件完善：

Redis密码查看方式

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

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

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

图中密码已注释，表示没有设置密码，取消注释则“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: 8080

spring:
profiles:
    active: dev
main:
    allow-circular-references: true
datasource:
    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=true
      username: ${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/*.xml
type-aliases-package: com.sky.entity
configuration:
    #开启驼峰命名
    map-underscore-to-camel-case: true

logging:
level:
    com:
      sky:
        mapper: debug
        service: info
        controller: info

sky:
jwt:
    # 设置jwt签名加密时使用的秘钥
    admin-secret-key: itcast
    # 设置jwt过期时间
    admin-ttl: 72000002222
    # 设置前端传递过来的令牌名称
    admin-token-name: token

alioss:
    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: localhost
    port: 6379
#    password: 123456
    database: 1

文件完整代码：

sky:
datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    host: localhost
    port: 3306
    database: sky_take_out
    username: root
    password: root
alioss:
    endpoint: oss-cn-beijing.aliyuncs.com
    access-key-id: LTAI5tPjjUp2rSRyizZtYX4y
    access-key-secret: eMbPCYCwdl4h9GVAROmgsH6mjZnylY
    bucket-name: sky-itcast-tx
redis:
    host: localhost
    port: 6379
#    password: 123456
    database: 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";
    @Autowired
    private 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";
    @Autowired
    private 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包下的ShopController和user包下ShopController同名，导致他们在spring容器中的Bean名也一样即开头首字母变小写（shopController），直接启动项目汇报错，所以要自定义Bean名(如user表改为"userShopController")

代码分别如下：

@RestController("userShopController")
@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 {
    @Bean
    public 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的序列化方式为StringRedisSerializer
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        // 设置value的序列化方式为Jackson2JsonRedisSerializer（支持多种类型）
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

        // 同时设置hash类型的key和value的序列化器
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);

        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
}