Jedis(Java操作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>

package com.wyh;
import redis.clients.jedis.Jedis;
/**
 * @program: redis
 * @description: 连接Redis数据库
 * @author: 魏一鹤
 * @createDate: 2021-11-11 23:20
 **/
public class RedisTest {
public static void main(String[] args){
// 1.new 一个Jedis
        Jedis jedis = new Jedis("127.0.0.1",6379); //本地服务加端口号
        //jedis中的所有命令和redis中的命令都是完全相同的
        System.out.println(jedis.ping());//返回pong表示本地redis连接成功
        String set = jedis.set("name", "wyh"); //设置一个键值对
        String name = jedis.get("name");  //获取name这个键对应的值
        System.out.println(name);
    }
}

package com.wyh;
import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;
/**
 * @program: redis
 * @description: redis实现事务
 * @author: 魏一鹤
 * @createDate: 2021-11-14 17:00
 **/
public class RedisTransaction {
public static void main(String[] args){
//连接redis
        Jedis jedis = new Jedis("127.0.0.1", 6379);
//刷新redis数据库
        jedis.flushDB();
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("key1","value1");
        jsonObject.put("key2","value2");
//开启事务
        Transaction multi = jedis.multi();
//转化json数据
        String jsonString = jsonObject.toJSONString();
//命令入队(进入队列)
        try {
            multi.set("user1",jsonString);
            multi.set("user2",jsonString);
//代码抛出异常,事务执行失败 
            int num=1/0;
//成功就执行事务
            multi.exec();
        } catch (Exception e) {
//失败就放弃事务
            multi.discard();
//自动捕获异常并打印出来
            e.printStackTrace();
        } finally {
            System.out.println(jedis.get("user1"));
            System.out.println(jedis.get("user2"));
//关闭redis
            jedis.close();
        }
    }
}