JAVA数据库

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();
            }
        }
    }
}
上一篇 下一篇

猜你喜欢

热点阅读