史上最完整的《苍穹外卖》项目实操笔记，跟视频的每一P对应，全系列10万字，涵盖详细步骤与问题的解决方案。如果你操作到某一步卡壳，参考这篇，相信会带给你极大启发。

《苍穹外卖》项目实操笔记【中】：P66~P122《苍穹外卖》项目实操笔记【中】

《苍穹外卖》项目实操笔记【下】：P123~P189《苍穹外卖》项目实操笔记【下】

（PS：如在做项目的过程中遇到问题，建议先自行解决，如实在解决不了，可添加文末微信咨询答疑，收费标准按8.88元/人次，避免改BUG的痛苦；如需源码可联系博主暂售5.88元。建议慎重选择。毕设需求定制、网站搭建均欢迎咨询，专业实惠。）

一、重要知识点精讲

1.1 nginx反向代理P11

1. nginx反向代理好处：

1. 提高访问速度（可以进行缓存，如果访问相同资源可以直接响应数据）

2. 可以进行负载均衡（如果没有nginx前端只能固定地访问后端某一台服务器，加入nginx则可以将请求分发给后端不同的服务器）

负载均衡：把大量的请求按照、我们指定的指定的方式均衡的分配给集群中的每台服务器。

3. 保证后端服务安全（前端不能直接请求到后端服务器，需要通过Nginx转发）

2. nginx反向代理的搭建：

location /api/ 的意思是如果请求能匹配上/api/这个字符串。

proxy_pass 该指令的作用是设定转发的目的地，其后跟的是转发的目的地址。

3. nginx负载均衡的配置：

在webservers里面定义一组服务器，用于承接访问负载：

4. nginx负载均衡的策略：

服务器不一定需要平均承接请求，可以通过更改参数赋以不同的权重：

技巧：

1. 按F12可以打开浏览器的调试工具  

3. 备注写上TODO可以在IDEA下方的TODO列表看到待做的操作

重要知识点：

1.用Git进行版本控制 P7 **

2.JWT令牌 P10 *

3.nginx反向代理 P11 **

4.Swagger P15 *

5.ThreadLocal P20 **

6.分页查询 P22 *

7.AOP P32 *

8.上传文件 图片 P36 P37 *

9.批量删除 P43 *

二、搭建开发环境 P3~P14

2.1软件开发整体介绍P3

软件开发流程

1. 需求分析：需求规格说明书（word文档）、产品原型（静态网页展示功能图片）。

2. 设计：UI设计（用户界面，小到按钮，大到页面布局，人机交互）、数据库设计（表结构、字段、类型等）、接口设计。

3. 编码：项目代码、单元测试。

4. 测试：测试用例、测试报告。

5. 上线运维：软件环境安装、配置。

角色分工

软件环境

2.2 苍穹外卖项目介绍P4

项目介绍

为餐饮企业（餐厅、饭店）定制的一款软件产品。

功能架构：体现项目中的业务功能模块。

产品原型（产品经理）

产品原型：用于展示项目的业务功能（一般用静态的HTML页面+适当的说明文字进行展示），一般由产品经理进行设计。

技术选型（架构师）

技术选型：展示项目中使用到的技术框架和中间件等。

2.3 前端环境搭建P5

先确保将nginx.exe放在无中文的目录下：

将监听的端口号更改为81，因为80端口时常被占用，如果用80端口可能会因为端口占用而无法打开！！

注意：这里配置的是nginx的监听端口，nginx在81号端口上监听网页端，最后是将数据传入8080端口的服务器端。

2.4 后端环境搭建P6

1. 熟悉项目框架+2.5+2.6

common存放的是公共类：constant常量类，context项目上下文，enumeration枚举类，exception异常类，json处理json转换的类，properties是Springboot中的一些配置属性类，会把配置文件中的配置项封装成对象，result后端的返回结果，utils工具类。

注意下面对象职责的说明：

Entity就是实体类，实体类一般与数据库表对应。（数据库字段一般是下划线命名，实体类属性一般是驼峰命名）

DTO数据传输对象，DTO一般是作为方法传入的参数在使用，不局限于前端给controller层传参，也可以是controller层给service层传参。

VO是视图对象，用于前端数据的展示，所以一般是controller层把VO传给前端，然后前端展示。

server子模块存放的是配置文件、配置类、拦截器、controller、service、mapper、启动类等。

2.5 使用Git进行版本控制P7

.gitignore中存放的是git不需要管理的文件：比如编译后生成的targit文件，以及测试类、测试包还有idea自带的一些文件。

先创建Git本地仓库

VCS - Create Git Repository创建远程仓库，选中根目录即可，若右上角出现标志说明成功：

 

打钩是提交按钮，点击后勾选所有文件，编写版本文字，点击Commit，这步是将项目提交到本地仓库：

PS：如果已有本地仓库，若想移除重新添加，下面是移除本地仓库的方法，首先在settings中移除本地仓库，然后关闭idea，把仓库地址下的.git、.idea、.gitignore文件删除，重新启动idea打开项目即可：

然后创建Git远程仓库

在gitee上创建远程仓库：

点击复制按钮，在IDEA中点击向上的按钮：

 

点击下面的链接，定义远程仓库，然后将刚刚复制的链接粘贴进来点击OK，即可将本地仓库与远程仓库关联：

最后将本地文件推送到Git远程仓库

然后直接点击Push即可，然后刷新一下gitee页面，会发现同步成功：

2.6 搭建数据库P8

一共11张表如下：

将已经提供的建表语句粘贴到查询处，点击运行，左边建立成功11张表：

2.7 前后端联调P9

要先将连接数据库的密码改为自己的密码：

在右端Maven处选中compile进行编译，若显示BUILD SUCCESS则说明编译通过：

 

在sky-server目录下的SkyApplication类中启动项目：

输入localhost:81可以打开登录页面：

2.8 调试方法+JWT令牌P10

点击小虫（进入断点调试），打上断点，然后前端点击登录（此时前端的数据会作为参数传入）：

光标放在字段上还会显示接收到的数据：

若想程序在所希望的地方停止，可以添加断点，然后点击左下角的右箭头，意思是放行；点击一折的箭头，意思是前进一步：

执行之后会在其中标明注入的数据：

jwt令牌是调用了一个工具类，JwtProperties是一个配置属性类，这里讲一个小技巧，ctri+鼠标左键点进去后，可以通过点击左上角的地球来锁定当前类所在的目录路径位置：

@ConfigurationProperties注解代表当前类是一个配置属性类，作用是：封装配置文件中的一些配置项。

在注解内的参数指示了配置类中的参数，比如sky.jwt，就去application.yml文件中找sky jwt的配置项，这些配置项就对应了相应的属性。

原理就是：通过配置属性类，将配置文件中的配置项，封装成一个类，然后通过@Autowired注解注入到要使用的地方。

如下图使用builder方式来建造对象，前提是要在EmployeeLoginVo类上面加上@Builder注解。

注意后端给前端响应的数据一律都是封装为Result：

按f12进入到开发者工具，点击登录，可以看到请求的路径：

2.9 nginx反向代理P11

但出现问题，前端请求的地址和后端接口的地址不一致是如何请求成功的呢？

下图是前端请求地址，端口为81：

后端的地址如下，应该是http://localhost:8080/admin/employee/login

原理：nginx反向代理，将前端发送的请求由nginx转发到后端服务器。

 下图是nginx的配置文件，它监听的是81端口，服务器名是本地（http://localhost:81）。如果匹配到api字符串（http://localhost:81/api），就转发到proxy_pass对应的地址（http://localhost:8080/admin）。如果后面还有字符串就拼接到目标地址后面（http://localhost:8080/admin/employee/login）。

2.10 完善登录功能P12

目前登录存在的问题：密码是明文存储（如123456），安全性太低。

思路：将密码采用MD5方式加密后进行存储，提高安全性（存储入数据库的密码是加密后的数据，并且加密的过程是不可逆的，无法通过加密结果算出明文）。

比对思路是：将前端输入的密码，经过转换，看能否比对上数据库中存储的密文。

将下面字符串粘贴到数据库：e10adc3949ba59abbe56e057f20f883e记得要Ctrl+S保存更改结果。

在service类中只需调用Spring提供的DigestUtils类中的md5DigestAsHex方法对密码进行加密转换，提供给后面比对即可，代码如下：

password = DigestUtils.md5DigestAsHex(password.getBytes());

2.11 导入接口文档P13

在开发之前需要先将接口定义好，然后前后端人员并行开发。

前后端分离开发流程

操作步骤

2.12 SwaggerP14

Swagger介绍

使用Swagger只需要按照规范去定义接口及接口相关的信息，就可以做到生成接口文档，以及在线接口调试页面。Swagger可以帮助后端生成接口文档、进行在线接口测试。

Knife4j是为Java MVC框架集成Swagger生成Api文档的增强解决方案。

Swagger使用步骤

导入下面坐标：

<dependency>

<groupId>com.github.xiaoymin</groupId>

<artifactId>knife4j-spring-starter</artifactId>

<version>3.0.2</version>

</dependency>

相关配置：

@Bean

public Docket docket() {

ApiInfo apiInfo = new ApiInfoBuilder()

.title("苍穹外卖项目接口文档")

.version("2.0")

.description("苍穹外卖项目接口文档")

.build();

Docket docket = new Docket(DocumentationType.SWAGGER_2)

.apiInfo(apiInfo)

.select()

.apis(RequestHandlerSelectors.basePackage("com.sky.controller"))

.paths(PathSelectors.any())

.build();

return docket;

}

它会扫描controller里面的所有方法，然后通过反射去解析，最终生成接口文档。

设置静态资源映射：

protected void addResourceHandlers(ResourceHandlerRegistry registry) {

registry.addResourceHandler("/doc.html").addResourceLocations("classpath:/META-INF/resources/");

registry.addResourceHandler("/webjars/**").addResourceLocations("classpath:/META-INF/resources/webjars/");

}

启动后访问localhost:8080/doc.html即可： 

有login和logout这些都是controller里的方法： 

 

可以直接在页面的测试栏中对方法进行测试：

 

Swagger常用注解P15

@Api注解使用样例（记得要加tags=）：

@ApiModel注解使用样例：

@ApiModelProperty注解使用样例：

@ApiOperation注解使用样例：

 

注解影响如下图：

三、模块开发

3.1 (新增员工)分析设计P16

一般是对产品原型（静态HTML页面）分析，因为比较直观。思考录入项有没有什么限制。

密码采用默认密码，登录后可以进行修改。

接口定义如下（data一般是查询是会用到，msg一般是出错时会返回消息）：

数据库设计如下：

3.2 (新增员工)代码开发P17

注意：当前端提交的数据和实体类中对应的属性差别较大时（也就是实体类中会有多余的属性），建议使用DTO来封装（DTO里的数据字段和前端提交的数据字段都能对应上）。

1.在EmployeeController中新建一个方法save，传入的参数是employeeDTO

1. 首先编写如下代码，是网页端读入的字段数据，在这里传入employeeService对象。有2点注意事项：①前端传入的数据是json格式，要用@RequestBody注解转换为对象。②为了方便调试加一个log.info，花括号{}的内容在后面会被替换为employeeDTO的值。

@PostMapping//post方式请求

@ApiOperation("新增员工")

public Result save(@RequestBody EmployeeDTO employeeDTO){

log.info("新增员工：{}",employeeDTO);

employeeService.save(employeeDTO);

return Result.success();

}

2. 在EmployeeService中编写如下代码，思路是：先创建一个emloyee实体类，然后把DTO的数据拷贝到实体类中，然后对剩下的属性进行赋值。

public void save(EmployeeDTO employeeDTO){

Employee employee = new Employee();

BeanUtils.copyProperties(employeeDTO,employee);//对象属性拷贝

employee.setStatus(StatusConstant.ENABLE);

employee.setPassword(DigestUtils.md5DigestAsHex(PasswordConstant.DEFAULT_PASSWORD.getBytes()));

employee.setCreateTime(LocalDateTime.now());

employee.setUpdateTime(LocalDateTime.now());

employee.setCreateUser(10L); //TODO 后续需要改为当前登录用户的id

employee.setUpdateUser(10L);

employeeMapper.insert(employee);

}

有2个注意事项：①可以用BeanUtils工具类中的copyProperties方法来对对象进行拷贝，前提是对象的属性有一部分是相同的。②不应该直接用数字数字，否则会是硬编码，应该使用StatusConstant常量类。 

3. 在EmployeeMapper中编写SQL语句，来将数据插入数据库：

@Insert("insert into employee(name,username,password,phone,sex,id_number,status,create_time,update_time,create_user,update_user)"+

"values"+

"(#(name),#(username),#(password),#(phone),#(sex),#(idNumber),#(status),#(createTime),#(updateTime),#(createUser),#(updateUser))")

void insert(Employee employee);

下面是开启驼峰命名：

3.3 (新增员工)功能测试P18

在开发阶段，前端界面可能没有开发好，所以不能进行前后端联调测试，只能用接口文档进行测试。

下面进行测试出现401，是因为有拦截器进行了拦截，原因是缺少token令牌：

所以我们先在员工登录页面获取一个令牌：

全局参数设置-输入参数名称+参数值，然后关闭页面： 

然后带着参数值发送：

成功在数据库中添加记录：

下面是前后端联调成功：

3.4 (新增员工)完善P19-20

问题1：录入的用户名已存在，抛出异常后没有处理，没处理的话，控制台会抛出错误P19。

用全局的异常处理器sky-server/handler/GlobalExceptionHandler，创建exceptionHandler方法，在方法里添加如下代码：

@ExceptionHandler

public Result exceptionHandler(SQLIntegrityConstraintViolationException ex) {

String message = ex.getMessage();

if(message.contains("Duplicate entry")){

String[] split = message.split(" ");

String username = split[2];

String msg = username + MessageConstant.ALREADY_EXISTS;

return Result.error(msg);

}else{

return Result.error(MessageConstant.UNKNOWN_ERROR);

}

}

目的是输出：xxx已经存在的提示。核心思想是：提取错误那段话的第3个词，然后拼接后输出。

 

问题2：新增员工时，创建人id和修改人id设置为了固定值P20。

程序中将创建者和更新者的id写死为10：

JWT认证机制：用户发起请求发送用户名和密码，后端进行校验，如果验证通过就生成JWT Token，将Token返回给客户端，客户端会保存Token，在后续请求的请求头中都会携带JWT Token，请求会被拦截器拦截到，会检查Token，如果通过就会展示数据，如果没有通过就会返回错误信息。

在拦截请求验证的时候可以获得JWT令牌

问题是：在解析出登录员工id后如何传递给Service的save方法？

答：通过ThreadLocal，它是Thread的局部变量，为每个线程提供单独一份的存储空间，具有线程隔离的效果，只有在线程内才能获取到对应的值，在线程外则不能访问。

可以通过在controller、service和拦截器中输出线程的id来看是否单次请求是同一个线程，经实验验证是同一个线程。 

System.out.println("当前线程的id:"+Thread.currentThread().getId());

 

在sky-common/src/main/java/context/BaseContext下封装了ThreadLocal的操作。 

