# redis学习 **Repository Path**: ayuanyuan1/redis-learning ## Basic Information - **Project Name**: redis学习 - **Description**: No description available - **Primary Language**: Unknown - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 0 - **Created**: 2024-06-19 - **Last Updated**: 2024-06-19 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # redis学习 ## 一、键 > 1、keys*: 查看当前库所有key > > 2、exists key: 判断某个key是否存在 > > 3、type key: 查看你的key是什么类型 > > 4、del key: 删除指定的key > > 5、unlink key: 根据value选择==非阻塞==（异步）删除 > > 6、expire key 10: 为给定的key设置过期时间，单位秒 > > 7、ttl key: 查看还有多少秒过期，-1表示永不过期，-2表示已过期 > > 9、select ：命令切换数据库 > > 10、dbsize: 查看当前数据库的key的数量 > > 11、flushdb：清空当前库 > > 12、flushall: 通杀全部库 ## 二、常用数据类型 ### （1）字符串String > ·字符串最大长度为512M,单键单值 > > 1、set : 添加键值对，如果存在则修改 > > 2、get : 取值 > > 3、append : 追加值到末尾 > > 4、strlen : 获得值的长度 > > 5、setnx : 只有key不存在时，设置key的值 > > 6、incr : 将key中存储的数字值增加1，只能对数字操作，如果为空，新增值为1 > > 7、 decr : 将key中存储的数字值减1 > > 8、 incrby/decrby <步长>: 将key中存储的数字值加/减步长 > > 9、mset:设置一个或多个key-value对 > > 10、mget:同时获取一个或多个value > > 11、msetnx:设置一个或多个key-value对,有一个失败则都==失败== > > 12、getrange <起始位置><结束位置>：获得值的范围，包前包后 > > 13、setrange <起始位置>:覆盖之前的从起始位置开始的值 > > 14、setex <过期时间>:设置键值的同时，设置过期时间 > > 15、getset:设置新值的同时获得旧值 ### （2）列表List > 单键多值，底层是双向列表 > > 1、lpush/rpush :从左边/右边插入一个或多个值 > > 2、lpop/rpop:吐出一个值。==值在键在，值亡键亡== > > 3、rpoplpush:从key1右边吐出一个值，插到key2左边 > > 4、lrange:按照索引下标获得元素，stop为 -1表示末尾 > > 5、lindex:按照索引下标获得元素 > > 6、llen：或者列表的长度 > > 7、linsertbefore/after:在value的后面/前面插入新value > > 8、lrem:从左边删除n个value > > 9、lset:将列表key下标为index的值替换成value ### （3）集合Set > 添加、删除、查找的复杂度都是O(1) > > 1、sadd ：添加一个或多个元素，如果重复则忽略 > > 2、smembers：取出该集合的所有值 > > 3、sismember:判断集合是否存在value,有1，没有0 > > 4、scard:返回集合的元素个数 > > 5、srem:删除集合中某些元素 > > 6、spop:随机从改集合中吐出一个值 > > 7、srandmember:随机从集合中取出n个值，不会从集合中删除 > > 8、smove:把集合中一个值从一个集合移动到另外一个集合 > > 9、sinter:返回两个集合的交集元素 > > 10、sunion:返回两个集合的并集元素 > > 11、sdiff:返回两个集合的差集元素（key1中的，不包含key2中的） ### （4）哈希hash > key:{id=1,name=zhangsan,age=20} > > 1、hset :给集合中的field键赋value值 > > 2、hget :从集合field中取值 > > 3、hmset>：批量设置hash值 > > 4、hexists:判断field是否存在 > > 5、hkeys:列出集合的所有field > > 6、hvals:列出集合的所有value > > 7、hincrby:给field的值加上增量increment > > 8、hsetnx:给field的值设置为value,==field不存在== ### （5）有序集合Zset > 与set非常相似，是一个没有重复元素的字符串集合 > > 每个元素都都关联了一个评分，评分可以重复，通过评分可以排序(升序) > > 1、zadd:将一个或多个member元素及其score加入有序集key中 > > 2、zrange[withscores]:返回之间的元素，带withscores可以让分数和值一起返回到结果集 > > 3、zrangebyscore ==min max== [withscores] [limit off]:返回集合key中，所以score在min和max之间（包括边界）的元素，从小到大排序 > > 4、z==rev==rangebyscore ==max min== [withscores] [limit offset count]:从大到小 > > 5、zincrby :为元素的score加上增量 > > 6、zrem:删除该集合下指定value的值 > > 7、zcount ：统计分数区间的元素个数 > > 8、zrank:返回改value值在集合中的排名，从0开始 ## 三、新数据类型 ### （1）Bitmaps > 对字符串进行位操作 > > 合理使用位操作可以提高内存使用率和开发速率 > > 1、setbit :设置bitmaps中某个偏移量的值（0或1） > > 2、getbit :获取偏移量offset的值，从0开始算 > > 3、bitcount:统计字符串被设置为1的数量 > > 4、bitcount [start,end]:统计字符串在start~end（-1最后一位，-2倒数第二位）范围内被设置为1的数量 > > 5、bitop and(or/not/xor) [key1,key2]:把key1和可以2的交集（并集，非，异或）的结果保存到destkey ### （2）HyperLogLog > 基数就是一个集合中除去相同值的基准数 > > 基数中统计相关的功能 > > 1、pfadd : 添加一个或多个元素，能够去重 > > 2、pfcount: 获得基数的数量 > > 3、pfmerge : 合并两个key1,key2到destkey中去 ### （3）Geospatial > 地理信息 > > 1、geoadd:添加一个或多个地理位置（经度，纬度，名称）==经度范围-180~180，纬度-85.051~85.051超出范围会报错== > > 2、geopos: 获得坐标值 > > 3、geodist[m/km/ft/mi]:获取两个位置的直线距离，默认单位米 > > 4、georadius m/km/ft/mi：以给定的维度为中心，找出某一半径内的元素 ## 四、发布和订阅 > 1、打开一个客户端订阅通道：channe1 ```linux subscribe channe1 ``` > 2、打开另外一个客户端在通道channe1发送消息hello ```linux publish channe1 hello #返回订阅者数量 ``` > 3、第一个客户端可以看到消息 ## 五、Jedis操作 > 添加jar > > 如果是配置在服务器上的redis连接不上，可以修改配置文件 > > 1、注释掉 bind 127.0.0.1 ，因为默认是本机访问 > > 2、保护模式protected-mo yes改成no > > 3、重启redis > > 4、关闭防火墙 systemctl stop(state) firewalld ```maven redis.clients jedis 2.9.0 ``` ### (1)测试连接 ```java public static void main(String[] args) { //1.创建Jedis对象 Jedis jedis = new Jedis("127.0.0.1", 6379); //2.测试是否连接成功 String ping = jedis.ping(); System.out.println(ping); //输出pong } ``` ### (2)key操作 ```java public static void main(String[] args) { //1.创建Jedis对象 Jedis jedis = new Jedis("127.0.0.1", 6379); //2.创建一个key-value String set = jedis.set("name", "suyuan");//返回ok //3.获取value String name = jedis.get("name");//suyuan //4.设置多个key-value String mset = jedis.mset("k1", "v1", "k2", "v2");//ok //5.输出所有key Set keys = jedis.keys("*"); System.out.println(keys); } ``` ### (3)数据类型操作 ```java public static void main(String[] args) { //1.创建Jedis对象 Jedis jedis = new Jedis("127.0.0.1", 6379); //2.左边添加 Long key1 = jedis.lpush("key1", "1", "11", "111"); //3 //3.左边获取 List key11 = jedis.lrange("key1", 0, -1); System.out.println(key11);//111,11,1 //a.添加set Long sadd = jedis.sadd("set1", "a", "b", "c","a");//3 Set set1 = jedis.smembers("set1"); System.out.println(set1);//[a, b, c] //b.哈希操作 Long hset = jedis.hset("users", "age", "20");//1 String hget = jedis.hget("users", "age"); System.out.println(hget);//20 //c.zset操作 jedis.zadd("china",100,"shanghai"); Set china = jedis.zrange("china", 0, -1); System.out.println(china); } ``` ### (4)模拟验证码发生 > 案例 > > 1.输入手机号，生成6为验证码，2分钟有效 > > 2.每个手机号一天只能获取3次验证码 ``` import redis.clients.jedis.Jedis; import java.util.Random; public class JedisDemo1 { public static void main(String[] args) { //1.获取验证码 VerifyPhoneGetCode("139789"); //245892 //2.判断验证码 // verifyCode("139789","245892"); } //3.验证验证码 public static void verifyCode(String phone,String code){ //1.建立jedis连接 Jedis jedis = new Jedis("", 6379); //2.获取redis的验证码 String codekey = "verify:"+phone+":code"; final String rediscode = jedis.get(codekey); if (code.equals(rediscode)){ System.out.println("验证成功"); }else { System.out.println("验证失败"); } } //2.通过手机号获取验证码 public static String VerifyPhoneGetCode(String phone){ //1.建立jedis连接 Jedis jedis = new Jedis("", 6379); //2.创建两个key,1个存放手机号当前获取几次验证码，1个存放当前手机号的验证码 String countkey = "verify:"+phone+":count"; String codekey = "verify:"+phone+":code"; //3.判断当前手机获取验证码次数 String count = jedis.get(countkey); if (count==null){//第一次 jedis.setex(countkey,60*60*24,"1");//设置第一次存放过期时间为一天 }else if (Long.parseLong(count)<3){ jedis.incr(countkey);//加1 }else { //超过三次 System.out.println(phone+"：今日获取验证码次数已经超过3次"); jedis.close(); return "";//或者抛出异常 } //4.存放code,注意如果超过三次就不用存放code的，上面return或者抛出异常了 final String code = getCode(); System.out.println(phone+"存放redis的code:"+code); jedis.setex(codekey,60*2,code);//设置过期时间两分钟 return ""; } //1.生成6位验证码 public static String getCode(){ Random random = new Random(); String code=""; for (int i = 0; i < 6; i++) { int ran = random.nextInt(10); code +=ran; } return code; } } ``` ## 六、springboot整合redis ### (1)引入依赖 ```maven org.springframework.boot spring-boot-starter-data-redis org.apache.commons commons-pool2 ``` ### (2)添加配置文件 ```properties #Redis服务器地址 spring.redis.host=127.0.0.1 #Redis服务器连接端口 spring.redis.port=6379 #Redis数据库索引（默认位0） spring.redis.database=0 #连接超时时间（毫秒） spring.redis.timeout=1800000 #连接池最大连接数（使用负值表示没有限制） spring.redis.lettuce.pool.max-active=20 #最大阻塞等待时间（复数表示没有限制） spring.redis.lettuce.pool.max-wait=-1 #连接池中的最大空闲连接 spring.redis.lettuce.pool.max-idle=5 #连接池中的最小空闲连接 spring.redis.lettuce.pool.min-idle=0 ``` ### (3)添加配置类 ```java @EnableCaching @Configuration public class RedisConfig extends CachingConfigurerSupport { @Bean public RedisTemplate redisTemplate(RedisConnectionFactory factory) { RedisTemplate template = new RedisTemplate<>(); RedisSerializer redisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); template.setConnectionFactory(factory); //key序列化方式 template.setKeySerializer(redisSerializer); //value序列化 template.setValueSerializer(jackson2JsonRedisSerializer); //value hashmap序列化 template.setHashValueSerializer(jackson2JsonRedisSerializer); return template; } @Bean public CacheManager cacheManager(RedisConnectionFactory factory) { RedisSerializer redisSerializer = new StringRedisSerializer(); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); //解决查询缓存转换异常的问题 ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); // 配置序列化（解决乱码的问题）,过期时间600秒 RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofSeconds(600)) .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer)) .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) .disableCachingNullValues(); RedisCacheManager cacheManager = RedisCacheManager.builder(factory) .cacheDefaults(config) .build(); return cacheManager; } } ``` ### (4)测试 ```java //我写在了AdminsController //http://localhost:8080/ayuancity/admins/redis @Autowired private RedisTemplate redisTemplate; //测试redis @GetMapping("/redis") public String testRedis(){ //1.设置值到redis redisTemplate.opsForValue().set("name","suyuanyuan"); //2.获得redis值 String name=(String) redisTemplate.opsForValue().get("name"); return name; } ``` ## 七、事务操作 ### （1）基本操作 > ·Redis事务是一个单独的隔离操作∶事务中的所有命令都会序列化、按顺序地执行。事务在执行的过程中，不会被其他客户端发送来的命令请求所打断 > > ·Redis事务的主要作用就是串联多个命令防止别的命令插队 > > ·multi:组队阶段；exec：执行阶段；discard:放弃组队 ![在这里插入图片描述](./redis%E5%AD%A6%E4%B9%A0.assets/20210705212449445.png) ``` 组队发生失败，则执行失败组队成功，但个别命令失败，则只会发生个别命令失败 ``` ### （2）事物冲突 ``` 只有一万块钱，三个请求同时过来，最终造成金额为-4千 ``` ![1718331690968](redis%E5%AD%A6%E4%B9%A0.assets/1718331690968.png) > 解决办法 > > a.悲观锁：每次操作前先加锁，别人不能进行操作 > > b.乐观锁：添加一个版本号，每个操作都会修改版本号，别人操作时候查看版本号是否一致才能操作 ![1718331940784](redis%E5%AD%A6%E4%B9%A0.assets/1718331940784.png) ### （3）乐观锁的使用 > 使用场景：抢票等多读的场景 > > 语法： > > 1.在执行multi之前先执行watch key1[key2],监视一个或者多个key > > 2.unwath取消监视 ![1718332677665](redis%E5%AD%A6%E4%B9%A0.assets/1718332677665.png) ### （4）事务三特性 > 1.单独隔离操作 > > 所有事物都会序列化，按顺序执行。事务在执行过程中不会被其他客户端发送来的命令打断 > > 2、没有隔离级别的概念 > > 队列命令没有提交之前都不会被执行 > > 3.不保证原子性 > > 事务中如果有一条命令执行失败，其他的命令仍然会执行，没有回滚 ### （5）事务和锁的秒杀案例 ![在这里插入图片描述](redis%E5%AD%A6%E4%B9%A0.assets/169c92b8f8ab4320999af26ea3f79891.png) #### a.前端页面 ```html <%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> Insert title here

