苍穹外卖|DAY6-Redis和店铺营业状态设置模块

目录九、Redis1. Redis入门1.1 Redis下载与安装1.2 Redis服务启动与停止1.3 Redis图形化工具2. Redis数据类型3. Redis常用命令3.1 字符串操作命令3.2 哈希操作命令3.3 列表操作命令3.4 集合操作命令3.5 有序集合操作命令3.6 通用命令4. 在Java中操作Redis4.1 Redis的Java客户端4.2 Spring Data Redis使用方式十、店铺营业状态设置1. 需求分析和设计2. 代码开发3. 功能测试十一、小tip九、RedisRedis是一个基于内存的key-value结构数据库redis和mysql数据库的区别redis是通过键值对来存储数据mysql是通过二维表来存储数据redis是将数据存储在内存里→内存存储mysql是将数据通过数据文件的方式存储在磁盘上→磁盘存储redis特点基于内存存储 读写性能高适合存储热点数据热点商品、咨询、新闻企业应用广泛由于内存有限 所以不可能将数据全都存储在redis业务数据→mysql热点数据→redis1. Redis入门1.1 Redis下载与安装redis的Windows版属于绿色软件 直接解压即可使用 解压后目录结构如下1.2 Redis服务启动与停止注redis-server.exe redis.windows.conf→启动redis服务 ctrlC→退出redis服务注redis-cli.exe→连接redis服务 默认连接本地redis 并使用默认端口号6379redis-cli.exe -h 要连接的ip -p 指定端口号→指定连接哪个地方哪个端口的服务redis配置文件中默认是没有配置密码的 即默认情况下 客户端是不需要通过密码就可以连接上的→不安全 修改redis配置文件注把foobared改为想要修改的密码连接redis是没有用户的概念的 即不需要提供用户名 只提供密码即可配置密码后需要加-a 密码 来进行连接 否则操作无法正常进行通过redis-server启动redis服务 通过redis-cli连接redis1.3 Redis图形化工具Another Redis Desktop Manager2. Redis数据类型redis存储的是key-value结构的数据 其中key是字符串类型 value有五种常用的数据类型字符串 string普通字符串 redis中最简单的数据类型哈希 hash也叫散列 类似于Java中的HashMap结构→比较适合存储对象列表 list按照插入顺序排序 可以有重复元素 类似于Java中的LinkedList集合 set无序集合 没有重复元素 类似于Java中的HashSet有序集合 sorted set/zset集合中每个元素关联一个分数score 根据分数升序排序 没有重复元素3. Redis常用命令mysql数据库中通过sql语句操作数据库 sql的结构跟数据类型无关redis数据库中插入数据需要看数据类型 不同数据类型的命令不同3.1 字符串操作命令注SETEX key seconds value适用场景→短信验证码SETNX key value适用场景→分布式锁一种在分布式系统多个独立进程或服务中 用来保证同一时刻只有一个客户端能访问共享资源的机制3.2 哈希操作命令3.3 列表操作命令注L是left R是rightstart为0头部 stop为-1尾部 代表将列表的所有元素返回3.4 集合操作命令3.5 有序集合操作命令注ZRANGE key start stop返回默认是升序排列3.6 通用命令4. 在Java中操作Redis4.1 Redis的Java客户端Redis的Java客户端很多 常用的几种JedisLettuce底层是基于Netty高性能、异步事件驱动的网络应用框架这个多线程框架来实现的 性能高效Spring Data RedisSpring Data Redis是Spring的一部分 对redis底层开发包Jedis、Lettuce进行了高度封装在Spring项目中 可以使用Spring Data Redis来简化操作4.2 Spring Data Redis使用方式配置redis数据源编写配置类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 //RedisConnectionFactory→redis的连接工厂对象 public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){ log.info(开始创建redis模板对象...); RedisTemplate redisTemplate new RedisTemplate(); //设置连接工厂对象 redisTemplate.setConnectionFactory(redisConnectionFactory); //设置redis key的序列化器key在redis中显示正常 redisTemplate.setKeySerializer(new StringRedisSerializer()); return redisTemplate; } }SpringDataRedisTestpackage com.sky.test; ​ import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.redis.core.*; ​ import java.util.concurrent.TimeUnit; ​ SpringBootTest public class SpringDataRedisTest { Autowired private RedisTemplate redisTemplate; ​ Test public void RedisTemplate() { System.out.println(redisTemplate); //获取操作字符串的value对象 ValueOperations valueOperations redisTemplate.opsForValue(); //获取操作哈希的value对象 HashOperations hashOperations redisTemplate.opsForHash(); //获取操作列表的value对象 ListOperations listOperations redisTemplate.opsForList(); //获取操作集合的value对象 SetOperations setOperations redisTemplate.opsForSet(); //获取操作有序集合的value对象 ZSetOperations zSetOperations redisTemplate.opsForZSet(); } }操作字符串类型的数据/** * 操作字符串类型的数据 * */ Test public void testString() { //value在redis中显示是有问题的 因为通过java程序存储的数据 redis中存储的是序列化之后的数据 redisTemplate.opsForValue().set(city, 北京); String city (String) redisTemplate.opsForValue().get(city); System.out.println(city); redisTemplate.opsForValue().set(code,1234,3, TimeUnit.MINUTES); //value可以给任意类型Object 最终都会把这个对象进行序列化 转成redis当中的string进行存储 redisTemplate.opsForValue().setIfAbsent(lock,1); redisTemplate.opsForValue().setIfPresent(lock,2); }操作哈希类型的数据/** * 操作哈希类型数据 * */ Test public void testHash() { HashOperations hashOperations redisTemplate.opsForHash(); hashOperations.put(1,name,tom); hashOperations.put(1,age,18); String name (String) hashOperations.get(1, name); System.out.println(name); Set keys hashOperations.keys(1); System.out.println( keys); List values hashOperations.values(1); System.out.println(values); hashOperations.delete(1,age); }其他类型的数据操作类似/** * 操作列表类型数据 * */ Test public void testList() { ListOperations listOperations redisTemplate.opsForList(); listOperations.leftPushAll(list, 1, 2, 3); listOperations.leftPush(list, a); ​ List list listOperations.range(list, 0, -1); System.out.println(list); ​ listOperations.rightPop(list); ​ long size listOperations.size(list); System.out.println(size); } ​ /** * 操作集合类型数据 * */ Test public void testSet() { SetOperations setOperations redisTemplate.opsForSet(); setOperations.add(set1, 1, 2, 3); setOperations.add(set2, 2, 3, a); Set members setOperations.members(set1); System.out.println(members); ​ Long size setOperations.size(set1); System.out.println(size); ​ Set intersect setOperations.intersect(set1, set2); System.out.println(intersect); ​ Set union setOperations.union(set1, set2); System.out.println(union); ​ setOperations.remove(set1, 1); } ​ /** * 操作有序集合类型数据 * */ Test public void testZSet() { ZSetOperations zSetOperations redisTemplate.opsForZSet(); zSetOperations.add(zset, 1, 1); zSetOperations.add(zset, 2, 2); zSetOperations.add(zset, 3, 3); Set zset zSetOperations.range(zset, 0, -1); System.out.println(zset); ​ zSetOperations.incrementScore(zset, 1, 10); ​ zSetOperations.remove(zset, 1); } ​ /** * 通用命令操作 */ Test public void testCommon() { Set keys redisTemplate.keys(*); System.out.println(keys); ​ Boolean city redisTemplate.hasKey(city); System.out.println(city); ​ for (Object key : keys){ DataType type redisTemplate.type(key); System.out.println(type.name()); } ​ redisTemplate.delete(city); }Redis不能直接存储Java对象 所以RedisTemplate内部会使用序列化器将对象转换成字节数组再存进去 取数据时再用同样的序列化器把字节变回对象十、店铺营业状态设置1. 需求分析和设计接口设计设置营业状态、管理端查询营业状态、用户端查询营业状态本项目约定管理端发出的请求 统一使用/admin作为前缀用户端发出的请求 统一使用/user作为前缀所以查询营业状态接口需要分为管理端和用户端营业状态数据存储方式基于redis的字符串来进行存储约定1代表营业 0代表打烊2. 代码开发基于redis存储 不需要调用service、mapper等package com.sky.config; ​ import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import springfox.documentation.builders.ApiInfoBuilder; import springfox.documentation.builders.PathSelectors; import springfox.documentation.builders.RequestHandlerSelectors; import springfox.documentation.service.ApiInfo; import springfox.documentation.spi.DocumentationType; import springfox.documentation.spring.web.plugins.Docket; ​ Configuration Slf4j public class Knife4jConfiguration { ​ /** * 通过knife4j生成接口文档管理端接口文件 * * return */ Bean public Docket docket1() { ApiInfo apiInfo new ApiInfoBuilder().title(苍穹外卖项目接口文档).version(2.0).description(苍穹外卖项目接口文档).build(); ​ return new Docket(DocumentationType.SWAGGER_2) .apiInfo(apiInfo) .groupName(01-管理端接口文档) //分组名称 .select() .apis(RequestHandlerSelectors.basePackage(com.sky.controller.admin)) //设置扫描包范围 .paths(PathSelectors.any()) .build(); } ​ ​ /** * 通过knife4j生成接口文档用户端接口文档 * * return */ Bean public Docket docket2() { ApiInfo apiInfo new ApiInfoBuilder().title(苍穹外卖项目接口文档).version(2.0).description(苍穹外卖项目接口文档).build(); ​ return new Docket(DocumentationType.SWAGGER_2) .apiInfo(apiInfo) .groupName(02-用户端接口文档) //分组名称 .select() .apis(RequestHandlerSelectors.basePackage(com.sky.controller.user)) //设置扫描包范围 .paths(PathSelectors.any()) .build(); } ​ }注接口文档分为管理端和用户端 以便区分 修改扫描包的范围和分组名3. 功能测试十一、小tip通过redis-server启动redis服务 通过redis-cli连接redis业务数据→mysql 热点数据→redis由于内存有限 所以不可能将数据全都存储在redisRedis不能直接存储Java对象 所以RedisTemplate内部会使用序列化器将对象转换成字节数组再存进去 取数据时再用同样的序列化器把字节变回对象接口文档分为管理端和用户端 以便区分 修改扫描包的范围和分组名