先在拦截器JwtTokenAdminInterceptor里将ID存到存储空间里（set），因为每次请求线程不变，所以存储空间的值不会被更改，因此可以在EmployeeServiceImpl类中取到该值（get），进而输出，很妙！

 

小技巧：选中要计算的表达式，然后右键，选择Evaluate Expression，然后点击Evaluate即可。

3.5 (分页查询)分析设计P21

分页展示，每页展示10条数据，可以输入员工姓名进行查询。total是总的数目，records是一页的条目数。

 

3.6 (分页查询)代码开发P22

下面是PageResult和EmployeePageQueryDTO的实体类定义：

Result<PageResult>是在PageResult的基础上加上code和msg，作为返回给前端的对象。

在EmployeeController添加一个方法：

@GetMapping("/page")

@ApiOperation("员工分页查询")

public Result<PageResult> page(EmployeePageQueryDTO employeePageQueryDTO){

log.info("员工分页查询，参数为：{}",employeePageQueryDTO);

PageResult pageResult = employeeService.PageQuery(employeePageQueryDTO);

return Result.success(pageResult);

}

在EmployeeService接口中编写方法：

public PageResult PageQuery(EmployeePageQueryDTO employeePageQueryDTO);

在EmployeeServiceImpl中实现方法：

@Override

public PageResult PageQuery(EmployeePageQueryDTO employeePageQueryDTO) { //DTO已将页码和每页记录数传入，因此可以算出

// select * from employee limit 0,10，通过Limit来控制

PageHelper.startPage(employeePageQueryDTO.getPage(),employeePageQueryDTO.getPageSize()); //页码和每页记录数传入

//Page是固定的，Employee是每个用户的信息

Page<Employee> page = employeeMapper.pageQuery(employeePageQueryDTO);//

//要将page对象处理为PageResult对象

long total = page.getTotal();

List<Employee> result = page.getResult();

return new PageResult(total,result);

}

PageHelper的startPage方法可以通过传入的参数自动设置Limit，传入的是页码和每页的记录数，好处是：字符串的拼接不用自己做。底层实现是：它会给ThreadLocal设置上述参数，然后在执行SQL语句时会自动被取出，然后拼接成Limit。

Page是PageHelper插件定义的一个泛型类，是一个固定的返回类型。

pagehelper可以简化分页代码的编写：

在EmployeeMapper中编写方法：

Page<Employee> pageQuery(EmployeePageQueryDTO employeePageQueryDTO);

在application.yml配置文件中扫描了EmployeeMapper.xml配置文件： 

在EmployeeMapper.xml中编写SQL语句，limit不用我们手写，pagehelper会自动帮我们追加拼接，order by是排序条件：

<mapper namespace="com.sky.mapper.EmployeeMapper">

<select id="pageQuery" resultType="com.sky.entity.Employee">

select * from employee

<where>

<if test="name != null and name != ''">

