1、构建redis连接池,返还到连接池

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();
  }
}

2、 jedis使用

典型的jedis使用方法

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;
}

这种写法会经常忘记返回jedis到pool.参考Spting JdbcTemplate的实现方式，优化如下

优化jedis使用方法

public static String getByTemplate(final String key) {
  RedisTemplate redisTemplate = new RedisTemplate(getJedisPool());
  String value = redisTemplate.execute(new RedisCallback<String>() {
    @Override
    public String handle(Jedis jedis) {
      return jedis.get(key);
    }
  });
  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);
}

常用的jedis方法

字符串

@Test
public void testString() {
  jedis.set("name", "webb"); // 添加数据
  System.out.println("name -> " + jedis.get("name"));

  jedis.append("name", " , javaer"); // 拼接
  System.out.println("name -> " + jedis.get("name"));

  jedis.del("name"); // 删除数据
  System.out.println("name -> " + jedis.get("name"));

  jedis.mset("name", "webb", "age", "24"); // 设置多个键值对
  jedis.incr("age"); // 进行加1操作

  System.out.println("name -> " + jedis.get("name") + ", age -> " + jedis.get("age"));
}

列表

@Test
public void testList() {
  String key = "java framework";

  jedis.lpush(key, "spring");
  jedis.lpush(key, "spring mvc");
  jedis.lpush(key, "mybatis");

  System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有

  jedis.del(key);
  jedis.rpush(key, "spring");
  jedis.rpush(key, "spring mvc");
  jedis.rpush(key, "mybatis");

  System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有

  System.out.println(jedis.llen(key)); // 列表长度
  System.out.println(jedis.lrange(key, 0, 3));
  jedis.lset(key, 0 , "redis"); // 修改列表中单个值
  System.out.println(jedis.lindex(key, 1)); // 获取列表指定下标的值
  System.out.println(jedis.lpop(key)); // 列表出栈
  System.out.println(jedis.lrange(key, 0 , -1)); // -1表示取得所有
}

散列

@Test
public void testMap() {
  String key = "user";

  Map<String, String> map = new HashMap<>();
  map.put("name", "webb");
  map.put("age", "24");
  map.put("city", "hangzhou");

  jedis.hmset(key, map); // 添加数据

  List<String> rsmap = jedis.hmget(key, "name", "age", "city"); // 第一个参数存入的是redis中map对象的key,后面跟的是放入map中的对象的key
  System.out.println(rsmap);

  jedis.hdel(key, "age"); // 删除map中的某个键值

  System.out.println(jedis.hmget(key, "age"));
  System.out.println(jedis.hlen(key)); // 返回key为user的键中存放的值的个数
  System.out.println(jedis.exists(key)); // 是否存在key为user的记录
  System.out.println(jedis.hkeys(key)); // 返回map对象中的所有key
  System.out.println(jedis.hvals(key)); // 返回map对象中所有的value

  Iterator<String> iterator = jedis.hkeys("user").iterator();

  while (iterator.hasNext()) {
    String key2 = iterator.next();
    System.out.print(key2 + " : " + jedis.hmget("user", key2) + "\n");
  }
}

集合

@Test
public void testSet() {
  String key = "userSet";
  String key2 = "userSet2";

  jedis.sadd(key, "webb");
  jedis.sadd(key, "webb");
  jedis.sadd(key, "lebo");
  jedis.sadd(key, "lebo0425");
  jedis.sadd(key, "who");

  jedis.srem(key, "who"); // 删除

  System.out.println(jedis.smembers(key)); // 获取所有加入的value
  System.out.println(jedis.sismember(key, "who")); // 判断value是否在集合中
  System.out.println(jedis.srandmember(key)); // 随机返回一个value
  System.out.println(jedis.scard(key)); // 返回集合的元素个数

  jedis.sadd(key2, "webb");
  jedis.sadd(key2, "ssq");

  System.out.println(jedis.sinter(key, key2)); // 交集
  System.out.println(jedis.sunion(key, key2)); // 并集
  System.out.println(jedis.sdiff(key, key2)); // 差集
}

有序集合

