脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Jedis使用Redis事务

关于Jedis的用法以及Jedis使用Redis事务

 更新时间：2023年03月17日 15:00:47   作者：茂桑  
这篇文章主要介绍了关于Jedis的用法以及Jedis使用Redis事务问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

我们要使用java来操作redis

什么是Jedis?

什么是Jedis 是Redis官方推荐的java连接开发工具!使用Java操作Redis 中间件!（就是一个jar包）如果你要使用java操作redis，那么一定要对Jedis十分的熟悉!

测试

1、导入对应的依赖

        <!-- 导入jedis的包 -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>4.2.2</version>
        </dependency>
        <!-- fastjson-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.50</version>
        </dependency>

2、编码测试

  • 连接redis数据库
  • 操作命令
  • 断开连接！
public class TestPing {
    public static void main(String[] args) {
        //1、new Jedis对象即可
        Jedis jedis = new Jedis("127.0.0.1",6379);
        //Jedis所有的命令就是我们之前学习的指令！
        System.out.println(jedis.ping());;
    }
}

输出：说明连接成功

PONG

jedis所有方法和redis里的所有命令一模一样，没有任何改变，在redis上能操作的，使用jedis同样可以操作

String

执行结果：

string的其他方法：

list

执行结果：

set

执行结果：

hash

执行结果：

zset

也是一样，在linux上执行的命令就是jedis的方法

所有的api命令，就是我们学习的指令，一一对应，一个都没有变化!

事务

1、在java中使用redis的事务：

package com.uno;

import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class TestTx {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("hello","world");
        jsonObject.put("name", "UNO");
        String result = jsonObject.toJSONString();
        //1、开启事务
        Transaction multi = jedis.multi();
        //jedis.watch(result);  //加乐观锁，监视
        try {
            //2、命令入队
            multi.set("user1", result);
            multi.set("user2",result);
            //3、执行，这三个步骤也都是和linux中操作redis命令一模一样
            multi.exec();
        } catch (Exception e) {
            //当出现错误，放弃事务
            multi.discard();
            throw new RuntimeException(e);
        } finally {
            System.out.println(jedis.get("user1"));
            System.out.println(jedis.get("user2"));
            //关闭连接
            jedis.close();
        }
    }
}

执行结果：成功

{"name":"UNO","hello":"world"}

{"name":"UNO","hello":"world"}

2、如果出现错误：

package com.uno;

import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class TestTx {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        jedis.flushDB(); //先清理一下数据库，免得被上面的代码在redis设置的值影响
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("hello","world");
        jsonObject.put("name", "UNO");
        String result = jsonObject.toJSONString();
        //1、开启事务
        Transaction multi = jedis.multi();
//        jedis.watch(result);  //加乐观锁，监视
        try {
            //2、命令入队
            multi.set("user1", result);
            multi.set("user2",result);
            int i = 1/0;  //手动设置一个运行时异常，看是不是会出现运行时异常，然后被catch捕获
            //3、执行，这三个步骤也都是和linux中操作redis命令一模一样
            multi.exec();
        } catch (Exception e) {
            //放弃事务
            multi.discard();
            throw new RuntimeException(e);
        } finally {
            System.out.println(jedis.get("user1"));
            System.out.println(jedis.get("user2"));
            //关闭连接
            jedis.close();
        }
    }
}

执行结果：出现运行时异常，被catch捕获，在catch中放弃事务，就是都不执行

null
null
Exception in thread "main" java.lang.RuntimeException: java.lang.ArithmeticException: / by zero
    at com.uno.TestTx.main(TestTx.java:28)
Caused by: java.lang.ArithmeticException: / by zero
    at com.uno.TestTx.main(TestTx.java:22)

注意事项：jedis连不上远程服务器

用Jedis连接阿里云等服务器上的redis

一. 配置redis.conf

1.设置访问redis的密码：requirepass 要设置密码

2.注释bind 127.0.0.1

(重启redis-server服务,进入redis后要先验证密码,用这个命令：auth 密码 ,然后ping一下看有没有配置成功)

二 . idea访问时添加auth密码

Jedis jedis = new Jedis("服务器的外网ip",6379);
jedis.auth("redis的密码");
System.out.println(jedis.ping());
（输出PONG的话就成功了）

题外话：为什么事务transaction简称为TX

transaction的读法是/træn’zækʃən/

x的读法是/ɛks/

所以tx分别代表：t - tran; x-saction

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • RabbitMQ实现消费端限流的步骤

    RabbitMQ实现消费端限流的步骤

    消费者端限流的主要目的是控制消费者每次从 RabbitMQ 中获取的消息数量,从而实现消息处理的流量控制,这篇文章主要介绍了RabbitMQ如何实现消费端限流,需要的朋友可以参考下
    2024-03-03
  • 如何让Spring Rest 接口中路径参数可选

    如何让Spring Rest 接口中路径参数可选

    这篇文章主要介绍了如何让Spring Rest 接口中路径参数可选，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-10-10
  • SpringBoot+slf4j线程池全链路调用日志跟踪问题及解决思路(二)

    SpringBoot+slf4j线程池全链路调用日志跟踪问题及解决思路(二)

    本文主要给大家介绍如何实现子线程中的traceId日志跟踪，本文通过封装Callable为例给大家介绍的非常详细，需要的朋友一起看看吧
    2021-05-05
  • 如何通过zuul添加或修改请求参数

    如何通过zuul添加或修改请求参数

    这篇文章主要介绍了如何通过zuul添加或修改请求参数的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-07-07
  • SpringBoot实现过滤敏感词的示例代码

    SpringBoot实现过滤敏感词的示例代码

    这篇文章主要为大家详细介绍了如何利用SpringBoot实现过滤敏感词功能，文中的示例代码讲解详细，感兴趣的小伙伴可以动手尝试一下
    2022-08-08
  • java中对字符串每个字符统计的方法

    java中对字符串每个字符统计的方法

    java中对字符串每个字符统计的方法，需要的朋友可以参考一下
    2013-03-03
  • 基于SpringBoot创建Web页面并热更新的操作步骤

    基于SpringBoot创建Web页面并热更新的操作步骤

    SpringBoot是一个用于快速开发单个微服务的框架,它基于 Spring 框架,简化了Spring应用的初始化过程和开发流程,本文给大家介绍了如何基于SpringBoot创建Web页面并热更新,文中通过图文介绍的非常详细,需要的朋友可以参考下
    2023-11-11
  • Java项目全面升级转化经验(涉及JDK、Spring boot版本及依赖管理架构)

    Java项目全面升级转化经验(涉及JDK、Spring boot版本及依赖管理架构)

    在软件开发领域,项目升级是一个必然的过程,随着技术的不断进步和业务需求的变化,对于旧项目的升级和优化已成为许多企业必须面对的问题,这篇文章主要介绍了Java项目全面升级转化的相关资料,包括JDK、Spring boot版本及依赖管理架构,需要的朋友可以参考下
    2025-09-09
  • Java中Function的使用及说明

    Java中Function的使用及说明

    这篇文章主要介绍了Java中Function的使用及说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2023-05-05
  • Java自定义异常类的实例详解

    Java自定义异常类的实例详解

    这篇文章主要介绍了Java自定义异常类的实例详解的相关资料,希望通过本文能帮助到大家，让大家学习理解掌握这部分内容，需要的朋友可以参考下
    2017-09-09

最新评论