and name like concat('%',#{name},'%')

</if>

</where>

order by create_time desc

</select>

</mapper>

如果有传入name，代表是员工姓名查询，它只会返回带有相关词（字也可以，因为是模糊查询）的员工信息。

如果没有传入name，那么name就为空，<if>判断内容不执行,<where>默认返回1，所以它会查询所有employee元素。

在这里是模糊查询，用concat将name与%进行拼接，%的意思是匹配任意字符串/字符。

<select>标签的id是mapper中的对应方法名。resultType是传入的参数类型。

3.7 (分页查询)功能测试P23

返回401，说明JWT校验时出现问题：Token的有效时间大约是2小时（此时重新登录获得Token，然后设置全局）。

发现日期显示的格式有问题（数字挤在一起）：

3.8 (分页查询)代码完善P24

、

方法一：在Employee实体类中的LocalDateTime属性上加上@JsonFormat注解，格式化时间。

@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")

private LocalDateTime updateTime;

方法二：拓展Spring MVC的消息转换器，统一对后端返回给前端的数据进行转换处理：

在sky-server下的com/sky/config/WebMvcConfiguration下创建：

//托转Spring MVC框架的消息转换器

protected void extendMessageConverters(List<HttpMessageConverter<?>> converters) {

//先创建一个消息转换器对象

MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();

//为消息转换器设置一个对象转换器，对象转换器可以将Java对象序列化为json数据

converter.setObjectMapper(new JacksonObjectMapper());

//消息转换器还没交给框架，需要把消息转换器加到容器里

converters.add(0,converter); //容器自带消息转换器，默认新加的排在末尾，0表示是首位，自己加的消息转换器排在首位

}

在JacksonObjectMapper里面有关于日期时间的序列化和反序列化器。 

按下面方式推送一下：

3.9 (启禁账号)分析设计P25

 

{status}是路径参数，1为启用，0为禁用。地址栏传参传入员工id。

3.10 (启禁账号)代码开发P26

操作：传入status和id，将某一id的status从0改为1或从1改为0。

在EmployeeController中编写如下代码：

@PostMapping("/status/{status}")

@ApiOperation("启用禁用员工账号")

public Result startOrStop(@PathVariable Integer status,Long id){

log.info("启用禁用员工账号：{},{}",status,id);

employeeService.startOrStop(status,id);

return Result.success();

}

取的是路径参数，加注解@PathVariable，如果和路径参数不同名，就要加括号双引号指明取的是哪个路径参数@PathVariable("status") ；如果同名，就不用加。

在EmployeeService接口中编入如下代码：

//启用禁用员工账号

void startOrStop(Integer status, Long id);

在EmployeeServiceImpl类中写入如下代码，注意下面的第2种书写方式：

@Override

public void startOrStop(Integer status, Long id) {

//update employee set status = ? where id = ?

/* Employee employee = new Employee();

employee.setStatus(status);

employee.setId(id); */

Employee employee = Employee.builder()

.status(status)

.id(id)

.build();

employeeMapper.update(employee);

}

在EmployeeMapper中写入如下代码：

void update(Employee employee);

 在EmployeeMapper.xml中写入如下代码，下面这个代码对全字段都可以进行修改，所以不仅仅适用于对status的修改：

</select>

<update id="update" parameterType="Employee">

update employee

<set>

<if test="name != null"> name = #{name},</if>

<if test="username != null"> username = #{username},</if>

<if test="password != null"> password = #{password},</if>

<if test="phone != null"> phone = #{phone},</if>

<if test="sex != null"> sex = #{sex},</if>

<if test="idNumber != null"> id_Number = #{idNumber},</if>

<if test="updateTime != null"> update_Time = #{updateTime},</if>

<if test="updateUser != null"> update_User = #{updateUser},</if>

<if test="status != null"> status = #{status},</if>

</set>

where id = #{id}

</update>

3.11 (编辑员工)分析设计P27

可以修改员工的姓名、手机号和身份证号等。

首先根据id查询到员工信息，然后编辑员工信息。

3.12 (编辑员工)代码开发P28

①回显数据操作：用查询语句把Employee对象查出来，然后显示。

EmployeeController编写如下代码：

@GetMapping("/{id}")

@ApiOperation("根据id查询员工信息")

public Result<Employee> getById(@PathVariable Long id){

Employee employee = employeeService.getById(id);

return Result.success(employee);

}

EmployeeService接口编写如下代码：

//根据id查询员工

Employee getById(Long id);

EmployeeServiceImpl实现类编写如下代码：

@Override

public Employee getById(Long id) {

Employee employee = employeeMapper.getById(id);

employee.setPassword("****");

return employee;

}

EmployeeMapper中编写如下代码：

//根据id查询员工信息

@Select("select * from employee where id = #{id}")

Employee getById(Long id);

②接收提交的数据：调用之前mapper的update方法进行更新。

EmployeeController编写如下代码：

@PutMapping

@ApiOperation("编辑员工信息")

public Result update(@RequestBody EmployeeDTO employeeDTO){

log.info("编辑员工信息：{}",employeeDTO);

employeeService.update(employeeDTO);

return Result.success();

}

EmployeeService接口编写如下代码：

//编辑员工信息

void update(EmployeeDTO employeeDTO);

EmployeeServiceImpl实现类编写如下代码：

@Override

public void update(EmployeeDTO employeeDTO) {

Employee employee = new Employee();

BeanUtils.copyProperties(employeeDTO,employee); //属性拷贝

employee.setUpdateTime(LocalDateTime.now());

employee.setUpdateUser(BaseContext.getCurrentId());

employeeMapper.update(employee); //需要传入Employee参数

}

EmployeeMapper中编写如下代码：

void update(Employee employee);

3.13 (编辑员工)功能测试P29

修改原有的一条数据成功。

3.14 导入分类管理代码P30

视频首先介绍了一下该模块的主要功能。

然后就是导入类，Java的Mapper层是3个类，resources的Mapper层是1个类，Service层有1个接口1个实现类（Impl结尾），Controller层有1个类。

 

然后进行前后端联调测试。

3.15 (字段填充)分析设计P31

在多个业务表中都有公共字段，如create_time、create_user（insert时用到）；update_time，update_user（insert和update时用到）这些。

插入数据的时候需要为这些字段赋值，会有大量重复的冗余set方法代码，后期如果表结构发生变化，代码需要跟着修改，此时就不方便修改（如果后期进行修改要重复一个个进行修改）。

实现思路：自定义注解AutoFill，用于标识需要进行公共字段自动填充的方法。然后自定义切面类AutoFillAspect，统一拦截加入了AutoFill注解的方法，通过反射为公共字段赋值。在Mapper的方法上加入AutoFill注解。

技术点：枚举，注解，AOP，反射。

3.16 (字段填充)代码开发P32

1. 在com.sky下创建annotation包，创造一个AutoFill的Annotation注解。

写入如下代码：

//自定义注解，用于标识某个方法需要进行功能字段自动填充处理

@Target(ElementType.METHOD)

@Retention(RetentionPolicy.RUNTIME)

public @interface AutoFill {

//数据库操作类型：UPDATE INSERT

OperationType value();

}

Target注解指定加上什么上面，Retention注解指定什么时候用，

2. 在com.sky下创建aspect包，创建类AutoFillAspect，写入如下代码：

//自定义切面，实现公共字段自动填充处理逻辑

@Aspect

@Component

@Slf4j

public class AutoFillAspect {

//切入点

@Pointcut("execution(* com.sky.mapper.*.*(..)) && @annotation(com.sky.annotation.AutoFill)")

public void autoFillPointCut(){}

//前置通知，在通知中进行公共字段的赋值

@Before("autoFillPointCut()")

public void autoFill(JoinPoint joinPoint){

log.info("开始进行公共字段自动填充...");

}

}

切入点：对哪些类的哪些方法进行拦截。@Pointcut里面写的是对哪些方法进行拦截，要满足2点：①必须是mapper下的所有类的方法，②还要有AutoFill这个注解。

通知：前置通知，后置通知，环绕通知，异常通知。

然后在sky-server下的mapper中的EmployeeMapper类里，insert上加入@AutoFill(value= OperationType.INSERT)注解，update上加入@AutoFill(value= OperationType.UPDATE)注解。

3.测试：在aspect/AutoFillAspect上的log.info("开始进行公共字段自动填充...")处打上断点，然后点击小虫（断点调试），正常登录，到员工管理界面，点击修改，看是否会运行到log语句。

3.17 (字段填充)代码开发P33

在sky-server的com.sky下的aspect的AutoFillAspect里的log.info("开始进行公共字段自动填充...");下添加如下代码：

1.获取到当前被拦截的方法上的数据库操作类型（比如是Insert还是Update，不同的类型需要给不同的参数赋值）

MethodSignature signature = (MethodSignature) joinPoint.getSignature();//通过连接点对象来获取签名，向下转型为MethodSignature

AutoFill autoFill = signature.getMethod().getAnnotation(AutoFill.class);//获得方法上的注解对象

OperationType operationType = autoFill.value();//获得数据库操作类型（Insert or Update）

2.获取到当前被拦截的方法的参数--实体对象（比如传入的参数是员工还是菜品还是其它的）

Object[] args = joinPoint.getArgs(); //获得了方法所有的参数

if(args == null || args.length==0 ){ //没有参数

return;

}

Object entity = args[0];//现在约定实体放在第1个位置,传入实体可能不同所以用Object

3.准备赋值的数据（给公共字段赋值的数据，比如时间就是系统时间，用户ID是从ThreadLocal获取）

4.根据当前不同的操作类型，为对应的属性通过反射来赋值

LocalDateTime now = LocalDateTime.now();

Long currentId = BaseContext.getCurrentId();

if(operationType == OperationType.INSERT){

//为4个公共字段赋值

try {

Method setCreateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_TIME, LocalDateTime.class); //把方法名全部换成常量类，防止写错

Method setCreateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_USER, Long.class);

Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class);

Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);

//4.根据当前不同的操作类型，为对应的属性通过反射来赋值

setCreateTime.invoke(entity,now);

setCreateUser.invoke(entity,currentId);

setUpdateTime.invoke(entity,now);

setUpdateUser.invoke(entity,currentId);

}catch (Exception e){

e.printStackTrace();

}

}else if(operationType == OperationType.UPDATE){

try {

//为2个公共字段赋值

Method setUpdateTime = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME, LocalDateTime.class);

Method setUpdateUser = entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);

//4.根据当前不同的操作类型，为对应的属性通过反射来赋值

setUpdateTime.invoke(entity, now);

setUpdateUser.invoke(entity, currentId);

}catch (Exception e){

e.printStackTrace();

}

}

}

然后要在mapper层的CategoryMapper和EmployeeMapper中的Insert和Update方法上加上@AutoFill注解，注解内容用OperationType.INSERT或OperationType.Update。

最后把service层的那些手动赋值删除掉或者注释掉。

3.18 (字段填充)功能测试P34

在log.info("开始进行公共字段自动填充")上打一个断点。逐步放行看signature的值，看autoFill的值，确定是UPDATE。然后看args数组传入的参数，employee的4个公共字段为空。看准备的数据是否正确，比如当前系统时间，和用户ID这里是1。最后看反射是否为具体的参数赋值，也就是entity。执行完Update语句看控制台是否输出了正确的sql。最后提交一下代码：公共字段自动填充代码实现。

3.19 (新增菜品)设计分析P35

需求分析+接口设计+数据库设计。

根据类型查询分类；文件上传；新增菜品。

3.20 (新增菜品)代码开发+OSS P36

在controller下创建一个CommonController，写入如下代码（只是一个原始版本，改进版本在P37）：

@RestController

@RequestMapping("/admin/common")

@Api(tags="通用接口")

@Slf4j

public class CommonController {

@PostMapping("/upload")

@ApiOperation("文件上传")

public Result<String> upload(MultipartFile file){

log.info("文件上传：{}",file);

return null;

}

}

然后需要在阿里云上申请一个oss（Object Storage Service） 即对象存储服务，阿里云上有7天试用期。

下面是获取endpoint、accessKeyId、accessKeySecret和bucketName的方法：

 

下面是操作后得到的accessKeyId、accessKeySecret：

endpoint：oss-cn-shenzhen.aliyuncs.com

accessKeyId：LTAI5tHzX4fMjySKcCoCvYci

