Redis通用指令和第一个Jedis程序的实现

Redis学习3

sorted_set

用于为资源排序

---

获取数据对应得索引

zrank key member(正序)

zrevrank key member(逆序)

score值获取与修改

zscore key member

zincrby key increment member

1.score 储存空间是64位，在-9007199254740992~9007199254740992

2.score保存double类型的数据时可能会丢失精度

3.如果重复添加相同的数据，score的会一直覆盖，只会保留最后一次修改的值。

应用场景：主要用于处理时间限定的任务执行顺序管理，或任务过期管理。

获取当前系统时间

time

应用场景：Redis应用于即使任务/消息队列执行管理

2.也可应用于按次结算的服务控制 例如：不用最大值的判定，利用超过最大值抛出异常的形式代替判断是否大于最大值。

3.应用于时间顺序的数据操作。

返回值是0不带表添加失败，值已经发生了变化

Redis 通用指令

---

key通用操作

删除指定key

delkey

获取key是否存在

exists key

获取key的类型

type key

key 扩展操作（时效性控制,查询模式,其他操作）

为指定key设置有效期

expire key seconds

pexpire key milliseconds

expireat key timestamp

pexpireat key milliseconds-timestamp

获取key的有效时间

ttl key

pttl key

把key的时效性更改为永久性

persist key

注意：key关于时间的，如果一个key返回值不存在，那么他就返回一个-2，如果存在就返回-1，设置了有效期，就返回现在有效的时长

查询key

keys pattern

规则

• *匹配任意数量的任意符号 ？配合任意一个符号 []匹配一个指定符号

keys * 查询所有

keys xx* 查询所有以xx开头

keys *xx查询所有以xx结尾

keys ??xx查询所有前面两个字符任意，后面以xx结尾

keys xx:? 查询所有以xx:开头，最后一个字符任意

keys x[st]y:1 查询所有以x开头，以y:1结尾，中间包含一个字母，s或t

为key改名

rename key newkey

renamenx key newkey

对所有key排序

sort

其他key通用操作

help @generic

数据库通用指令

---

redis的服务提供有16个数据库，编号是索引0-15，每个数据库是独立的

db 基本操作， 相关操作

切换数据库 select index

其他操作 quit 退出

ping 检测服务是否连接成功

echo message 打印信息

数据移动

move key db

数据清除

dbsize 查看key个数

flushdb 删除当前数据库

flushall 删除所有数据库 (谨慎操作，基本用不到)

Jedis

简介：java连接Redis简称Jedis

第一个Jedis程序

环境搭建

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

编写代码

public void testJedis(){
        //连接
        Jedis jedis = new Jedis("localhost", 6379);
        //操作
//        jedis.set("name","java");
        String name = jedis.get("name");
        System.out.println(name);
        //关闭
        jedis.close();
    }

public void testList(){
    //连接
    Jedis jedis = new Jedis("localhost", 6379);
    //操作
    jedis.lpush("list1","a","b","c");
    jedis.rpush("list1","x");

    List<String> list1 = jedis.lrange("list1", 0, -1);
    for (String s : list1) {
        System.out.println(s);
    }
    System.out.println(jedis.llen("list1"));
    System.out.println();
    //关闭
    jedis.close();
}

public void testHash(){
    //连接
    Jedis jedis = new Jedis("localhost", 6379);
    //操作
    jedis.hset("hash1","a1","b1");
    jedis.hset("hash1","a2","a2");
    jedis.hset("hash1","a3","b3");
    Map<String, String> hash1 = jedis.hgetAll("hash1");
    System.out.println(hash1);
    System.out.println(jedis.hlen("hash1"));
    System.out.println();
    //关闭
    jedis.close();
}

Jedis读写redis数据

第一步，实现业务方法，第二步，设置多线程类，实现线程调度，第三步，设计Redis业务逻辑，第四步，设计启动主程序

public class Service {
    private String id;
    private int num;
    public Service(String id,int num) {
        this.num=num;
        this.id = id;
    }

    //控制单元
        public void service( ){
            Jedis jedis = new Jedis("localhost", 6379);
//            jedis.set("name","java");
            String value = jedis.get("name"+id);
            //判断值是否存在
            try {
                if (value == null){
                    //不存在，创建该值
                    jedis.setex("name"+id,20,Long.MAX_VALUE-num+"");
                }else{
                    //存在，自增，调用服务
                    Long val = jedis.incr("name" + id);
                    business(id,num-(Long.MAX_VALUE - val));
                }
            }catch (JedisDataException e){
                System.out.println("使用次数已达到上限，请使用会员级别");
                return;
            }finally {
                jedis.close();
            }
  }
    //业务操作
    public void business(String id,Long val){
        System.out.println("用户："+id+" 业务执行操作第"+val+"次");
    }
}
class MyThread extends Thread{
        Service sc;
        public MyThread(String id,int num){
            sc =  new Service(id,num);
        }
       @Override
       public void run(){
           while (true){
               sc.service();
               try {
                   Thread.sleep(300L);
               } catch (InterruptedException e) {
                   e.printStackTrace();
               }
           }
       }
}
class Main{
    public static void main(String[] args) {
        MyThread t = new MyThread("初级用户",10);
        MyThread t2 = new MyThread("高级用户", 30);
        t.start();
        t2.start();
    }
}

Jedis工具类

第一步，初始化静态资源，连接配置对象，第二步，从连接处获取jedis对象，第三步，配置封装连接参数。

public class JedisUtils {
    //初始化静态资源
    private static JedisPool jp =null; //连接池技术
    private static String host =null;//服务器地址
    private static int port;//服务端口号
    private static int maxTotal;
    private static int maxIdle;
    static {
        ResourceBundle rb = ResourceBundle.getBundle("jedis");
        host = rb.getString("jedis.host");
        port = Integer.parseInt(rb.getString("jedis.port"));
        maxTotal = Integer.parseInt(rb.getString("jedis.maxIdle"));
        maxIdle = Integer.parseInt(rb.getString("jedis.maxIdle"));
        JedisPoolConfig jpc = new JedisPoolConfig();//连接配置对象
        jpc.setMaxTotal(maxTotal); //最大连接数
        jpc.setMaxIdle(maxIdle);//设置最大活动数
         jp = new JedisPool(jpc, host, port);
    }
    //获取连接提供jedis对象，连接从连接处获取
    public static Jedis getJedis(){
        return jp.getResource();
    }

    public static void main(String[] args) {
        JedisUtils.getJedis();
    }
}

封装连接参数

jedis.properties

jedis.host =127.0.0.1
jedis.port = 6379
jedis.maxTotal=30
jedis.maxIdle=10