redis 在java中的使用

Posted 2020-09-30 【

1、首先下载jar包放到你的工程中

2、练习

package com.jianyuan.redisTest;

import java.util.Iterator;
import java.util.List;
import java.util.Set;

import redis.clients.jedis.Jedis;

public class RedisTest {

public static void main(String[] args) {
//连接本地的Redis服务
Jedis jedis = new Jedis("127.0.0.1",6379);
//权限认证
jedis.auth("wenhongyu66");
jedis.select(0);
System.out.println("连接成功");
//查看服务是否运行
System.out.println(jedis.ping());

//设置 redis 字符串数据
jedis.set("runoobkey", "www.runoob.com");
// 获取存储的数据并输出
System.out.println("redis 存储的字符串为: "+ jedis.get("runoobkey"));

//存储数据到列表中
jedis.lpush("site-list", "Runoob");
jedis.lpush("site-list", "Google");
jedis.lpush("site-list", "Taobao");
System.out.println(jedis.llen("site-list"));
// 获取存储的数据并输出
List<String> list = jedis.lrange("site-list", 0 ,jedis.llen("site-list"));
for(int i=0; i<list.size(); i++) {
System.out.println("列表项为: "+list.get(i));
}

// 获取数据并输出
Set<String> keys = jedis.keys("*");
Iterator<String> it=keys.iterator() ;
while(it.hasNext()){
String key = it.next();
System.out.println(key);
}

}

}

 

总结：自己可以封装一些工具类方便使用，包括连接池的配置，jedis参数的配置等。

private static JedisPool jedisPool = null;

private static Jedis jedis;

 

static {

  jedis = getJedisPool().getResource();

}

 

/**

 * 构建redis连接池

 */

public static JedisPool getJedisPool() {

  if (jedisPool == null) {

    JedisPoolConfig config = new JedisPoolConfig();

    config.setMaxTotal(1024); // 可用连接实例的最大数目,如果赋值为-1,表示不限制.

    config.setMaxIdle(5); // 控制一个Pool最多有多少个状态为idle(空闲的)jedis实例,默认值也是8

    config.setMaxWaitMillis(1000 * 100); // 等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时/如果超过等待时间,则直接抛出异常

    config.setTestOnBorrow(true); // 在borrow一个jedis实例时,是否提前进行validate操作,如果为true,则得到的jedis实例均是可用的

    jedisPool = new JedisPool(config, "127.0.0.1", 6379);

  }

  return jedisPool;

}

 

/**

 * 释放jedis资源

 */

public static void returnResource(Jedis jedis) {

  if (jedis != null) {

    jedis.close();

  }

}

public static String get(String key) {

  String value = null;

  Jedis jedis = null;

  try {

    JedisPool pool = getJedisPool();

    jedis = pool.getResource();

    value = jedis.get(key);

  }

  catch (Exception e) {

    returnResource(jedis);

    e.printStackTrace();

  }

  finally {

    returnResource(jedis);

  }

  return value;

}

 

RedisTemplate封装了从JedisPool中取jedis以及返回池中

 

public class RedisTemplate {

 

  private JedisPool jedisPool;

 

  public RedisTemplate(JedisPool jedisPool) {

    this.jedisPool = jedisPool;

  }

 

  public <T> T execute(RedisCallback<T> callback) {

    Jedis jedis = jedisPool.getResource();

    try {

      return callback.handle(jedis);

    }

    catch (Exception e) {

      // throw your exception

      throw e;

    }

    finally {

      returnResource(jedis);

    }

  }

 

  private void returnResource(Jedis jedis) {

    if (jedis != null) {

      jedis.close();

    }

  }

}

public interface RedisCallback<T> {

  public T handle(Jedis jedis);

}