accessKeySecret：vPKhVa4Kux8jUP6fU4614CQ3FW0wiC

bucketName：cangqiongwaimaipbj

在application.yml中是使用了引用的方式，引用了application-dev.yml中设置的参数值：

 配置属性类，读取配置文件的配置项，然后封装为一个Java对象（所以在配置类中会有输出的提示；在配置类中是用横线分割，在类中是用驼峰命名法，框架会自动转换）。

在sky-common下面的utils包里有一个AliOssUtil是一个上传图片的包。

在sky-server下面的config包里添加一个OssConfiguration类。

@Configuration

@Slf4j

public class OssConfiguration {

@Bean

@ConditionalOnMissingBean

public AliOssUtil aliOssUtil(AliOssProperties aliOssProperties){

log.info("开始创建阿里云文件上传工具类对象：{}",aliOssProperties);

return new AliOssUtil(aliOssProperties.getEndpoint(),

aliOssProperties.getAccessKeyId(),

aliOssProperties.getAccessKeySecret(),

aliOssProperties.getBucketName());

}

}

@ConditionalOnMissingBean注解的意思：当没有这个对象的时候再去创建。注意要return的是这个新创建的对象，不然后面自动注入会失败，这里的主要目的就是创建Bean对象，但具体的原理还没有搞清楚。 

注意读写权限要像上图一样设置为公共读，这是为了后面前端能正确访问OSS中的图片并显示。

设置为公共读之后可以看到前端的图片能够正常展示。

3.21 (新增菜品)代码开发P37 

下面是新的commonController代码）：

@RestController

@RequestMapping("/admin/common")

@Api(tags="通用接口")

@Slf4j

public class CommonController {

@Autowired

private AliOssUtil aliOssUtil;

//文件上传

@PostMapping("/upload")

@ApiOperation("文件上传")

public Result<String> upload(MultipartFile file){

log.info("文件上传：{}",file);

try {

String originalFilename = file.getOriginalFilename();//原始文件名

//截取原始文件名的的后缀

String extention = originalFilename.substring(originalFilename.lastIndexOf("."));

//构造新文件名称

String objectName = UUID.randomUUID().toString()+extention;

//文件的请求路径

String filePath = aliOssUtil.upload(file.getBytes(), objectName);

return Result.success(filePath);

}catch(IOException e){

log.error("文件上传失败：{}",e);

}

return null;

}

}

简单测试一下：看图片是否能在前端显示。 

3.22 (新增菜品)代码开发P38

在sky-server的controller下创建DishController：

@RestController

@RequestMapping("/admin/dish")

@Api(tags="菜品相关接口")

@Slf4j

public class DishController {

@Autowired

private DishService dishService;

@PostMapping

@ApiOperation("新增菜品")

public Result save(@RequestBody DishDTO dishDTO){

log.info("新增菜品：{}",dishDTO);

dishService.saveWithFlavor(dishDTO);

return Result.success();

}

}

 在sky-server的service下创建DishService：

public interface DishService {

//新增菜品和对应的口味

public void saveWithFlavor(DishDTO dishDTO);

}

在sky-server的service的impl下创建DishServiceImpl：

@Service

@Slf4j

public class DishServiceImpl implements DishService {

@Autowired

private DishMapper dishMapper;

@Autowired

private DishFlavorMapper dishFlavorMapper;

//新增菜品对应的口味

@Transactional

public void saveWithFlavor(DishDTO dishDTO) {

Dish dish = new Dish();

BeanUtils.copyProperties(dishDTO,dish);

//想菜品表插入1条数据

dishMapper.insert(dish);

//获取insert语句生成的主键值

Long dishId = dish.getId();

//向口味表插入n条数据

List<DishFlavor> flavors = dishDTO.getFlavors();

if(flavors != null && flavors.size()>0){

flavors.forEach(dishFlavor -> {

dishFlavor.setDishId(dishId);

});

//向口味表插入n条数据

dishFlavorMapper.insertBatch(flavors);

}

}

}

一个菜品有多个口味数据，向菜品表插入1条数据，向口味表插入n条数据。

因为涉及到多个表，所以添加@Transactional的注解（需要在启动类上添加@EnableTransactionManagement注解）：

在sky-server的mapper创建DishMapper类，写入insert方法的代码：

@Mapper

public interface DishMapper {

//根据分类id查询菜品数量

@Select("select count(id) from dish where category_id = #{categoryId}")

Integer countByCategoryId(Long categoryId);

void insert(Dish dish);

}

 在sky-server的resources下的mapper下创建DishMapper.xml文件，写入如下代码：

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.sky.mapper.DishMapper">

<insert id="insert">

insert into dish(name,category_id,price,image,description,create_time,update_time,create_user,update_user,status)

