Redis6--Jedis篇

大忽悠爱学习

发布于 2021-11-15 15:14:04

4860

发布于 2021-11-15 15:14:04

文章被收录于专栏：c++与qt学习c++与qt学习

Redis6

Redis_Jedis_测试

Jedis所需要的依赖

<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.2.0</version>
</dependency>

连接Redis注意事项

systemctl status firewalld ：查看防火墙的状态，开启还是关闭

禁用Linux的防火墙：Linux(CentOS7)里执行命令

systemctl stop/disable firewalld.service

redis.conf中注释掉bind 127.0.0.1 ,然后 protected-mode no，记得重启Redis服务器

注意就不止本机可以访问redis了，别的ip地址也可以访问

Jedis常用操作

测试连接

创建测试程序

public class jedis
{
    public static void main(String[] args) {
        //创建jedis的对象---连接的主机的ip地址和Redis的端口号
        Jedis jedis=new Jedis("192.168.112.128",6379);
        String ping = jedis.ping();
        System.out.println(ping);
        jedis.close();
    }
}

错误提示:

检查配置文件是否修改，防火墙是否关闭

测试相关数据类型

Key数据类型

   Jedis jedis=new Jedis("192.168.112.128",6379);
        //获得已经有的所有key
        Set<String> keys = jedis.keys("*");
        keys.forEach(System.out::println);
        //向其中加入key
        System.out.println("===========================");
        jedis.set("k3","大忽悠和小朋友");
        keys.forEach(System.out::println);
        System.out.println(jedis.exists("k1"));
        System.out.println(jedis.ttl("k1"));
        System.out.println(jedis.get("k1"));

String数据类型

        Jedis jedis=new Jedis("192.168.112.128",6379);
        jedis.mset("str1","v1","str2","v2","str3","v3");
        System.out.println(jedis.mget("str1","str2","str3"));

List数据类型

        Jedis jedis=new Jedis("192.168.112.128",6379);
        jedis.lpush("dhy","大忽悠","小朋友");
        List<String> list = jedis.lrange("dhy",0,-1);
       list.forEach(System.out::println);

注意:不停的执行lpush命令，就会不断的往当前List集合中追加值

set数据类型

        Jedis jedis=new Jedis("192.168.112.128",6379);
        jedis.sadd("orders", "order01","order02","order03");
    Set<String> smembers = jedis.smembers("orders");
            smembers.forEach(System.out::println);
      System.out.println("=============================]");
        jedis.srem("orders", "order02");
        Set<String> smembers1 = jedis.smembers("orders");
        smembers1.forEach(System.out::println);

hash数据类型

        //设置单个属性
        Jedis jedis=new Jedis("192.168.112.128",6379);
        jedis.hset("hash1","userName","lisi");
        System.out.println(jedis.hget("hash1","userName"));

       Map<String,String> map = new HashMap<String,String>();
        map.put("telphone","13810169999");
        map.put("address","atguigu");
        map.put("email","abc@163.com");
        //批量设置多个属性
        jedis.hmset("hash2",map);
        //批量得到多个属性
        List<String> result = jedis.hmget("hash2", "telphone","email");
        for (String element : result) {
            System.out.println(element);
        }

zset数据类型

        Jedis jedis=new Jedis("192.168.112.128",6379);
        //d表示double类型
        jedis.zadd("zset01", 100d, "z3");
        Map<String,Double> map=new HashMap<>();
        map.put("l4",90d);
        map.put("w5",80d);
        map.put("z6",70d);
    jedis.zadd("zset01", map);
    //默认顺序按照score从小到大
        Set<String> zrange = jedis.zrange("zset01", 0, -1);
        for (String e : zrange) {
            System.out.println(e);
        }

模拟完成一个手机验证码功能

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

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

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

//模拟发送验证码
public class MyCode
{
    //测试
    public static void main(String[] args) {
        //模拟发送验证码
        String code=getCode();
        System.out.println("模拟发送的验证码是: "+code);
        InfoCode("13688716354",code);
        //模拟用户输入验证码
        verifyCode("13688716354",code);
    }
    //验证码的校验
    public static  void verifyCode(String phoneNum,String code)
    {
        //连接redis
        Jedis jedis=new Jedis("192.168.112.128",6379);
        //从redis中取出发送的验证码
        String codeInfo = jedis.get("Verify" + phoneNum + ":code");
        //判断用户输入的验证码和发送的验证码是否一致
        if(codeInfo.equals(code))
            System.out.println("验证成功");
        else
            System.out.println("验证失败");
        //关闭连接
        jedis.close();
    }

    //将验证码放入到redis中进行存储，并设置每个手机每天最多发送3条消息的限制
 public static  void InfoCode(String phoneNum,String code)
 {
     //连接redis
  Jedis jedis=new Jedis("192.168.112.128",6379);
  //手机发送次数的key
     String countKey="Verify"+phoneNum+":count";
  //手机验证码的key
     String codeKey="Verify"+phoneNum+":code";

     //每个手机每天只能发送三次
     String count = jedis.get(codeKey);
      //首先判断当前手机是否发送过验证码
     if(count==null)
     {
         //当前手机在当日还未发送过验证码
         //是第一次发送
         /*
         setex < key ><过期时间>< value >
           设置键值的同时，设置过期时间，单位秒。
         */
         //过期时间是24小时，即一天
         jedis.setex(countKey,24*60*60, String.valueOf(1));
     }
     //说明当前手机发送过至少一次验证码，但没有超过最大的发送次数
     else if(Integer.parseInt(count)<=2)
     {
         //发送次数加一
         jedis.incr(countKey);
     }
     //发送次数超过了最大限制
     else
     {
         System.out.println("当前可发送次数已经超过了最大次数限制");
         //关闭当前连接
         jedis.close();
         return;
     }

     //将验证码存储到redis中，并设置失效时间为2分钟
      jedis.setex(codeKey,120,code);
      jedis.close();
 }

    //生成随机的6位验证码
    public static String getCode()
    {
        Random random=new Random();
        //存放验证码的字符串
        String code="";
        for(int i=0;i<6;i++)
        {
            //生成0-9的随机数字
            code+=random.nextInt(10);
        }
         return code;
    }
}