我是靠谱客的博主 鳗鱼口红,最近开发中收集的这篇文章主要介绍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)所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复