values (#{name},#{categoryId},#{price},#{image},#{description},#{createTime},#{updateTime},#{createUser},#{updateUser},#{status})

</insert>

</mapper>

在sky-server的mapper创建DishFlavorMapper类，写入insert方法的代码。

@Mapper

public interface DishFlavorMapper {

@AutoFill(value= OperationType.INSERT)

void insertBatch(List<DishFlavor> flavors);

}

 在sky-server的resources下的mapper下创建DishFlavorMapper.xml文件，写入如下代码。

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.sky.mapper.DishFlavorMapper">

<insert id="insertBatch">

insert into dish_flavor (dish_id,name,value) VALUES

<foreach collection="flavors" item="df" separator=",">

(#{df.dishId},#{df.name},#{df.value})

</foreach>

</insert>

</mapper>

在DishMapper和DishFlavorMapper中的insert方法上添加@AutoFill(value= OperationType.INSERT)注解。

3.23 (新增菜品)功能测试P39

采用前后端联调的方式。在DishServiceImpl的saveWithFlavor方法中，首先看一下传入参数dishDTO是否被封装好。然后看拷贝后的dish对象的值是否完整。最后看insert语句后的2个公共字段是否被赋值好。

没啥问题之后提交代码：新增菜品业务代码开发。

3.24 (分页查询)设计分析P40

请求的参数会被封装成DTO

因为categoryName是不存在菜品表里的，现在前端页面要展示分类名称，所以要定义VO，将VO转为JSON数据然后展示。

3.25 (分页查询)代码开发P41

在sky-server的controller中已有的DishController类中添加如下代码：

@GetMapping("/page")

@ApiOperation("菜品分页查询")

public Result<PageResult> page(DishPageQueryDTO dishPageQueryDTO){

log.info("菜品分页查询：{}",dishPageQueryDTO);

PageResult pageResult = dishService.pageQuery(dishPageQueryDTO);

return Result.success(pageResult);

}

在sky-server的service中已有的DishService类中添加如下代码：

public PageResult pageQuery(DishPageQueryDTO dishPageQueryDTO);

在sky-server的service中已有的DishServiceImpl类中添加如下代码

public PageResult pageQuery(DishPageQueryDTO dishPageQueryDTO){

PageHelper.startPage(dishPageQueryDTO.getPage(),dishPageQueryDTO.getPageSize());

Page<DishVO> page = dishMapper.pageQuery(dishPageQueryDTO);

return new PageResult(page.getTotal(),page.getResult());

}

在sky-server的mapper中已有的DishMapper类中添加如下代码：

Page<DishVO> pageQuery(DishPageQueryDTO dishPageQueryDTO);

 在sky-server的resources下的mapper下已有的DishMapper.xml中写入如下代码：

<select id="pageQuery" resultType="com.sky.vo.DishVO">

select d.* , c.name as categoryName from dish d left outer join category c on d.category_id = c.id

<where>

<if test="name != null">

and d.name like concat('%',#{name},'%')

</if>

<if test="categoryId != null">

and d.category_id = #{categoryId}

</if>

<if test="status != null">

and d.status = #{status}

</if>

</where>

</select>

可以先在Navicat中编写SQL语句进行查询再写到配置文件中。

出现问题，有2列都叫name，于是给category表起别名。

select d.* , c.name as categoryName from dish d left outer join category c on d.category_id = c.id

简单测试一下发现没有问题：

3.26 (删除菜品)设计分析P42

3.27 (删除菜品)代码实现P43

批量删除是在地址栏写入要删除菜品的集合。

在sky-server的controller中已有的DishController类中添加如下代码：

@DeleteMapping

@ApiOperation("菜品批量删除")

public Result delete(@RequestParam List<Long> ids){

log.info("菜品批量删除：{}",ids);

dishService.deleteBatch(ids);

return Result.success();

}

需要加一个注解@RequestParam，可以将地址栏中多个数字参数提取出来然后变成List集合。 

在sky-server的service中已有的DishService类中添加如下代码：

void deleteBatch(List<Long> ids);

在sky-server的service的Impl中已有的DishServiceImpl类中添加如下代码：

@Transactional

public void deleteBatch(List<Long> ids){

//不能删除：存在起售中的菜品

for (Long id : ids) {

Dish dish = dishMapper.getById(id);

if(dish.getStatus()== StatusConstant.ENABLE){ //状态为1起售中

//当前菜品处于起售中，不能删除

throw new DeletionNotAllowedException(MessageConstant.DISH_ON_SALE);

}

}

//不能删除：菜品被套餐关联

List<Long> setmealIds = setmealDishMapper.getSetmealIdsByDishIds(ids);

if(setmealIds != null && setmealIds.size()>0){

//当前菜品被套餐关联了，不能删除

throw new DeletionNotAllowedException(MessageConstant.DISH_BE_RELATED_BY_SETMEAL);

}

//删除菜品表中的菜品数据

for (Long id : ids) {

dishMapper.deleteById(id);

//删除口味数据

dishFlavorMapper.deleteByDishId(id);

}

}

批量删除用foreach循环来遍历，删除被套餐关联的SQL语句比较复杂。 

删除菜品表中的菜品数据这里，每次循环需要执行2次SQL，可能会出现性能问题。应该采用如下的SQL形式：delete from dish where id in (?,?,?)。

在sky-server的mapper中已有的DishMapper类中添加如下代码（负责删除菜品）：

//根据主键删除菜品

@Delete("delete from dish where id = #{id}")

void deleteById(Long id);

在sky-server的mapper中创建DishFlavorMapper类中添加如下代码（负责删除关联的口味数据）：

//根据菜品id删除对应的口味数据

@Delete("delete from dish_flavor where dish_id = #{dishId}")

void deleteByDishId(Long dishId);

在sky-server的mapper中创建SetmealDishMapper类中添加如下代码（负责查看是否有关联的套餐）：

@Mapper

public interface SetmealDishMapper {

//根据菜品id查询对应的套餐id

//select setmeal_id from setmeal_dish where dish_id in (1,2,3,4)

List<Long> getSetmealIdsByDishIds(List<Long> dishIds);

}

（上步SQL具体实现）在sky-server的resources的mapper中创建SetmealDishMapper类中添加如下代码（思路是去查询套餐表，看套餐菜品id是否和当前传入的id相同）：

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.sky.mapper.SetmealDishMapper">

<select id="getSetmealIdsByDishIds" resultType="java.lang.Long">

select setmeal_id from setmeal_dish where dish_id in

<foreach collection="dishIds" item="dishId" separator="," open="(" close=")">

#{dishId}

</foreach>

</select>

</mapper>

这里比较巧妙的是foreach循环，collection是集合，item是一个个项，separator是分割符号，open是开始符号，close是结束符号。每个元素用逗号分割，然后用大括号括起来。 

3.28 (删除菜品)功能测试P44

先测试一下删除单个，再测试批量删除。要注意起售中和被套餐关联的菜品不能被删除。最后提交一下代码：删除菜品业务代码开发。

 在sky-server的service的Impl中已有的DishServiceImpl类中修改代码如下（只是修改最后一部分）：

@Transactional

public void deleteBatch(List<Long> ids){

//不能删除：存在起售中的菜品

for (Long id : ids) {

Dish dish = dishMapper.getById(id);

if(dish.getStatus()== StatusConstant.ENABLE){ //状态为1起售中

//当前菜品处于起售中，不能删除

throw new DeletionNotAllowedException(MessageConstant.DISH_ON_SALE);

}

}

//不能删除：菜品被套餐关联

List<Long> setmealIds = setmealDishMapper.getSetmealIdsByDishIds(ids);

if(setmealIds != null && setmealIds.size()>0){

//当前菜品被套餐关联了，不能删除

throw new DeletionNotAllowedException(MessageConstant.DISH_BE_RELATED_BY_SETMEAL);

}

//删除菜品表中的菜品数据

dishMapper.deleteByIds(ids);

//删除口味数据

dishFlavorMapper.deleteByDishIds(ids);

}

在sky-server的mapper中已有的DishMapper类中添加如下代码：

void deleteByIds(List<Long> ids);

在sky-server的resources的mapper中已有的DishMapper.xml配置文件中添加如下代码：

<delete id="deleteByIds">

delete from dish where id in

<foreach collection="ids" separator="," open="(" close=")">

#{id}

</foreach>

</delete>

在sky-server的mapper中已有的DishFlavorMapper类中添加如下代码：

void deleteByDishIds(List<Long> dishIds);

在sky-server的resources的mapper中已有的DishFlavorMapper.xml配置文件中添加如下代码：

<delete id="deleteByDishIds">

delete from dish_flavor where dish_id

<foreach collection="dishIds" separator="," open="(" close=")">

#{dishId}

</foreach>

</delete>

3.29 (修改菜品)分析设计P45

根据id查询菜品和口味，回显返回数据。然后修改菜品（用PUT）。

3.30 (修改菜品)代码开发P46

 在sky-server的controller中已有的DishController类中添加代码如下：

@GetMapping("/{id}")

@ApiOperation("根据id查询菜品")

public Result<DishVO> getById(@PathVariable Long id){

log.info("根据id查询菜品：{}",id);

DishVO dishVO = dishService.getByIdWithFlavor(id);

return Result.success(dishVO);

}

 在sky-server的service中已有的DishService类中添加代码如下：

//根据id查询菜品

DishVO getByIdWithFlavor(Long id);

 在sky-server的service的Impl中已有的DishServiceImpl类中添加代码如下：

//根据id查询菜品和对应的口味数据

public DishVO getByIdWithFlavor(Long id){

//根据id查询菜品数据

Dish dish = dishMapper.getById(id);

//根据菜品id查询口味数据

List<DishFlavor> dishFlavors = dishFlavorMapper.getByDishId(id);

//将查询到的数据封装到VO

DishVO dishVO = new DishVO() ;

BeanUtils.copyProperties(dish,dishVO);

dishVO.setFlavors(dishFlavors);

return dishVO;

}

  在sky-server的mapper中已有的dishFlavorMapper类中添加代码如下：

@Select("select * from dish_flavor where dish_id=#{dishId}")

List<DishFlavor> getByDishId(Long dishId);

3.31 (修改菜品)代码开发P47

 在sky-server的controller中已有的DishController类中添加代码如下：

//修改菜品

@PutMapping

@ApiOperation("修改菜品")

public Result update(@RequestBody DishDTO dishDTO){

log.info("修改菜品；{}",dishDTO);

dishService.updateWithFlavor(dishDTO);

return Result.success();

}

 在sky-server的service中已有的DishService类中添加代码如下：

//根据id修改菜品基本信息和对应的口味信息

void updateWithFlavor(DishDTO dishDTO);

 在sky-server的service的Impl中已有的DishServiceImpl类中添加代码如下：

//根据id修改菜品基本信息和对应的口味信息

public void updateWithFlavor(DishDTO dishDTO){

Dish dish = new Dish();

BeanUtils.copyProperties(dishDTO,dish);

//修改菜品表基本信息

dishMapper.update(dish);

//删除原有的口味数据

dishFlavorMapper.deleteByDishId(dishDTO.getId());

//重新插入口味数据

List<DishFlavor> flavors = dishDTO.getFlavors();

if(flavors != null && flavors.size()>0){

flavors.forEach(dishFlavor ->{

dishFlavor.setDishId(dishDTO.getId());

});

}

dishFlavorMapper.insertBatch(flavors);

}

口味的修改比较麻烦，有可能是删除了再新增，有可能不删除，有可能没删除直接新增。

处理方法：直接把菜品原先关联的口味数据删掉，然后再按照当前传来的口味重新插入数据。

传入DTO不合适，因为DTO里有口味数据，而修改菜品不应该包含口味，所以应该只传入一个Dish数据。

  在sky-server的mapper中已有的dishFlavorMapper类中添加代码如下：

//根据id动态修改菜品

@AutoFill(value=OperationType.UPDATE)

void update(Dish dish);

  在sky-server的resources下的mapper中已有的dishFlavorMapper.xml类中添加代码如下：

<update id="update">

update dish

<set>

<if test="name != null"> name = #{name},</if>

<if test="categoryId != null">category_id = #{categoryId},</if>

<if test="price != null">price = #{price},</if>

<if test="image != null">image = #{image},</if>

<if test="description != null">description = #{description},</if>

<if test="status != null">status = #{status},</if>

<if test="updateTime != null">update_Time = #{updateTime},</if>

<if test="updateUser != null">update_User = #{updateUser},</if>

</set>

where id = #{id}

</update>

这里用的是动态SQL。

3.32 (修改菜品)功能测试P48

前后端联调测试，尝试修改一道菜品，能成功修改即可。

四、Redis系列

本辑讲的是：Redis入门 -> Redis数据类型 -> Redis常用命令 -> 在Java中操作Redis -> 店铺营业状态设置。

4.1 Redis入门 P50

Redis是一个基于内存的key-value结构数据库。读写性能高。因为内存有限所以不能存储所有数据。Redis只存储热点数据。

下载方式：直接在苍穹外卖资料包中第5天的资料中，选择windows版本x64版的压缩包解压。

启动方式：在redis-server.exe和redis.windows.conf所在的目录，点击路径栏，输入cmd，然后输入下面的启动命令：

redis-server.exe redis.windows.conf

下面就是启动成功： 

输入ctrl+c就是停止服务。

在server服务端启动的基础上，去启动客户端cli，同样进入当前路径下的cmd，然后输入：

redis-cli.exe

如果出现下面就是成功进入： 

输入exit即可退出。

cli客户端可以通过-h指定连接的ip，-p制定连接的端口：

redis-cli.exe -h localhost -p 6379

redis默认没有密码，如果需要密码则修改redis.windows.conf配置文件。

此时重新登录也并不会提示输入密码，但如果输入keys *则会报错，身份验证被要求。

通过-a的方式来输入密码：

redis-cli.exe -h localhost -p 6379 -a 密码

也可以通过图形化界面来操作服务。

填入Host和Port和密码即可图形化：

4.2 Redis常用数据类型 P51

Redis存储是key-value结构的数据，其中key是字符串类型，value有5种常用的数据类型。

字符串string，哈希hash，列表list，集合set，有序集合zset（sorted set）。

哈希：在value里面又分为field和value。比较适合存储对象，包括属性和值。

列表：类似于一个队列，有顺序，按照插入顺序排序，可以有重复元素。可以存储跟顺序有关系的。

集合：无序集合，没有重复元素。可以运算交集或者并集。

有序集合：集合中每个元素关联一个分数，根据分数升序排序，没有重复元素。适用场景排行榜，或者投票排名、

4.3 Redis字符串操作P52

可以通过可视化工具来练习Redis语法：

SET key value                设置指定key的值。

GET key                         获取指定key的值。

SETEX key seconds value                 设置指定key的值，并将key的过期时间设为seconds秒。

（seconds是时间，时间以秒为单位，下图想说明的是如果过期了，将直接删除key和value）

 

SETNX key value                只有在key不存在时设置key的值。

（下图想说明的是如果已经存在了某个键将无法再重新设置，设置成功返回1，设置失败返回0）

4.4 Redis哈希操作P53

HSET key field value                将哈希表key中的字段field的值设为value。

效果展示如下图：

HGET key field                获取存储在哈希表中指定field的值。

HDEL key field                删除存储在哈希表中的指定field。

HKEYS key                获取哈希表中所有field。

HVALS key                获取哈希表中所有value。

4.5 Redis列表操作P54

列表是简单的字符串列表，跟插入顺序有关，最先插入的会排在最后。

LPUSH key value1 [value2]                将一个或多个值插入到列表头部

LRANGE key start stop                获取列表指定范围内的元素

（如果stop为-1则表示获取全部元素）

RPOP key                移除并获取列表最后一个元素

LLEN key                获取列表长度

4.6 Redis集合操作P55

集合中没有重复元素。而且没有顺序。

SADD key member1 [member2]                向集合添加一个或多个成员。

SMEMBERS key                返回集合中的所有成员。

SCARD key                获取集合的成员数

SINTER key1 [key2]                返回给定所有集合的交集

SUNION key1 [key2]                返回所有给定集合的并集

SREM key member1 [member2]                删除集合中一个或多个成员

4.7 Redis有序集合操作P56

ZADD key score1 member1 [score2 member2]                向有序集合添加一个或多个成员

ZRANGE key start stop [WITHSCORES]                通过索引区间返回有序集合中指定区间内的成员。（stop为-1表示范围为全部，withscores是展示member的同时展示score）

 

ZINCRBY key increment member                有序集合中对指定成员的分数加上增量increment。

 

ZREM key member [member ...]                移除有序集合中的一个或多个成员。

 

4.8 Redis 通用命令P57

KEYS pattern                查找所有符合给定模式（pattern）的key

（*代表全部，剩下的可以是半匹配）

EXISTS key                检查给定key是否存在

TYPE key                返回key所储存的值的类型

DEL key                该命令用于在key存在时删除key

Java中操作Redis

4.9 操作步骤说明 P58

Redis的Java客户端很多，包括：Jedis（所有的方法和Redis是一一对应的）、Lettuce、Spring Data Redis。

Spring Data Redis是Spring的一部分，对Redis底层开发包进行了高度封装。在Spring项目中，可以使用Spring Data Redis来简化操作。

①导入Spring Data Redis的maven坐标

②配置Redis数据源

③编写配置类，创建RedisTemplate对象

④通过RedisTemplate对象操作Redis

4.10 环境搭建P59

①导入Spring Data Redis的maven坐标

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-redis</artifactId>

</dependency>

②配置Redis数据源

方法1：是直接在application.yml中配置，但不推荐，最好使用引用。

spring:

redis:

host: localhost

port: 6379

database: 0

方法2：是在application-dev.yml中配置具体值

sky:

redis:

host: localhost

port: 6379

database: 0

在application.yml中配置引用

spring:

redis:

host: ${sky.redis.host}

port: ${sky.redis.port}

database: ${sky.redis.database}

 数据库默认是0号数据库（DB0），一直到15，总共16个。

③编写配置类，创建RedisTemplate对象

 在sky-server下的config包下创建RedisConfiguration类，写入如下代码：

@Configuration

@Slf4j

public class RedisConfiguration {

@Bean

public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){

log.info("开始创建redis模板对象...");

RedisTemplate redisTemplate = new RedisTemplate();

//设置redis的连接工厂对象

redisTemplate.setConnectionFactory(redisConnectionFactory);

//设置redis key的序列化器

redisTemplate.setKeySerializer(new StringRedisSerializer());

return redisTemplate;

}

}

 在sky-server/src/test/java/com/sky/test下创建Java类SpringDataRedisTest写入如下代码：

@SpringBootTest

public class SpringDataRedisTest {

@Autowired

private RedisTemplate redisTemplate;

@Test

public void testRedisTemplate(){

System.out.println(redisTemplate);

ValueOperations valueOperations = redisTemplate.opsForValue();

HashOperations hashOperations = redisTemplate.opsForHash();

ListOperations listOperations = redisTemplate.opsForList();

ZSetOperations zSetOperations = redisTemplate.opsForZSet();

}

}

可以先运行当前文件输出一下看看是否生成了对象。 

④通过RedisTemplate对象操作Redis

 4.11 操作字符串数据 P60

Redis的String和Java的String不是完全相同。Java中的任何对象都会转为Redis的字符串进行存储。

在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码：

//操作字符串类型的数据

@Test

public void testString(){

//set get setex setnx

redisTemplate.opsForValue().set("city","北京");

String city = (String)redisTemplate.opsForValue().get("city");

System.out.println(city);

redisTemplate.opsForValue().set("code","1234",3, TimeUnit.MINUTES);//第3个参数是时间，第4个参数是时间单位

redisTemplate.opsForValue().setIfAbsent("lock","1");

redisTemplate.opsForValue().setIfAbsent("lock","2");

}

 value会有乱码的现象，key不会有问题，是因为序列化器不同，所以结果不同。

4.12 操作哈希数据P61

在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码：

@Test

public void testHash(){

//hset hget hkeys hvals

HashOperations hashOperations = redisTemplate.opsForHash();

hashOperations.put("100","name","tom"); //相当于hset

hashOperations.put("100","age","20");

String name = (String)hashOperations.get("100", "name"); //相当于hget

System.out.println(name);

Set keys = hashOperations.keys("100"); //相当于hkeys

System.out.println(keys);

List values = hashOperations.values("100"); //相当于hvals

System.out.println(values);

hashOperations.delete("100","age");//相当于hdel

}

控制台输出结果如下：

4.13 操作其它类型数据P62

列表（list）类数据：

在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码：

@Test

public void testList(){

//Lpush lrange rpop llen

ListOperations listOperations = redisTemplate.opsForList();

listOperations.leftPushAll("mylist","a","b","c"); //lpush多个value

listOperations.leftPush("mylist","d"); //lpush单个value

List mylist = listOperations.range("mylist",0,-1); //lrange

System.out.println(mylist);

listOperations.rightPop("mylist"); //rpop

Long size = listOperations.size("mylist"); //llen

System.out.println(size);

}

 

集合类数据：

在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码：

@Test

public void testSet(){

//sadd smembers scard sinter sunion srem

SetOperations setOperations = redisTemplate.opsForSet();

setOperations.add("set1","a","b","c","d"); //sadd

setOperations.add("set2","a","b","x","y");

Set members = setOperations.members("set1"); //smembers

System.out.println(members);

Long size = setOperations.size("set1"); //scard

System.out.println(size);

Set intersect = setOperations.intersect("set1","set2"); //sinter取交集

System.out.println(intersect);

Set union = setOperations.union("set1","set2"); //sunion取并集

System.out.println(union);

setOperations.remove("set1","a","b"); //srem

}

有序集合类数据：

在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码：

@Test

public void testZset(){

//zadd zrange zincrby zrem

ZSetOperations zSetOperations = redisTemplate.opsForZSet();

zSetOperations.add("zset1","a",10); //zadd

zSetOperations.add("zset2","b",12);

zSetOperations.add("zset1","c",9);

Set zset1 = zSetOperations.range("zset1",0,-1); //zrange

System.out.println(zset1);

zSetOperations.incrementScore("zset1","c",10); //zincrby

zSetOperations.remove("zset1","a","b"); //zrem

}

通用命令操作：

在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码：

@Test

public void testCommon(){

//keys exists type del

Set keys = redisTemplate.keys("*"); //keys

System.out.println(keys);

Boolean name = redisTemplate.hasKey("name"); //exists

Boolean set1 = redisTemplate.hasKey("set1");

for(Object key : keys){

DataType type = redisTemplate.type(key); //type

System.out.println(type.name());

}

redisTemplate.delete("mylist"); //del

}

4.14(营业状态设置)分析设计P63

设置营业状态；管理端查询营业状态，用户端查询营业状态（管理端和用户端查询路径不同）。

营业状态存储在Redis中，不用在Mysql中单独创建一张表。

4.15(营业状态设置)代码开发P64

先把test中的SpringDataRedisTest里的@SpringBootTest注释掉。

这里要注意一点：营业状态是存储在Redis中的，SHOP_STATUS这个key不能够通过redis直接修改，这里必须通过前端页面（管理端电脑）进行修改，也就是调用下面的setStatus，因为redis和SpringDataRedis的序列化器是不同的。

在controller/admin下创建ShopController这个是管理端的，写入如下代码：

@RestController("adminShopController")

@RequestMapping("/admin/shop")

@Api(tags="店铺相关接口")

@Slf4j

public class ShopController {

public static final String KEY="SHOP_STATUS";

@Autowired

private RedisTemplate redisTemplate;

//设置店铺营业状态

@PutMapping("/{status}")

@ApiOperation("设置店铺的营业状态")

public Result setStatus( @PathVariable Integer status){

log.info("设置店铺的营业状态为：{}",status==1 ?"营业中":"打烊中");

redisTemplate.opsForValue().set("SHOP_STATUS",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);

}

}

在controller下创建user包，然后把amin的ShopController复制到这个下面，然后进行简单修改，只保留获取状态的。因为有2个类类名相同，会导致Bean冲突，所以我们要在@RestController中指定Bean的名称。

@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);

}

}

