Jedis连接Redis数据库
2018-05-05 本文已影响1人
WebGiser
在运行程序前,要注意启动Redis数据库服务。
1、pom.xml依赖:
<dependencies>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
</dependencies>
2、连接数据库代码:
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class TestJedisTest {
/*
* jedis单例测试
* */
@Test
public void test1(){
//1、设置ip地址和端口号
Jedis jedis = new Jedis("192.168.2.1",6379);
//2、保存数据
jedis.set("name","abc");
//3、获取数据
String value = jedis.get("name");
System.out.println(value);
}
/*
* jedis连接池
* */
@Test
public void test2(){
//1、获得连接池的配置对象
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
//2、设置最大连接数
jedisPoolConfig.setMaxTotal(30);
//3、设置最大空闲连接数
jedisPoolConfig.setMaxIdle(10);
//4、获得连接池
JedisPool jedisPool = new JedisPool(jedisPoolConfig,"192.168.2.1",6379);
Jedis jedis = null;
try{
//5、获取jedis对象
jedis = jedisPool.getResource();
jedis.set("name","xyz");
String value = jedis.get("name");
System.out.println(value);
}catch (Exception e){
e.printStackTrace();
}finally {
if(jedis != null){
jedis.close();
}
if(jedisPool != null){
jedisPool.close();
}
}
}
}