Jedis与Redis

Jedis与Redis

通过Jedis操作Redis

Jedis是Redis官方推荐的java连接开发工具 , 使用ava操作Redis中间件

创建项目

首先创建一个空项目:

Jedis与Redis

创建一个Maven的Module项目:

Jedis与Redis

一路next即可。

因为该项目的最先创建的是空项目,所以需要手动调节部分配置:

以下修改的都是JDK配置,按照自己电脑为准

  1. File----Project Structure---project
Jedis与Redis
  1. File----Project Structure---modules
Jedis与Redis
  1. File---Settings ,搜索 Java Compiler
Jedis与Redis

导入依赖

<!--导入jedis-->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.2.0</version>
</dependency>
<!--fastjson-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.62</version>
</dependency>

Redis-Dome编写

1.连接Redis

先打开你电脑上的 redis-server

Jedis与Redis
public class TestPing {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1",6379);
        System.out.println(jedis.ping());
    }
}

Jedis与Redis

2.常用API

所有的命令,就和在 Linux 中使用Redis 没有区别,以下对 StringList 进行举例:

String 命令

Jedis jedis = new Jedis("127.0.0.1",6379);
System.out.println("String存入数据:"+jedis.set("k", "v"));
System.out.println("String获取数据:"+jedis.get("k"));
System.out.println("String查看该元素是否存在"+jedis.exists("k"));
System.out.println("String追加字符串:"+jedis.append("k","、hello"));
System.out.println("String获取字符串长度:"+jedis.strlen("k"));
System.out.println("String设置过期时间:"+jedis.setex("k1",3,"test"));
// 睡眠3s,验证k1是否过期
Thread.sleep(3000);
System.out.println("String查看是否过期:"+jedis.ttl("k1"));
System.out.println("String不存在再设置:"+jedis.setnx("k2","v2"));
System.out.println("String同时设置多个值:"+jedis.mset("k3","v3","k4","v4"));
System.out.println("String同时获取多个值:"+jedis.mget("k3","k4"));

Jedis与Redis

List 命令

System.out.println("清除数据:"+jedis.flushDB());
System.out.println("List存入数据(头插):"+jedis.lpush("list","one","two","three"));
System.out.println("List存入数据(尾插):"+jedis.rpush("list","right"));
System.out.println("List获取范围内的数据:"+jedis.lrange("list",1,2));
System.out.println("List通过下标获得值:"+jedis.lindex("list",1));
System.out.println("List获取列表长度:"+jedis.llen("list"));
System.out.println("List移除指定数据:"+jedis.lrem("list",1,"one"));
System.out.println("List替换指定位置的值:"+jedis.lset("list",0,"test"));
System.out.println("List插入具体值:"+jedis.linsert("list", ListPosition.BEFORE,"two","111111"));
System.out.println("List查看全部的元素:"+jedis.lrange("list",0,-1));
System.out.println("List取出数据(从头部):"+jedis.lpop("list"));
System.out.println("List取出数据(从尾部):"+jedis.rpop("list"));

Jedis与Redis

3.Jedis理解事务

  • 连接Redis
  • 开启事务
  • 存入数据
  • 运行
    • 若正常,直接执行事务
    • 若出异常,事务直接结束
  • 最后关闭连接
public class AffairsTesi {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
		jedis.flushDB();
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("k", "v");
        jsonObject.put("name", "zc");
        //开启事务
        Transaction multi = jedis.multi();
        String s = jsonObject.toJSONString();

        try {
            multi.set("user1", s);
            multi.set("user2", s);
            // int i = 1/0 ;     // 加入该句,可以使之产生异常,自行测试
            multi.exec();        // 没出问题 ,执行事务
        } catch (Exception e) {
            multi.discard();     // 出异常,结束事务
            e.printStackTrace();
        } finally {
            System.out.println(jedis.get("user1"));
            System.out.println(jedis.get("user2"));
            jedis.close();      // 最终关闭连接
        }
    }
}

正常结束

Jedis与Redis

异常结束

Jedis与Redis

个人博客为:
MoYu's HomePage

上一篇:Redis学习


下一篇:技术干货 | 高负载压测下接口异常问题定位排查-Redis