传智播客旗下技术交流社区北京校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 淡淡的念 初级黑马   /  2019-1-10 12:58  /  28 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

jedis连接池: JedisPool
                * 使用:
                        1. 创建JedisPool连接池对象
                        2. 调用方法 getResource()方法获取Jedis连接
                                //0.创建一个配置对象
                        JedisPoolConfig config = new JedisPoolConfig();
                        config.setMaxTotal(50);
                        config.setMaxIdle(10);
               
                        //1.创建Jedis连接池对象
                        JedisPool jedisPool = new JedisPool(config,"localhost",6379);
               
                        //2.获取连接
                        Jedis jedis = jedisPool.getResource();
                        //3. 使用
                        jedis.set("hehe","heihei");
  //4. 关闭 归还到连接池中
                        jedis.close();
               
                * 连接池工具类
                        public class JedisPoolUtils {

                            private static JedisPool jedisPool;
                       
                            static{
                                //读取配置文件
                                InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");
                                //创建Properties对象
                                Properties pro = new Properties();
                                //关联文件
                                try {
                                    pro.load(is);
                                } catch (IOException e) {
                                    e.printStackTrace();
                                }
                                //获取数据,设置到JedisPoolConfig中
                                JedisPoolConfig config = new JedisPoolConfig();
                                config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));
                                config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));
                       
                                //初始化JedisPool
                                jedisPool = new JedisPool(config,pro.getProperty("host"),Integer.parseInt(pro.getProperty("port")));
}
  /**
                             * 获取连接方法
                             */
                            public static Jedis getJedis(){
                                return jedisPool.getResource();
                            }
                        }
分享至 : QQ空间
收藏

0 个回复

您需要登录后才可以回帖 登录 | 加入黑马