Jedis快速入门
- 1.Jedis使用的基本步骤:
- 1.1 引入依赖
- 1.2 创建Jedis对象,建立连接
- 1.3 使用Jedis,方法名与Redis命令一致
- 1.4 释放资源
- 1.5 完整代码
- 1.6 可视化工具查看
- 2.Jedis的连接池
- 2.1 代码
- 2.2 获取连接修改如下
1.Jedis使用的基本步骤:
1.1 引入依赖
<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>3.7.0</version>
</dependency>
1.2 创建Jedis对象,建立连接
void setUp() {jedis = new Jedis("255.255.255.255", 6379);jedis.auth("123456");jedis.select(0);
}
1.3 使用Jedis,方法名与Redis命令一致
@Test
public void demo1() {String result = jedis.set("name", "虎哥");System.out.println("result=" + result);String name = jedis.get("name");System.out.println("name=" + name);
}@Test
public void demo2() {jedis.hset("user:1", "name", "Jack");jedis.hset("user:1", "age", "21");Map<String, String> map = jedis.hgetAll("user:1");System.out.println(map);}
1.4 释放资源
void tearDown() {if (jedis != null) {jedis.close();}
}
1.5 完整代码
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;@BeforeEachvoid setUp() {jedis = new Jedis("255.255.255.255", 6379);jedis.auth("123456");jedis.select(0);}@AfterEachvoid tearDown() {if (jedis != null) {jedis.close();}}@Testpublic void demo1() {String result = jedis.set("name", "虎哥");System.out.println("result=" + result);String name = jedis.get("name");System.out.println("name=" + name);}@Testpublic void demo2() {jedis.hset("user:1", "name", "Jack");jedis.hset("user:1", "age", "21");Map<String, String> map = jedis.hgetAll("user:1");System.out.println(map);}
}
1.6 可视化工具查看
工具下载地址:https://github.com/lework/RedisDesktopManager-Windows/releases
2.Jedis的连接池
2.1 代码
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;public class JedisConnectionFactory {private static final JedisPool jedisPool;static {//配置连接池JedisPoolConfig poolConfig = new JedisPoolConfig();//最大连接poolConfig.setMaxTotal(8);//最大空闲连接poolConfig.setMaxIdle(8);//最小空闲连接poolConfig.setMinIdle(8);//设置最长等待时间,单位mspoolConfig.setMaxWaitMillis(1000);//创建连接池对象jedisPool = new JedisPool(poolConfig, "255.255.255.255", 6379, 1000, "123456");}//获取Jedis对象public static Jedis getJedis() {return jedisPool.getResource();}
}
2.2 获取连接修改如下
void setUp() {//直接获取连接//jedis = new Jedis("255.255.255.255", 6379);//jedis.auth("123456");//连接池获取连接jedis = JedisConnectionFactory.getJedis();jedis.select(0);
}