史上最完整的《苍穹外卖》项目实操笔记,跟视频的每一P对应,全系列10万字,涵盖详细步骤与问题的解决方案。如果你操作到某一步卡壳,参考这篇,相信会带给你极大启发。
《苍穹外卖》项目实操笔记【中】:P66~P122《苍穹外卖》项目实操笔记【中】
《苍穹外卖》项目实操笔记【下】:P123~P189《苍穹外卖》项目实操笔记【下】
一、重要知识点精讲
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使用步骤
导入下面坐标:
com.github.xiaoyminknife4j-spring-starter3.0.2
相关配置:
@Beanpublic 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 后续需要改为当前登录用户的idemployee.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方法,在方法里添加如下代码:
@ExceptionHandlerpublic 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的基础上加上code和msg,作为返回给前端的对象。
在EmployeeController添加一个方法:
@GetMapping("/page")@ApiOperation("员工分页查询")public Result page(EmployeePageQueryDTO employeePageQueryDTO){ log.info("员工分页查询,参数为:{}",employeePageQueryDTO); PageResult pageResult = employeeService.PageQuery(employeePageQueryDTO); return Result.success(pageResult);}
在EmployeeService接口中编写方法:
public PageResult PageQuery(EmployeePageQueryDTO employeePageQueryDTO);
在EmployeeServiceImpl中实现方法:
@Overridepublic PageResult PageQuery(EmployeePageQueryDTO employeePageQueryDTO) { //DTO已将页码和每页记录数传入,因此可以算出// select * from employee limit 0,10,通过Limit来控制PageHelper.startPage(employeePageQueryDTO.getPage(),employeePageQueryDTO.getPageSize()); //页码和每页记录数传入//Page是固定的,Employee是每个用户的信息Page page = employeeMapper.pageQuery(employeePageQueryDTO);////要将page对象处理为PageResult对象long total = page.getTotal();List result = page.getResult();return new PageResult(total,result);}
PageHelper的startPage方法可以通过传入的参数自动设置Limit,传入的是页码和每页的记录数,好处是:字符串的拼接不用自己做。底层实现是:它会给ThreadLocal设置上述参数,然后在执行SQL语句时会自动被取出,然后拼接成Limit。
Page是PageHelper插件定义的一个泛型类,是一个固定的返回类型。
pagehelper可以简化分页代码的编写:
在EmployeeMapper中编写方法:
Page pageQuery(EmployeePageQueryDTO employeePageQueryDTO);
在application.yml配置文件中扫描了EmployeeMapper.xml配置文件:
在EmployeeMapper.xml中编写SQL语句,limit不用我们手写,pagehelper会自动帮我们追加拼接,order by是排序条件:
select * from employeeand name like concat('%',#{name},'%')order by create_time desc
如果有传入name,代表是员工姓名查询,它只会返回带有相关词(字也可以,因为是模糊查询)的员工信息。
如果没有传入name,那么name就为空,判断内容不执行,默认返回1,所以它会查询所有employee元素。
在这里是模糊查询,用concat将name与%进行拼接,%的意思是匹配任意字符串/字符。
标签的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在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种书写方式:
@Overridepublic void startOrStop(Integer status, Long id) {//update employee set status = " />下面这个代码对全字段都可以进行修改,所以不仅仅适用于对status的修改: update employee name = #{name}, username = #{username}, password = #{password}, phone = #{phone}, sex = #{sex}, id_Number = #{idNumber}, update_Time = #{updateTime}, update_User = #{updateUser}, status = #{status},where id = #{id}
3.11 (编辑员工)分析设计P27
可以修改员工的姓名、手机号和身份证号等。
首先根据id查询到员工信息,然后编辑员工信息。
3.12 (编辑员工)代码开发P28
①回显数据操作:用查询语句把Employee对象查出来,然后显示。
EmployeeController编写如下代码:
@GetMapping("/{id}")@ApiOperation("根据id查询员工信息")public Result getById(@PathVariable Long id){Employee employee = employeeService.getById(id);return Result.success(employee);}
EmployeeService接口编写如下代码:
//根据id查询员工Employee getById(Long id);
EmployeeServiceImpl实现类编写如下代码:
@Overridepublic 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实现类编写如下代码:
@Overridepublic 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 INSERTOperationType value();}
Target注解指定加上什么上面,Retention注解指定什么时候用,
2. 在com.sky下创建aspect包,创建类AutoFillAspect,写入如下代码:
//自定义切面,实现公共字段自动填充处理逻辑@Aspect@Component@Slf4jpublic 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();//通过连接点对象来获取签名,向下转型为MethodSignatureAutoFill 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="通用接口")@Slf4jpublic class CommonController {@PostMapping("/upload")@ApiOperation("文件上传")public Result 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@Slf4jpublic class OssConfiguration {@Bean@ConditionalOnMissingBeanpublic 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="通用接口")@Slf4jpublic class CommonController {@Autowiredprivate AliOssUtil aliOssUtil;//文件上传@PostMapping("/upload")@ApiOperation("文件上传")public Result 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="菜品相关接口")@Slf4jpublic class DishController {@Autowiredprivate 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@Slf4jpublic class DishServiceImpl implements DishService {@Autowiredprivate DishMapper dishMapper;@Autowiredprivate DishFlavorMapper dishFlavorMapper;//新增菜品对应的口味@Transactionalpublic void saveWithFlavor(DishDTO dishDTO) {Dish dish = new Dish();BeanUtils.copyProperties(dishDTO,dish);//想菜品表插入1条数据dishMapper.insert(dish);//获取insert语句生成的主键值Long dishId = dish.getId();//向口味表插入n条数据List 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方法的代码:
@Mapperpublic 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文件,写入如下代码:
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})
在sky-server的mapper创建DishFlavorMapper类,写入insert方法的代码。
@Mapperpublic interface DishFlavorMapper {@AutoFill(value= OperationType.INSERT)void insertBatch(List flavors);}
在sky-server的resources下的mapper下创建DishFlavorMapper.xml文件,写入如下代码。
insert into dish_flavor (dish_id,name,value) VALUES(#{df.dishId},#{df.name},#{df.value})
在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 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 page = dishMapper.pageQuery(dishPageQueryDTO);return new PageResult(page.getTotal(),page.getResult());}
在sky-server的mapper中已有的DishMapper类中添加如下代码:
Page pageQuery(DishPageQueryDTO dishPageQueryDTO);
在sky-server的resources下的mapper下已有的DishMapper.xml中写入如下代码:
select d.* , c.name as categoryName from dish d left outer join category c on d.category_id = c.idand d.name like concat('%',#{name},'%')and d.category_id = #{categoryId}and d.status = #{status}
可以先在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 ids){log.info("菜品批量删除:{}",ids);dishService.deleteBatch(ids);return Result.success();}
需要加一个注解@RequestParam,可以将地址栏中多个数字参数提取出来然后变成List集合。
在sky-server的service中已有的DishService类中添加如下代码:
void deleteBatch(List ids);
在sky-server的service的Impl中已有的DishServiceImpl类中添加如下代码:
@Transactionalpublic void deleteBatch(List ids){//不能删除:存在起售中的菜品for (Long id : ids) {Dish dish = dishMapper.getById(id);if(dish.getStatus()== StatusConstant.ENABLE){ //状态为1起售中//当前菜品处于起售中,不能删除throw new DeletionNotAllowedException(MessageConstant.DISH_ON_SALE);}}//不能删除:菜品被套餐关联List 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中创建DishFlavorMapper类中添加如下代码(负责删除关联的口味数据):
//根据菜品id删除对应的口味数据@Delete("delete from dish_flavor where dish_id = #{dishId}")void deleteByDishId(Long dishId);
在sky-server的mapper中创建SetmealDishMapper类中添加如下代码(负责查看是否有关联的套餐):
@Mapperpublic interface SetmealDishMapper {//根据菜品id查询对应的套餐id//select setmeal_id from setmeal_dish where dish_id in (1,2,3,4)List getSetmealIdsByDishIds(List dishIds);}
(上步SQL具体实现)在sky-server的resources的mapper中创建SetmealDishMapper类中添加如下代码(思路是去查询套餐表,看套餐菜品id是否和当前传入的id相同):
select setmeal_id from setmeal_dish where dish_id in#{dishId}
这里比较巧妙的是foreach循环,collection是集合,item是一个个项,separator是分割符号,open是开始符号,close是结束符号。每个元素用逗号分割,然后用大括号括起来。
3.28 (删除菜品)功能测试P44
先测试一下删除单个,再测试批量删除。要注意起售中和被套餐关联的菜品不能被删除。最后提交一下代码:删除菜品业务代码开发。
在sky-server的service的Impl中已有的DishServiceImpl类中修改代码如下(只是修改最后一部分):
@Transactionalpublic void deleteBatch(List ids){//不能删除:存在起售中的菜品for (Long id : ids) {Dish dish = dishMapper.getById(id);if(dish.getStatus()== StatusConstant.ENABLE){ //状态为1起售中//当前菜品处于起售中,不能删除throw new DeletionNotAllowedException(MessageConstant.DISH_ON_SALE);}}//不能删除:菜品被套餐关联List 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 ids);
在sky-server的resources的mapper中已有的DishMapper.xml配置文件中添加如下代码:
delete from dish where id in#{id}
在sky-server的mapper中已有的DishFlavorMapper类中添加如下代码:
void deleteByDishIds(List dishIds);
在sky-server的resources的mapper中已有的DishFlavorMapper.xml配置文件中添加如下代码:
delete from dish_flavor where dish_id#{dishId}
3.29 (修改菜品)分析设计P45
根据id查询菜品和口味,回显返回数据。然后修改菜品(用PUT)。
3.30 (修改菜品)代码开发P46
在sky-server的controller中已有的DishController类中添加代码如下:
@GetMapping("/{id}")@ApiOperation("根据id查询菜品")public Result 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 dishFlavors = dishFlavorMapper.getByDishId(id);//将查询到的数据封装到VODishVO 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 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 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 dish name = #{name},category_id = #{categoryId},price = #{price},image = #{image},description = #{description},status = #{status},update_Time = #{updateTime},update_User = #{updateUser},where id = #{id}
这里用的是动态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坐标
org.springframework.bootspring-boot-starter-data-redis
②配置Redis数据源
方法1:是直接在application.yml中配置,但不推荐,最好使用引用。
spring:redis:host: localhostport: 6379database: 0
方法2:是在application-dev.yml中配置具体值
sky:redis:host: localhostport: 6379database: 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@Slf4jpublic class RedisConfiguration {@Beanpublic 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写入如下代码:
@SpringBootTestpublic class SpringDataRedisTest {@Autowiredprivate RedisTemplate redisTemplate;@Testpublic 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中写入如下代码:
//操作字符串类型的数据@Testpublic void testString(){//set get setex setnxredisTemplate.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中写入如下代码:
@Testpublic void testHash(){//hset hget hkeys hvalsHashOperations hashOperations = redisTemplate.opsForHash();hashOperations.put("100","name","tom"); //相当于hsethashOperations.put("100","age","20");String name = (String)hashOperations.get("100", "name"); //相当于hgetSystem.out.println(name);Set keys = hashOperations.keys("100"); //相当于hkeysSystem.out.println(keys);List values = hashOperations.values("100"); //相当于hvalsSystem.out.println(values);hashOperations.delete("100","age");//相当于hdel}
控制台输出结果如下:
4.13 操作其它类型数据P62
列表(list)类数据:
在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码:
@Testpublic void testList(){//Lpush lrange rpop llenListOperations listOperations = redisTemplate.opsForList();listOperations.leftPushAll("mylist","a","b","c"); //lpush多个valuelistOperations.leftPush("mylist","d"); //lpush单个valueList mylist = listOperations.range("mylist",0,-1); //lrangeSystem.out.println(mylist);listOperations.rightPop("mylist"); //rpopLong size = listOperations.size("mylist"); //llenSystem.out.println(size);}
集合类数据:
在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码:
@Testpublic void testSet(){//sadd smembers scard sinter sunion sremSetOperations setOperations = redisTemplate.opsForSet();setOperations.add("set1","a","b","c","d"); //saddsetOperations.add("set2","a","b","x","y");Set members = setOperations.members("set1"); //smembersSystem.out.println(members);Long size = setOperations.size("set1"); //scardSystem.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中写入如下代码:
@Testpublic void testZset(){//zadd zrange zincrby zremZSetOperations zSetOperations = redisTemplate.opsForZSet();zSetOperations.add("zset1","a",10); //zaddzSetOperations.add("zset2","b",12);zSetOperations.add("zset1","c",9);Set zset1 = zSetOperations.range("zset1",0,-1); //zrangeSystem.out.println(zset1);zSetOperations.incrementScore("zset1","c",10); //zincrbyzSetOperations.remove("zset1","a","b"); //zrem}
通用命令操作:
在sky-server/src/test/java/com/sky/test下已有的Java类SpringDataRedisTest中写入如下代码:
@Testpublic void testCommon(){//keys exists type delSet keys = redisTemplate.keys("*"); //keysSystem.out.println(keys);Boolean name = redisTemplate.hasKey("name"); //existsBoolean set1 = redisTemplate.hasKey("set1");for(Object key : keys){DataType type = redisTemplate.type(key); //typeSystem.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="店铺相关接口")@Slf4jpublic class ShopController {public static final String KEY="SHOP_STATUS";@Autowiredprivate RedisTemplate redisTemplate;//设置店铺营业状态@PutMapping("/{status}")@ApiOperation("设置店铺的营业状态")public Result setStatus( @PathVariable Integer status){log.info("设置店铺的营业状态为:{}",status==1 " /> 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="店铺相关接口")@Slf4jpublic class ShopController {public static final String KEY="SHOP_STATUS";@Autowiredprivate RedisTemplate redisTemplate;//获取店铺的营业状态@GetMapping("/status")@ApiOperation("获取店铺的营业状态")public Result 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中写入如下代码:
@Beanpublic 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;}@Beanpublic 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;}
可以分为用户端和管理端的接口: