• Redis（四）——Jedis操作Redis6、Redis6与SpringBoot整合

    目录

    Jedis常用操作

    创建测试程序​编辑

    测试相关数据类型

    Jedis-API:    Key

    Jedis-API:    String

    Jedis-API:    List

    Jedis-API:    set

    ​​​​​​​Jedis-API:    hash

    Jedis-API:    zset

    Jedis案例——模拟验证码发送

    SpringBoot整合Redis

    Jedis常用操作

    引入依赖：

    1. <dependency>
    2.     <groupId>redis.clientsgroupId>
    3.     <artifactId>jedisartifactId>
    4.     <version>3.2.0version>
    5. dependency>

    创建测试程序

    1. import redis.clients.jedis.Jedis;
    2. public class Demo01 {
    3.     public static void main(String[] args) {
    4.         //创建redis对象
    5.         Jedis jedis = new Jedis("192.168.137.3",6379);
    6.         //ping()方法，如果连接成功则会返回一个值，否则报错
    7.         String pong = jedis.ping();
    8.         System.out.println("连接成功："+pong);
    9.         jedis.close();
    10.     }
    11. }

    禁用Linux的防火墙：Linux(CentOS7)里执行命令（关闭防火墙之后，一定要重启）

    systemctl stop/disable firewalld.service  

    redis.conf中注释掉bind 127.0.0.1 ,然后 protected-mode no

    如果之前设置过密码的话，要在创建对象后设置auth

    jedis.auth("你的密码");一定要放在，Jedis jedis = new Jedis("");下面

    测试相关数据类型

    ​​​​​​​Jedis-API:    Key

    1. @Test
    2. public void demo1(){
    3.     //创建redis对象
    4.     Jedis jedis = new Jedis("192.168.137.3",6379);
    5.     //添加key
    6.     jedis.set("k1", "v1");
    7.     jedis.set("k2", "v2");
    8.     jedis.set("k3", "v3");
    9.     //参数为“*”表示得到所有的key，返回一个Set集合
    10.     Set keys = jedis.keys("*");
    11.     System.out.println(keys.size());
    12.     for (String key : keys) {
    13.         System.out.println(key);
    14.     }
    15.     System.out.println(jedis.exists("k1"));
    16.     System.out.println(jedis.ttl("k1"));                
    17.     System.out.println(jedis.get("k1"));  
    18. }

    ​​​​​​​Jedis-API:    String

    1. //设置多个key-value
    2. jedis.mset("str1","v1","str2","v2","str3","v3");
    3. List mget = jedis.mget("str1","str2","str3");
    4. System.out.println(mget);//输出相应的value

    Jedis-API:    List

    1. jedis.lpush("mylist","lucy","mary","jack");
    2. List list = jedis.lrange("mylist",0,-1);//把所有值都取出来
    3. for (String element : list) {
    4.     System.out.println(element);
    5. }

    Jedis-API:    set

    1. //注意key的名字不要和之前冲突
    2. jedis.sadd("orders", "order01");
    3. jedis.sadd("orders", "order02");
    4. jedis.sadd("orders", "order03");
    5. jedis.sadd("orders", "order04");
    6. Set smembers = jedis.smembers("orders");
    7. for (String order : smembers) {
    8.     System.out.println(order);
    9. }
    10. jedis.srem("orders", "order02");

    ​​​​​​​Jedis-API:    hash

    1. jedis.hset("hash1","userName","lisi");
    2. System.out.println(jedis.hget("hash1","userName"));
    3.  
    4. Map map = new HashMap();
    5. map.put("telphone","13810169999");
    6. map.put("address","atguigu");
    7. map.put("email","abc@163.com");
    8.  
    9. jedis.hmset("hash2",map);
    10. List result = jedis.hmget("hash2", "telphone","email");
    11. for (String element : result) {
    12.     System.out.println(element);
    13. }

    Jedis-API:    zset

    1. jedis.zadd("zset01", 100d, "z3");
    2. jedis.zadd("zset01", 90d, "l4");
    3. jedis.zadd("zset01", 80d, "w5");
    4. jedis.zadd("zset01", 70d, "z6");
    5.  
    6. Set zrange = jedis.zrange("zset01", 0, -1);
    7. for (String e : zrange) {
    8.     System.out.println(e);
    9. }

    Jedis案例——模拟验证码发送

    要求：

    1、输入手机号，点击发送后随机生成6位数字码，2分钟有效

    随机生成6位数字码：Random

    2分钟有效：把验证码放到redis里面,设置过期时间120秒

    2、输入验证码，点击验证，返回成功或失败

    验证：从redis获取验证码和输入的验证码进行比较

    3、每个手机号每天只能输入3次

    incr（每次发送之后+1）大于2时候，提交不能发送

    1. package com.zqf.jedis_redsidemo;
    2.  
    3. import redis.clients.jedis.Jedis;
    4.  
    5. import java.util.Random;
    6.  
    7. public class PhoneCode {
    8.     public static void main(String[] args) {
    9.         //模拟验证码
    10.         verifyCode("12345678974");
    11.  
    12. //        getRedisCode("12345678974","983534");
    13.     }
    14.  
    15.     //1.生成6位数验证码
    16.     public static String getCode(){
    17.         Random random = new Random();
    18.         String code = "";
    19.         for (int i=0;i<6;i++){
    20.             int i1 = random.nextInt(10);
    21.             code += i1;
    22.         }
    23.         return code;
    24.     }
    25.  
    26.  
    27.     //2.每个手机每天只能发送三次，验证码放到redis中，设置过期时间
    28.     public static void verifyCode(String phone){
    29.         //连接redis
    30.         Jedis jedis = new Jedis("192.168.2.129",6379);
    31.         //拼接key
    32.         //手机发送次数key
    33.         String countKey = "VerifyCode"+phone+":count";
    34.         //验证码key
    35.         String codeKey = "VerifyCode"+phone+":code" ;
    36.  
    37.         //每个手机每天只能发送三次
    38.         String count = jedis.get(countKey);   //从redis中取出发送次数
    39.         if (count == null){
    40.             //没有发送次数  第一次发送
    41.             //设置发送次数是1
    42.             jedis.setex(countKey,24*60*60,"1");     //key,过期时间,value
    43.         }else if (Integer.parseInt(count)<=2){
    44.             //发送次数+1
    45.             jedis.incr(countKey);
    46.         }else if(Integer.parseInt(count)>2){
    47.             System.out.println("24h内发送次数已经超过三次");
    48.             jedis.close();
    49.             return;   //三次之后return   以下代码将不执行
    50.         }
    51.  
    52.         //发送验证码到redis
    53.         String vcode = getCode();
    54.         jedis.setex(codeKey,120,vcode);
    55.         jedis.close();
    56.         
    57.     }
    58.  
    59.  
    60.     //3.验证码校验
    61.     public static void getRedisCode(String phone,String code){
    62.         //从redis里获取验证码
    63.         Jedis jedis = new Jedis("192.168.2.129",6379);
    64.         //验证码key
    65.         String codeKey = "VerifyCode"+phone+":code" ;
    66.         String redisCode = jedis.get(codeKey);
    67.         //判断
    68.         if (code.equals(redisCode)){
    69.             System.out.println("成功");
    70.         }else {
    71.             System.out.println("失败");
    72.         }
    73.  
    74.     }
    75.  
    76.  
    77. }

    SpringBoot整合Redis

    • 1.引入redis相关依赖
    2. <dependency>
    3.     <groupId>org.springframework.bootgroupId>
    4.     <artifactId>spring-boot-starter-data-redisartifactId>
    5. dependency>
    6.  
    8. <dependency>
    9.     <groupId>org.apache.commonsgroupId>
    10.     <artifactId>commons-pool2artifactId>
    11.     <version>2.6.0version>
    12. dependency>
    • 2.application.properties配置redis配置 
    1. #Redis服务器地址
    2. spring.redis.host=192.168.xxx.xxx
    3. #Redis服务器连接端口
    4. spring.redis.port=6379
    5. #Redis数据库索引（默认为0）
    6. spring.redis.database= 0
    7. #连接超时时间（毫秒）
    8. spring.redis.timeout=1800000
    9. #连接池最大连接数（使用负值表示没有限制）
    10. spring.redis.lettuce.pool.max-active=20
    11. #最大阻塞等待时间(负数表示没限制)
    12. spring.redis.lettuce.pool.max-wait=-1
    13. #连接池中的最大空闲连接
    14. spring.redis.lettuce.pool.max-idle=5
    15. #连接池中的最小空闲连接
    16. spring.redis.lettuce.pool.min-idle=0
    • 3.创建配置类，配置Redis里的相关内容
    1. package com.zqf.jedis_redsidemo.config;
    2.  
    3. import com.fasterxml.jackson.annotation.JsonAutoDetect;
    4. import com.fasterxml.jackson.annotation.PropertyAccessor;
    5. import com.fasterxml.jackson.databind.ObjectMapper;
    6. import org.springframework.cache.CacheManager;
    7. import org.springframework.cache.annotation.CachingConfigurerSupport;
    8. import org.springframework.cache.annotation.EnableCaching;
    9. import org.springframework.context.annotation.Bean;
    10. import org.springframework.context.annotation.Configuration;
    11. import org.springframework.data.redis.cache.RedisCacheConfiguration;
    12. import org.springframework.data.redis.cache.RedisCacheManager;
    13. import org.springframework.data.redis.connection.RedisConnectionFactory;
    14. import org.springframework.data.redis.core.RedisTemplate;
    15. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
    16. import org.springframework.data.redis.serializer.RedisSerializationContext;
    17. import org.springframework.data.redis.serializer.RedisSerializer;
    18. import org.springframework.data.redis.serializer.StringRedisSerializer;
    19.  
    20. import java.time.Duration;
    21.  
    22. @EnableCaching
    23. @Configuration
    24. public class RedisConfig extends CachingConfigurerSupport {
    25.  
    26.     @Bean
    27.     public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
    28.         RedisTemplate template = new RedisTemplate<>();
    29.         RedisSerializer redisSerializer = new StringRedisSerializer();
    30.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    31.         ObjectMapper om = new ObjectMapper();//Objectmapper是jackson的依赖，目的把对象写成json格式
    32.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    33.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    34.         jackson2JsonRedisSerializer.setObjectMapper(om);
    35.         template.setConnectionFactory(factory);
    36.         //key序列化方式
    37.         template.setKeySerializer(redisSerializer);
    38.         //value序列化
    39.         template.setValueSerializer(jackson2JsonRedisSerializer);
    40.         //value hashmap序列化
    41.         template.setHashValueSerializer(jackson2JsonRedisSerializer);
    42.         return template;
    43.     }
    44.  
    45.     @Bean
    46.     public CacheManager cacheManager(RedisConnectionFactory factory) {
    47.         RedisSerializer redisSerializer = new StringRedisSerializer();
    48.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    49.         //解决查询缓存转换异常的问题
    50.         ObjectMapper om = new ObjectMapper();
    51.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    52.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    53.         jackson2JsonRedisSerializer.setObjectMapper(om);
    54.         // 配置序列化（解决乱码的问题）,过期时间600秒
    55.         RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
    56.                 .entryTtl(Duration.ofSeconds(600))
    57.                 .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
    58.                 .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
    59.                 .disableCachingNullValues();
    60.         RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
    61.                 .cacheDefaults(config)
    62.                 .build();
    63.         return cacheManager;
    64.     }
    65. }
    • 4.RedisTestController中添加测试方法
    1. package com.zqf.jedis_redsidemo.controller;
    2.  
    3. import org.springframework.beans.factory.annotation.Autowired;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5. import org.springframework.web.bind.annotation.GetMapping;
    6. import org.springframework.web.bind.annotation.RequestMapping;
    7. import org.springframework.web.bind.annotation.RestController;
    8.  
    9. @RestController
    10. @RequestMapping("/redisTest")
    11. public class RedisTestController {
    12.     @Autowired
    13.     private RedisTemplate redisTemplate;
    14.  
    15.     @GetMapping
    16.     public String testRedis() {
    17.         //设置值到redis
    18.         redisTemplate.opsForValue().set("name","lucy");
    19.         //从redis获取值
    20.         String name = (String)redisTemplate.opsForValue().get("name");
    21.         return name;
    22.     }
    23. }

  • 相关阅读:
    ThinkPHP框架使用工厂模式对接多个物流公司下单接口架构示例（php7.0及以上）
    如何训练聊天机器人面对复杂的语言环境和需求？
    赚麻了！！！
    Perl中的文件系统守卫：实现自定义访问控制
    贪心算法（算法竞赛、蓝桥杯）--均分纸牌
    python中的变量的定义和使用
    玩转ChatGPT：快速制作PPT
    day07-缓存套餐
    jsp+sql毕业生招聘系统免费系统+论文
    专精特新企业认定条件
  • 原文地址：https://blog.csdn.net/m0_52601969/article/details/126249767