4.16(营业状态设置)功能测试P65

直接通过前后端联调的方式，去修改营业的状态，然后退出看状态是否保持，在Redis可视化界面中是否有相关的key-value记录。

因为现在接口用户端和管理端没有区分开，很不好看，所以现在在sky-server下的config的WebMvcConfiguration中写入如下代码：

@Bean

public Docket docket() {

ApiInfo apiInfo = new ApiInfoBuilder()

.title("苍穹外卖项目接口文档")

.version("2.0")

.description("苍穹外卖项目接口文档")

.build();

Docket docket = new Docket(DocumentationType.SWAGGER_2)

.groupName("管理端接口")

.apiInfo(apiInfo)

.select()

.apis(RequestHandlerSelectors.basePackage("com.sky.controller.admin"))

.paths(PathSelectors.any())

.build();

return docket;

}

@Bean

public Docket docket1() {

ApiInfo apiInfo = new ApiInfoBuilder()

.title("苍穹外卖项目接口文档")

.version("2.0")

.description("苍穹外卖项目接口文档")

.build();

Docket docket = new Docket(DocumentationType.SWAGGER_2)

.groupName("用户端接口")

.apiInfo(apiInfo)

.select()

.apis(RequestHandlerSelectors.basePackage("com.sky.controller.user"))

.paths(PathSelectors.any())

.build();

return docket;

}

可以分为用户端和管理端的接口：