zoukankan      html  css  js  c++  java
  • redis入门及相关API

    redis入门及相关API

    redis入门

    1. 依赖

    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-redis</artifactId>
    </dependency>
    

    2. 编写测试类

    public class TestRedis {
    
        /**
         * 完成Redis入门案例测试
         * 报错说明:
         *      1.检查Linux防火墙
         *      2.检查Redis3项配置
         *      3.重启redis.
         */
        @Test
        public void test01(){
            // 参数为IP地址和端口
            Jedis jedis = new Jedis("192.168.126.130",6379);
            //1.向redis中保存数据
            jedis.set("msg", "哈哈哈 今天下雨了 不负众望");
            //2.从redis中获取数据
            String value = jedis.get("msg");
            System.out.println(value);
        }
    }
    

    redis_API

    api基本上和redis命令相似, 但也有一些特殊件API使用更方便, 其中1和2最常用

    1.对key操作的命令

    exists(key):确认一个key是否存在

    del(key):删除一个key

    type(key):返回值的类型

    keys(pattern):返回满足给定pattern的所有key

    randomkey:随机返回key空间的一个key

    rename(oldname, newname):将key由oldname重命名为newname,若newname存在则删除newname表示的key

    dbsize:返回当前数据库中key的数目

    expire:设定一个key的活动时间(s)

    ttl:获得一个key的活动时间

    select(index):按索引查询

    move(key, dbindex):将当前数据库中的key转移到有dbindex索引的数据库

    flushdb:删除当前选择数据库中的所有key

    flushall:删除所有数据库中的所有key

    2.对String操作的命令

    set(key, value):给数据库中名称为key的string赋予值value

    get(key):返回数据库中名称为key的string的value

    getset(key, value):给名称为key的string赋予上一次的value

    mget(key1, key2,…, key N):返回库中多个string(它们的名称为key1,key2…)的value

    setnx(key, value):如果不存在名称为key的string,则向库中添加string,名称为key,值为value

    setex(key, time, value):向库中添加string(名称为key,值为value)同时,设定过期时间time

    mset(key1, value1, key2, value2,…key N, value N):同时给多个string赋值,名称为key i的string赋值value i

    msetnx(key1, value1, key2, value2,…key N, value N):如果所有名称为key i的string都不存在,则向库中添加string,名称key i赋值为value i

    incr(key):名称为key的string增1操作

    incrby(key, integer):名称为key的string增加integer

    decr(key):名称为key的string减1操作

    decrby(key, integer):名称为key的string减少integer

    append(key, value):名称为key的string的值附加value

    substr(key, start, end):返回名称为key的string的value的子串

    3.对List操作的命令

    rpush(key, value):在名称为key的list尾添加一个值为value的元素

    lpush(key, value):在名称为key的list头添加一个值为value的 元素

    llen(key):返回名称为key的list的长度

    lrange(key, start, end):返回名称为key的list中start至end之间的元素(下标从0开始,下同)

    ltrim(key, start, end):截取名称为key的list,保留start至end之间的元素

    lindex(key, index):返回名称为key的list中index位置的元素

    lset(key, index, value):给名称为key的list中index位置的元素赋值为value

    lrem(key, count, value):删除count个名称为key的list中值为value的元素。count为0,删除所有值为value的元素,count>0 从头至尾删除count个值为value的元素,count<0从尾到头删除|count|个值为value的元素。

    lpop(key):返回并删除名称为key的list中的首元素

    rpop(key):返回并删除名称为key的list中的尾元素

    blpop(key1, key2,… key N, timeout):lpop 命令的block版本。即当timeout为0时,若遇到名称为key i的list不存在或该list为空,则命令结束。如果 timeout>0,则遇到上述情况时,等待timeout秒,如果问题没有解决,则对key i+1开始的list执行pop操作。

    brpop(key1, key2,… key N, timeout):rpop的block版本。参考上一命令。

    rpoplpush(srckey, dstkey):返回并删除名称为srckey的list的尾元素,并将该元素添加到名称为dstkey的list的头部

    4.对Set操作的命令

    sadd(key, member):向名称为key的set中添加元素member

    srem(key, member) :删除名称为key的set中的元素member

    spop(key):随机返回并删除名称为key的set中一个元素

    smove(srckey, dstkey, member):将member元素从名称为srckey的集合移到名称为dstkey的集合

    scard(key) :返回名称为key的set的基数

    sismember(key, member) :测试member是否是名称为key的set的元素

    sinter(key1, key2,…key N) :求交集

    sinterstore(dstkey, key1, key2,…key N) :求交集并将交集保存到dstkey的集合

    sunion(key1, key2,…key N) :求并集

    sunionstore(dstkey, key1, key2,…key N) :求并集并将并集保存到dstkey的集合

    sdiff(key1, key2,…key N) :求差集

    sdiffstore(dstkey, key1, key2,…key N) :求差集并将差集保存到dstkey的集合

    smembers(key) :返回名称为key的set的所有元素

    srandmember(key) :随机返回名称为key的set的一个元素

    5.对zset(sorted set)操作的命令

    zadd(key, score, member):向名称为key的zset中添加元素member,score用于排序。如果该元素已经存在,则根据score更新该元素的顺序。

    zrem(key, member) :删除名称为key的zset中的元素member

    zincrby(key, increment, member) :如果在名称为key的zset中已经存在元素member,则该元素的score增加increment;否则向集合中添加该元素,其score的值为increment

    zrank(key, member) :返回名称为key的zset(元素已按score从小到大排序)中member元素的rank(即index,从0开始),若没有member元素,返回“nil”

    zrevrank(key, member) :返回名称为key的zset(元素已按score从大到小排序)中member元素的rank(即index,从0开始),若没有member元素,返回“nil”

    zrange(key, start, end):返回名称为key的zset(元素已按score从小到大排序)中的index从start到end的所有元素

    zrevrange(key, start, end):返回名称为key的zset(元素已按score从大到小排序)中的index从start到end的所有元素

    zrangebyscore(key, min, max):返回名称为key的zset中score >= min且score <= max的所有元素

    zcard(key):返回名称为key的zset的基数(个数)

    zscore(key, element):返回名称为key的zset中元素element的score

    zremrangebyrank(key, min, max):删除名称为key的zset中rank >= min且rank <= max的所有元素

    zremrangebyscore(key, min, max) :删除名称为key的zset中score >= min且score <= max的所有元素

    zunionstore / zinterstore(dstkeyN, key1,…,keyN, WEIGHTS w1,…wN, AGGREGATE SUM|MIN|MAX):对N个zset求并集和交集,并将最后的集合保存在dstkeyN中。对于集合中每一个元素的score,在进行AGGREGATE运算前,都要乘以对于的WEIGHT参数。如果没有提供WEIGHT,默认为1。默认的AGGREGATE是SUM,即结果集合中元素的score是所有集合对应元素进行 SUM运算的值,而MIN和MAX是指,结果集合中元素的score是所有集合对应元素中最小值和最大值。

    zadd zset_01 0 java #添加

    zadd zset_01 1 php #添加

    zadd zset_01 2 python #添加

    zrem zset_01 python #删除

    zrank zset_01 python #获取score

    zrange zset_01 0 -1 #获取所有元素

    zcard zset_01 #获取元素个数

    6.对Hash(字典)操作的命令

    hset(key, field, value):向名称为key的hash中添加元素field<—>value

    hget(key, field):返回名称为key的hash中field对应的value

    hmget(key, field1, …,field N):返回名称为key的hash中field i对应的value

    hmset(key, field1, value1,…,field N, value N):向名称为key的hash中添加元素field i<—>value i

    hincrby(key, field, integer):将名称为key的hash中field的value增加integer

    hexists(key, field):名称为key的hash中是否存在键为field的域

    hdel(key, field):删除名称为key的hash中键为field的域

    hlen(key):返回名称为key的hash中元素个数

    hkeys(key):返回名称为key的hash中所有键

    hvals(key):返回名称为key的hash中所有键对应的value

    hgetall(key):返回名称为key的hash中所有的键(field)及其对应的value

    hset hash_01 age 22

    hset hash_01 age 22

    hmset hash_01 name robbie age 22

    hget hash_01 name

    hget hash_01 age

    hincrby hash_01 age 2

    hdel hash_01 age

    API测试案例

    package com.jt.test;
    
    import org.junit.jupiter.api.Test;
    import org.springframework.boot.test.context.SpringBootTest;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.params.SetParams;
    
    //@SpringBootTest //需要依赖spring容器,从容器中动态的获取对象
    public class TestRedis {
    
        /**
         * 完成Redis入门案例测试
         * 报错说明:
         *      1.检查Linux防火墙
         *      2.检查Redis3项配置
         *      3.重启redis.
         */
        @Test
        public void test01(){
            Jedis jedis = new Jedis("192.168.126.129",6379);
            //1.向redis中保存数据
            jedis.set("2004", "哈哈哈 今天下雨了 不负众望");
            //2.从redis中获取数据
            String value = jedis.get("2004");
            System.out.println(value);
        }
    
        @Test
        public void test02(){
            Jedis jedis = new Jedis("192.168.126.129",6379);
    
            //1.判断redis中是否存在key
            if(jedis.exists("2004")){
                //2.如果存在则设定超时时间
                jedis.expire("2004", 100);
                //3.线程暂停2秒
                try {
                    Thread.sleep(2000);
                    //4.获取剩余的存活时间
                    Long time = jedis.ttl("2004");
                    System.out.println("还能活:"+time);
                    //5.撤销删除操作
                    jedis.persist("2004");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    
        /**
         * 需求说明:
         *  1.redis.set操作,后面的操作会将之前的value覆盖
         *  要求:如果key已经存在,则不允许赋值.
         *  注意环境: 检查redis中是否有改数据.
         *  */
        @Test
        public void test03() {
            //A  潘石屹    B 马云
            Jedis jedis = new Jedis("192.168.126.129", 6379);
            jedis.flushAll();   //清空redis缓存
            //如果key存在则不执行赋值操作.
            jedis.setnx("boss", "潘石屹");
            jedis.setnx("boss", "马云");
            System.out.println(jedis.get("boss"));
        }
    
        /**
         * 为数据添加超时时间.保证原子性操作
         * 原子性: 一起完成一起回滚
         * 锁机制: 保证原子性   死锁!!!!
         * 小结: setnx 如果key存在则不赋值
         *       setex  保证原子性操作,并且添加超时时间.
         * * */
        @Test
        public void test04() {
            Jedis jedis = new Jedis("192.168.126.129", 6379);
            jedis.setex("aaa", 20, "xxxxx"); //满足原子性需求.
        }
    
        /**
         * 需求:
         *  1.要求赋值操作时,如果数据已经存在则不允许赋值.
         *  2.同时要求添加超时时间 并且满足原子性要求.
         *   private static final String XX = "xx";   只有key存在时,才能赋值
         *   private static final String NX = "nx";   只有key不存在时,赋值
         *   private static final String PX = "px";   毫秒
         *   private static final String EX = "ex";   秒
         */
        @Test
        public void test05() {
            Jedis jedis = new Jedis("192.168.126.129", 6379);
            SetParams setParams = new SetParams();
            setParams.nx().ex(20);
            jedis.set("AAA", "CCCCC", setParams); //原子性要求
            System.out.println(jedis.get("AAA"));
        }
    
    	 /*测试hash数据类型*/
        @Test
        public void testHash() {
            Jedis jedis = new Jedis("192.168.126.129", 6379);
            jedis.hset("person", "name", "tomcat");
            jedis.hset("person", "age", "100");
            Map<String,String> map = jedis.hgetAll("person");
            System.out.println(map);
        }
    	
    	@Test
        public void testList() {
            Jedis jedis = new Jedis("192.168.126.129", 6379);
            jedis.lpush("list", "1","2","3","4");
            String value = jedis.rpop("list");
            System.out.println(value);
        }
    
    	 /**
         * 实现Redis 事务控制
         */
        @Test
        public void testMulti() {
            Jedis jedis = new Jedis("192.168.126.129", 6379);
            Transaction transaction = jedis.multi();
            try {
                transaction.set("AAA", "XXX");
                transaction.set("BBB", "XXX");
                transaction.exec(); //提交事务
            }catch (Exception exception){
                exception.printStackTrace();
                transaction.discard();//回滚事务
            }
    
        }
    }
    
  • 相关阅读:
    JavaScript函数调用
    JS数据类型&&typeof&&其他
    JavaScript闭包底层解析
    test
    C# 网页自动填表自动登录 .
    C#中没有id 没有name C#怎么点击按钮
    网页中403错误的含义
    C# 按钮置顶和隐藏
    C# webBrowser 屏蔽网页JS脚本错误弹窗
    HTML5 canvas globalCompositeOperation 设置绘图的顺序
  • 原文地址:https://www.cnblogs.com/zpKang/p/13497493.html
Copyright © 2011-2022 走看看