我是靠谱客的博主 鳗鱼口红,最近开发中收集的这篇文章主要介绍Redis的Java客户端之Jedis(Jedis)Redis的Java客户端(Jedis),觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

文章目录

  • Redis的Java客户端(Jedis)
    • 一、简介
    • 二、Jedis快速入门
      • 1、引入依赖
      • 2、建立连接
      • 3、使用Jedis
      • 4、释放资源
    • 三、Jedis连接池
      • 1、创建Jedis连接池配置
      • 2、调用Jedis连接池
    • 四、步骤整合
      • 1、引入依赖
      • 2、创建Jedis连接池类
      • 3、创建Jedis操作类


Redis的Java客户端(Jedis)

一、简介

  • Spring Data Redis:Jedis 以Redis命令作为方法名称,学习成本低,简单实用。但是Jedis实例是线程不安全的,多线程环境下需要基于连接池来使用。

  • Jedis官网:https://github.com/redis/jedis

二、Jedis快速入门

1、引入依赖

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

2、建立连接

package com.sgz.jedis;

import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;

public class JedisTest {

    private Jedis jedis;

    // 2、建立连接
    @BeforeEach
    void setUp() {
        // 1、建立连接
        jedis = new Jedis("192.168.8.137", 6379);
        // 2、设置密码
        jedis.auth("123123");
        // 3、选择库
        jedis.select(0);
    }
}

3、使用Jedis

    // 3、使用Jedis,测试String
    @Test
    void testString(){
        // 插入数据
        String result = jedis.set("name", "小李");
        System.out.println("result = "+ result);	// 返回 OK,插入成功
        // 获取数据
        String name = jedis.get("name");
        System.out.println("name = "+ name);
    }
    
     // 3、使用Jedis,测试 Hash
    @Test
    void testHash() {
        // 插入数据
        long hset = jedis.hset("student:1", "name", "Jack");
        long age = jedis.hset("student:1", "age", "21");
        System.out.println(  "hset = " + hset); // 返回1插入成功
        System.out.println(  "age = " + age);   // 返回1插入成功
        // 获取数据
        Map<String, String> map = jedis.hgetAll("student:1");
        System.out.println("map = " + map);
    }

4、释放资源

    // 4、释放资源
    @AfterEach
    void testDown(){
        if (jedis != null){
            jedis.close();
        }
    }

三、Jedis连接池

  • Jedis本身是线程不安全的,并且频繁的创建和销毁连接会有性能损耗,因此我们推荐大家使用Jedis连接池替代Jedis的直连方式。

1、创建Jedis连接池配置

package com.sgz.jedis.util;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisConnectionFactory {
    private static final JedisPool JEDIS_POOL;
    static {
        JedisPoolConfig poolConfig = new JedisPoolConfig();	// 配置连接池
        poolConfig.setMaxTotal(8);  // 最大连接
        poolConfig.setMaxIdle(8);   // 最大空闲连接
        poolConfig.setMinIdle(0);   // 最小空闲连接
        poolConfig.setMaxWaitMillis(1000);  // 设置最长等待时间,ms
        JEDIS_POOL = new JedisPool(poolConfig,"192.168.246.128",6379,1000,"123123",0); // 创建连接池对象
    }
	// 获取Jedis对象
    public static Jedis getJedis(){
        return JEDIS_POOL.getResource();
    }
}

2、调用Jedis连接池

package com.sgz.jedis;

import com.sgz.jedis.util.JedisConnectionFactory;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;
import java.util.Map;

public class JedisTest {

    private Jedis jedis;

    // 2、建立连接
    @BeforeEach
    void setUp() {
        // 从池子里获取连接
        jedis = JedisConnectionFactory.getJedis();
    }

      // 3、使用Jedis,测试String
    @Test
    void testString(){
        // 插入数据
        String result = jedis.set("name", "小李");
        System.out.println("result = "+ result);	// 返回 OK,插入成功
        // 获取数据
        String name = jedis.get("name");
        System.out.println("name = "+ name);
    }
    
     // 3、使用Jedis,测试 Hash
    @Test
    void testHash() {
        // 插入数据
        long hset = jedis.hset("student:1", "name", "Jack");
        long age = jedis.hset("student:1", "age", "21");
        System.out.println(  "hset = " + hset); // 返回1插入成功
        System.out.println(  "age = " + age);   // 返回1插入成功
        // 获取数据
        Map<String, String> map = jedis.hgetAll("student:1");
        System.out.println("map = " + map);
    }

    // 4、释放 资源
    @AfterEach
    void  testDown(){
        if (jedis != null){
            jedis.close();
        }
    }
}

四、步骤整合

1、引入依赖

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

2、创建Jedis连接池类

package com.sgz.jedis.util;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisConnectionFactory {
    private static final JedisPool JEDIS_POOL;
    static {
        JedisPoolConfig poolConfig = new JedisPoolConfig();	// 配置连接池
        poolConfig.setMaxTotal(8);  // 最大连接
        poolConfig.setMaxIdle(8);   // 最大空闲连接
        poolConfig.setMinIdle(0);   // 最小空闲连接
        poolConfig.setMaxWaitMillis(1000);  // 设置最长等待时间,ms
        JEDIS_POOL = new JedisPool(poolConfig,"192.168.246.128",6379,1000,"123123",0); // 创建连接池对象
    }
	// 获取Jedis对象
    public static Jedis getJedis(){
        return JEDIS_POOL.getResource();
    }
}

3、创建Jedis操作类

package com.sgz.jedis;

import com.sgz.jedis.util.JedisConnectionFactory;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;
import java.util.Map;

public class JedisTest {

    private Jedis jedis;

    // 建立连接
    @BeforeEach
    void setUp() {
    	// 从池子里获取连接
        jedis = JedisConnectionFactory.getJedis();
    }

      // 3、使用Jedis,测试String
    @Test
    void testString(){
        // 插入数据
        String result = jedis.set("name", "小李");
        System.out.println("result = "+ result);	// 返回 OK,插入成功
        // 获取数据
        String name = jedis.get("name");
        System.out.println("name = "+ name);
    }
    
     // 3、使用Jedis,测试 Hash
    @Test
    void testHash() {
        // 插入数据
        long hset = jedis.hset("student:1", "name", "Jack");
        long age = jedis.hset("student:1", "age", "21");
        System.out.println(  "hset = " + hset); // 返回1插入成功
        System.out.println(  "age = " + age);   // 返回1插入成功
        // 获取数据
        Map<String, String> map = jedis.hgetAll("student:1");
        System.out.println("map = " + map);
    }

    // 4、释放 资源
    @AfterEach
    void  testDown(){
        if (jedis != null){
            jedis.close();
        }
    }
}

最后

以上就是鳗鱼口红为你收集整理的Redis的Java客户端之Jedis(Jedis)Redis的Java客户端(Jedis)的全部内容,希望文章能够帮你解决Redis的Java客户端之Jedis(Jedis)Redis的Java客户端(Jedis)所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(63)

评论列表共有 0 条评论

立即
投稿
返回
顶部