美文网首页
3.redis连接池

3.redis连接池

作者: 惜小八 | 来源:发表于2020-06-15 20:00 被阅读0次

在项目当中要做单点登陆,所以使用到了redis,在项目当中使用了连接池进行连接,下面进行说明

一.连接池构建

需要注意的是连接池需要在项目初始化的时候进行,连接池的构建由JedisPool对象来完成,并提供了一个getJedis的方法。

package com.mall.common;

import com.mall.util.PropertiesUtil;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * redis连接池
 */
public class RedisPool {
    //tomcat 启动时JedisPool可以加载进来
    private static JedisPool pool;
    //最大连接数
    private static Integer maxTotal=Integer.parseInt(PropertiesUtil.getProperty("redis.max.total","20"));
    //最大空闲的连接数
    private static Integer maxIdle=Integer.parseInt(PropertiesUtil.getProperty("redis.max.idle","10"));
    //最小空闲连接数
    private static Integer minIdle=Integer.parseInt(PropertiesUtil.getProperty("redis.min.idle","2"));
    //从jedis连接池获取连接时,校验并返回可用的连接
    private static Boolean testOnBorrow=Boolean.parseBoolean(PropertiesUtil.getProperty("redis.test.borrow","true"));
    //把连接放回jedis连接池时,校验并返回可用的连接
    private static Boolean testOnReturn=Boolean.parseBoolean(PropertiesUtil.getProperty("redis.test.return","true"));


    private static String redisIp=PropertiesUtil.getProperty("redis.ip");
    private static Integer redisPort=Integer.parseInt(PropertiesUtil.getProperty("redis.port"));

    private static void initPool(){
        JedisPoolConfig config=new JedisPoolConfig();
        config.setMaxTotal(maxTotal);//默认8
        config.setMaxIdle(maxIdle);//默认8
        config.setMinIdle(minIdle);//默认0

        config.setTestOnBorrow(testOnBorrow);//默认false
        config.setTestOnReturn(testOnReturn);//默认false

        //默认就是true,连接耗尽的时候是否阻塞,false会报异常,true阻塞直到超时,超时会报超时异常
        config.setBlockWhenExhausted(true);

        pool=new JedisPool(config,redisIp,redisPort,1000*2);
    }

    //类在加载到jvm的时候加载连接池
    static {
        initPool();
    }

    //获取redis
    public static Jedis getJedis(){
        return pool.getResource();
    }

    //将redis放回连接池,释放资源
    public static void close(Jedis jedis){
        if(jedis !=null){
            jedis.close();
        }
    }


    public static void main(String[] args) {
        Jedis jedis=pool.getResource();// Jedis jedis=RedisPool.getJedis()
        jedis.set("name","codeSheep");
        close(jedis);

        pool.destroy();//销毁连接池当中的所有连接
        System.out.println("program is end");
    }

}
****************************redis参数****************************
#redis config start
redis.ip=127.0.0.1
redis.port=6379

redis.max.total=20
redis.max.idle=10
redis.min.idle=2
redis.test.borrow=true
redis.test.return=true

二.redis工具类封装

工具类比较简单,一般都是从连接池获取redis连接,然后执行操作,其次关闭连接。

package com.mall.util;


import com.mall.common.RedisPool;
import lombok.extern.slf4j.Slf4j;
import redis.clients.jedis.Jedis;

@Slf4j
public class RedisPoolUtil {

    public static String set(String key,String value){
        Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
        String result=jedis.set(key,value);
        RedisPool.close(jedis);
        return result;
    }

    public static String get(String key){
        Jedis jedis=RedisPool.getJedis();
        String value=jedis.get(key);
        RedisPool.close(jedis);
        return value;
    }

    //exTime的单位是s,设置key的值为value,存活时间是exTime
    public static String setEx(String key,String value,int exTime){
        Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
        //设置key的值为value,存活时间是exTime
        String result=jedis.setex(key,exTime,value);
        RedisPool.close(jedis);
        return result;
    }

    //重置key的有效期
    public static Long expire(String key,int exTime){
        Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
        //设置key的值为value,存活时间是exTime
        Long result=jedis.expire(key,exTime);
        RedisPool.close(jedis);
        return result;
    }

    //删除key
    public static Long del(String key){
        Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
        //删除key
        Long result=jedis.del(key);
        RedisPool.close(jedis);
        return result;
    }

    public static void main(String[] args) {
        String result=RedisPoolUtil.set("sex","男");
        String value=RedisPoolUtil.get("sex");
        System.out.println(value);

        RedisPoolUtil.setEx("zhandouli","10000",60*10);

        RedisPoolUtil.expire("sex",60*20);
        RedisPoolUtil.del("sex");
        System.out.println("end");

    }

}
结果正确显示

相关文章

  • 3.redis连接池

    在项目当中要做单点登陆,所以使用到了redis,在项目当中使用了连接池进行连接,下面进行说明 一.连接池构建 需要...

  • 撩课-JavaWeb之什么是连接池与连接池使用

    什么是连接池 没有连接池的情况 数据库连接池 池 连接池 作用 数据库连接池 示意图 连接池中的属性 连接池使用 ...

  • 代码分析

    interface 相关配置 默认子连接池 定义全局连接池 注册连接池 默认子连接池 连接

  • JDBC 进阶——连接池

    本文包括传统JDBC的缺点连接池原理自定义连接池开源数据库连接池DBCP连接池C3P0连接池Tomcat内置连接池...

  • springboot配置redis

    1.pom文件 2.application.properties文件 3.redis配置类 4.RedisTemp...

  • 3.redis汇总

    参考文档: http://doc.redisfans.com/# 1. 常用命令汇总 2. DBSIZE 返回ke...

  • redis 缓存注解

    Spring Boot 整合 Redis (进阶) 1.引入redis 2.添加配置 3.Redis 的 配置类 ...

  • SSM框架mybatis深入了解(二)

    一、mybatis中的连接池及事务控制 1.mybatis中的连接池使用及分析 1.1 连接池简介连接池是创建和...

  • JDBC进阶学习笔记

    JDBC进阶 JDBC连接池 1. 常见的JDBC连接池 c3p0 开源连接池 druid 阿里的开源数据库连接池...

  • Druid连接池

    第一章 连接池 一.1. 遇到的问题-引出连接池 | | 一.2. 连接池思想 | | 一.3. 连接池的概述 一...

网友评论

      本文标题:3.redis连接池

      本文链接:https://www.haomeiwen.com/subject/ezvhxktx.html