Jedis操作

àì夳堔傛蜴生んèń 2023-01-16 11:10 120阅读 0赞

## 1、准备工作 ##

在IDEA中创建一个maven工程，加入需要的依赖

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

要操作Jedis首先得链接上Linux虚拟机上，查看Linux主机号host，以及redis的端口号port，如何查看Linux上的主机host呢？

ye@ubuntu:~/Desktop$ ifconfig
    ens33: flags=4163<UP,BROADCAST,RUNNING,MULTICAST>  mtu 1500
            inet 192.168.42.128  netmask 255.255.255.0  broadcast 192.168.42.255
            inet6 fe80::9632:f2af:11e8:fb30  prefixlen 64  scopeid 0x20<link>
            ether 00:0c:29:9c:73:2b  txqueuelen 1000  (Ethernet)
            RX packets 4401  bytes 5930620 (5.9 MB)
            RX errors 0  dropped 0  overruns 0  frame 0
            TX packets 2349  bytes 177744 (177.7 KB)
            TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    
    lo: flags=73<UP,LOOPBACK,RUNNING>  mtu 65536
            inet 127.0.0.1  netmask 255.0.0.0
            inet6 ::1  prefixlen 128  scopeid 0x10<host>
            loop  txqueuelen 1000  (Local Loopback)
            RX packets 436  bytes 50726 (50.7 KB)
            RX errors 0  dropped 0  overruns 0  frame 0
            TX packets 436  bytes 50726 (50.7 KB)
            TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    ye@ubuntu:~/Desktop$

其中inet 192.168.42.128就是host号，而redis的端口号默认是6379.

public class RedisTest {
        public static void main(String[] arge){
            Jedis jedis = new Jedis("192.168.42.128",6379);
            String ping = jedis.ping();
            System.out.println(ping);
        }
    }

如果出现burg，需要注意两点：（保证你在Linux上打开了redis-server /opt/redis.conf）

1、禁用Linux的防火墙 **systemctl stop/disable firewalld.service**

2、找到redis.conf文件，并在其中注**释掉bind 127.0.0.1** ,然后 **protected-mode no （之前是yes，修改成no）**

没出现错误：上面的测试就会输出：PONG，现在好了测试搞好可以开始对Jedis操作了。

## 2、相关数据类型测试 ##

###       1）Key ###

public class RedisTest {
        public static void main(String[] arge){
            Jedis jedis = new Jedis("192.168.42.128",6379);
            jedis.set("k1","value1");
            jedis.set("k2","value2");
            jedis.set("k3","value3");
            Set<String> keys = jedis.keys("*");
            for(String key:keys){
                System.out.println(key);
            }
            System.out.println(jedis.exists("k1"));
            System.out.println(jedis.ttl("k1"));//-1 永久
            System.out.println(jedis.get("k1"));
            jedis.close();
        }
    }

###       2）String ###

public class RedisTest {
        public static void main(String[] arge){
            Jedis jedis = new Jedis("192.168.42.128",6379);
            jedis.mset("k4","123","k5","456","k6","789");
            System.out.println(jedis.get("k5"));//456
            jedis.close();
        }
    }

###       3）List ###

public class RedisTest {
        public static void main(String[] arge){
            Jedis jedis = new Jedis("192.168.42.128",6379);
            //List可以元素重复
            jedis.lpush("key1","123");
            jedis.rpush("key1","123");
            jedis.rpush("key1","456");
            List<String> list = jedis.lrange("key1", 0, -1);
            for(String li:list){
                System.out.println(li);
            }
            jedis.lrem("key1",2,"123");
            System.out.println("===");
            for(String li:list){
                System.out.println(li);
            }
            jedis.close();
        }
    }

###       4）set ###

@Test
    public void test04(){
        //set集合
        Jedis jedis = new Jedis("192.168.42.128",6379);
        jedis.sadd("Myset","C++","java","python");
        //获取所有
        Set<String> myset = jedis.smembers("Myset");
        for (String s : myset) {
            System.out.println(s);
        }
        jedis.close();
    }

###       5）hash ###

@Test
    public void test02(){
        //hash类型的操作
        Jedis jedis = new Jedis("192.168.42.128",6379);
        jedis.hset("myhash","name","wangwu");
        jedis.hset("myhash","age","21");
        jedis.hset("myhash","sex","男");
        System.out.println(jedis.hget("myhash", "age"));
        System.out.println(jedis.hget("myhash", "sex"));
        //获取hash的所有的map中的数据
        Map<String, String> myhash = jedis.hgetAll("myhash");
        Set<String> filed = myhash.keySet();
        for (String string : filed) {
            System.out.println(string+":"+myhash.get(string));
        }
        jedis.close();
    }

###       6）zset ###

@Test
    public void test05(){
        //setsorted集合
        Jedis jedis = new Jedis("192.168.42.128",6379);
        jedis.zadd("Mysorted",1,"项羽");
        jedis.zadd("Mysorted",21,"亚瑟");
        jedis.zadd("Mysorted",122,"孙悟空");
        //获取
        Set<String> mysort = jedis.zrange("Mysorted", 0, -1);
        for (String s : mysort) {
            System.out.println(s);
        }
        jedis.close();
    }

## 3、手机验证码功能案例 ##

要求：

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

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

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

public class RedisTest {
        public static void main(String[] arge){
            Jedis jedis = new Jedis("192.168.42.128",6379);
            Scanner in = new Scanner(System.in);
            while (true){
                System.out.println("输入手机号：");
                String phone = in.next();
                String rNum = RedisTest.getRandNumber();
                String countKey ="count"+phone;//保存次数一天三次
                String codeKey ="code"+phone;//保存验证码 60秒有效
                jedis.setex(codeKey, 60, rNum);
                System.out.println("验证码："+rNum);
                System.out.println("输入验证码：");
                String set1 = in.next();
                if(set1.equals(jedis.get(codeKey))){
                    System.out.println("输入验证码正确");
                    break;
                }else {
                    System.out.println("输入验证码错误");
                }
                String s = jedis.get(countKey);
                if(s==null){
                    jedis.setex(countKey,24*60*60,"1");
                }
                if(Integer.parseInt(jedis.get(countKey))<=2){
                    jedis.incr(countKey);
                }else {
                    System.out.println("超过一天发送验证码的次数");
                    break;
                }
            }
    
            jedis.close();
        }
        //随机生成6位数字
        public static String getRandNumber(){
            String temp ="";
            Random random = new Random();
            for(int i=0;i<6;i++){
                int randNum = random.nextInt(10);
                temp+=randNum;
            }
            return temp;
        }
    }