@Test
public void testSortedSet() {
  String key = "sortedSet";

  jedis.zadd(key, 1999, "one");
  jedis.zadd(key, 1994, "two");
  jedis.zadd(key, 1998, "three");
  jedis.zadd(key, 2000, "four");
  jedis.zadd(key, 2017, "five");

  Set<String> setValues = jedis.zrange(key, 0 , -1); // score从小到大
  System.out.println(setValues);
  Set<String> setValues2 = jedis.zrevrange(key, 0, -1); // score从大到小
  System.out.println(setValues2);

  System.out.println(jedis.zcard(key)); // 元素个数
  System.out.println(jedis.zscore(key, "three")); // 元素下标
  System.out.println(jedis.zrange(key, 0, -1)); // 集合子集
  System.out.println(jedis.zrem(key, "five")); // 删除元素
  System.out.println(jedis.zcount(key, 1000, 2000)); // score在1000-2000内的元素个数
}

以上这篇详谈Jedis连接池的使用就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

# jedis  # 连接池  # jedis连接池对commons-pool的封装示例详解  # java客户端Jedis操作Redis Sentinel 连接池的实现方法  # Jedis出现connection timeout问题解决方法（JedisPool连接池使用实例）  # 探索jedis连接池预热优化高并发  # 的是  # 给大家  # 值为  # 键值  # 象中  # 第一个  # 多个  # 最多  # 希望能  # 这篇  # 装了  # 抛出  # 小编  # 从小到大  # 大到  # 大家多多  # 是否存在  # 中取  # 默认值 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 历史网站制作软件,华为如何找回被删除的网站？  如何快速搭建支持数据库操作的智能建站平台？  浅述节点的创建及常见功能的实现  详解Nginx + Tomcat 反向代理 负载均衡 集群 部署指南  深圳防火门网站制作公司,深圳中天明防火门怎么编码？  在centOS 7安装mysql 5.7的详细教程  学生网站制作软件,一个12岁的学生写小说，应该去什么样的网站？  手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办？  JavaScript如何实现类型判断_typeof和instanceof有什么区别  php静态变量怎么调试_php静态变量作用域调试技巧【解答】  使用Dockerfile构建java web环境  Laravel如何使用Eloquent ORM进行数据库操作？（CRUD示例）  Laravel表单请求验证类怎么用_Laravel Form Request分离验证逻辑教程  详解Android图表 MPAndroidChart折线图  Laravel如何发送邮件和通知_Laravel邮件与通知系统发送步骤  EditPlus中的正则表达式实战(5)  使用spring连接及操作mongodb3.0实例  EditPlus中的正则表达式 实战(4)  香港服务器租用费用高吗？如何避免常见误区？  邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作，模板很多的那种？  如何用AI一键生成爆款短视频文案？小红书AI文案写作指令【教程】  Laravel如何集成微信支付SDK_Laravel使用yansongda-pay实现扫码支付【实战】  如何快速搭建高效香港服务器网站？  实例解析Array和String方法  Laravel如何使用Blade模板引擎？（完整语法和示例）  做企业网站制作流程,企业网站制作基本流程有哪些？  零服务器AI建站解决方案：快速部署与云端平台低成本实践  Laravel如何理解并使用服务容器（Service Container）_Laravel依赖注入与容器绑定说明  Windows10怎样连接蓝牙设备_Windows10蓝牙连接步骤【教程】  惠州网站建设制作推广,惠州市华视达文化传媒有限公司怎么样？  DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解  如何在 Python 中将列表项按字母顺序编号（a.、b.、c. …）  Laravel队列任务超时怎么办_Laravel Queue Timeout设置详解  Linux系统运维自动化项目教程_Ansible批量管理实战  高防服务器：AI智能防御DDoS攻击与数据安全保障  如何在阿里云香港服务器快速搭建网站？  如何使用 jQuery 正确渲染 Instagram 风格的标签列表  Laravel的.env文件有什么用_Laravel环境变量配置与管理详解  如何快速重置建站主机并恢复默认配置？  Laravel如何自定义错误页面（404, 500）？（代码示例）  Laravel如何创建自定义Artisan命令？（代码示例）  SQL查询语句优化的实用方法总结  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗？  如何确保FTP站点访问权限与数据传输安全？  Laravel distinct去重查询_Laravel Eloquent去重方法  青岛网站建设如何选择本地服务器？  Laravel怎么配置自定义表前缀_Laravel数据库迁移与Eloquent表名映射【步骤】  如何用wdcp快速搭建高效网站？  HTML 中动态设置元素 name 属性的正确语法详解  Win11怎么关闭透明效果_Windows11辅助功能视觉效果设置