iPhone 13 Pro !!! 1元秒杀！！！

``` #### b.后端代码 ```java /** * 秒杀案例 */ public class SecKillServlet extends HttpServlet { private static final long serialVersionUID = 1L; public SecKillServlet() { super(); } protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String userid = new Random().nextInt(50000) +"" ; String prodid =request.getParameter("prodid"); //boolean isSuccess=SecKill_redis.doSecKill(userid,prodid); boolean isSuccess= SecKill_redisByScript.doSecKill(userid,prodid); response.getWriter().print(isSuccess); } } ``` ```java public class SecKill_redis { public static void main(String[] args) { Jedis jedis =new Jedis("",6379); System.out.println(jedis.ping()); jedis.close(); } //秒杀过程 public static boolean doSecKill(String uid,String prodid) throws IOException { //1 uid和prodid非空判断 if(uid == null || prodid == null) { return false; } //2 连接redis Jedis jedis = new Jedis("",6379); //3 拼接key // 3.1 库存key String kcKey = "sk:"+prodid+":qt"; // 3.2 秒杀成功用户key String userKey = "sk:"+prodid+":user"; //4 获取库存，如果库存null，秒杀还没有开始 String kc = jedis.get(kcKey); if(kc == null) { System.out.println("秒杀还没有开始，请等待"); jedis.close(); return false; } // 5 判断用户是否重复秒杀操作 if(jedis.sismember(userKey, uid)) { System.out.println("已经秒杀成功了，不能重复秒杀"); jedis.close(); return false; } //因为kc为字符串，所以先转换城integer类型的 //6 判断如果商品数量，库存数量小于1，秒杀结束 if(Integer.parseInt(kc)<=0) { System.out.println("秒杀已经结束了"); jedis.close(); return false; } //7.1 库存-1 jedis.decr(kcKey); //7.2 把秒杀成功用户添加清单里面 jedis.sadd(userKey,uid); System.out.println("秒杀成功了.."); jedis.close(); return true; } } ``` > ==因为用户id是随机生成模拟的一次一次点击，如果同时点击可能会遇到bug== #### c.利用工具ab实现并发工具 > centos6:默认已经安装 > > centos7：yum install httpd-tools > > ab --help测试是否安装 > ab -n 请求数量 -c 并发数量 -p 提交参数(文件名，文件中写参数=值) -T 类型请求路径 > > ab -n 2000 -c 200 -k -p ~/postfile -T application/x-www-form-urlencoded http://172.22.109.30:8081/Seckill/doseckill ==出现超卖和连接超时问题== ##### ①连接超时问题解决：使用连接池 ```java public class JedisPoolUtil { private static volatile JedisPool jedisPool = null; private JedisPoolUtil() { } public static JedisPool getJedisPoolInstance() { if (null == jedisPool) { synchronized (JedisPoolUtil.class) { if (null == jedisPool) { JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxTotal(200); poolConfig.setMaxIdle(32); poolConfig.setMaxWaitMillis(100*1000); poolConfig.setBlockWhenExhausted(true); poolConfig.setTestOnBorrow(true); // ping PONG，判断是否还存在 jedisPool = new JedisPool(poolConfig, "172.22.109.205", 6379, 60000 ); } } } return jedisPool; } public static void release(JedisPool jedisPool, Jedis jedis) { if (null != jedis) { jedisPool.returnResource(jedis); } } } ``` ```java //2 连接redis //Jedis jedis = new Jedis("192.168.44.168",6379); //通过连接池得到jedis对象 JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance(); Jedis jedis = jedisPoolInstance.getResource(); ``` ##### ②超卖问题：利用乐观锁 ```java //加入一个监视的watch jedis.watch(kcKey); //4 获取库存，如果库存null，秒杀还没有开始 ......... //7 秒杀过程 //使用事务 Transaction multi = jedis.multi(); //组队操作 multi.decr(kcKey);//库存-1 multi.sadd(userKey,uid);//把秒杀成功用户添加清单里面 //执行 List