zoukankan      html  css  js  c++  java
  • Redis:jedis(连接池、工具类)

    1、创建java程序,通过程序实现存取操作

    (1)导入jar包:

     (2)程序:

    import redis.clients.jedis.Jedis;
    public class JedisDemo {
        public void test(){
            Jedis jedis=new Jedis("192.168.204.128",6379);
            jedis.set("河南","郑州");
            String add=jedis.get("河南");
            System.out.println(add);
        }
        public static void main(String[]args){
            JedisDemo jedisDemo=new JedisDemo();
            jedisDemo.test();
        }
    }

    (3)运行结果:

    2、连接池的方式

    (1)代码实现:

    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    public class JedisDemo {
        public void test(){
            //对连接池进行配置
            JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
            jedisPoolConfig.setMaxIdle(30);//最大闲置个数
            jedisPoolConfig.setMinIdle(10);//最小闲置个数
            jedisPoolConfig.setMaxTotal(50);//最大连接数
            //创建一个redis连接池
            JedisPool jedisPool=new JedisPool(jedisPoolConfig,"192.168.204.128",6379);
            //从连接池中获取redis的连接资源
            Jedis jedis=jedisPool.getResource();
            //对数据库进行存取操作
            jedis.set("河南","郑州");
            System.out.println(jedis.get("河南"));
            //释放资源
            jedis.close();
            jedisPool.close();
        }
        public static void main(String[]args){
            JedisDemo jedisDemo=new JedisDemo();
            jedisDemo.test();
        }
    }

    (2)运行结果:

     3、连接池工具类:

    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    public class JedisDemo {
        private static JedisPool jedisPool= null;
            static{
                //对连接池进行配置
                JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
                jedisPoolConfig.setMaxIdle(30);//最大闲置个数
                jedisPoolConfig.setMinIdle(10);//最小闲置个数
                jedisPoolConfig.setMaxTotal(50);//最大连接数
                //创建一个redis连接池
                jedisPool=new JedisPool(jedisPoolConfig,"192.168.204.128",6379);
            }
            public static Jedis getJedis(){//从连接池中获取redis的连接资源
                return jedisPool.getResource();
            }
        public static void main(String[] args){
            Jedis jedis=getJedis();
            String add=jedis.get("河南");
            System.out.println(add);
        }
    }

    4、添加配置文件的工具类:

    (1)配置文件:

    redis.maxIdle=30
    redis.minIdle=10
    redis.maxTotal=50
    redis.url=192.168.204.128
    redis.port=6379

    (2)工具类:

    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.Properties;
    
    public class JedisDemo {
        private static JedisPool jedisPool= null;
            static{
                //读取配置文件
                InputStream inputStream=JedisDemo.class.getClassLoader().getResourceAsStream("redis.properties");
                Properties properties=new Properties();
                try {
                    properties.load(inputStream);
                } catch (IOException e) {
                    e.printStackTrace();
                }
    
                //对连接池进行配置
                JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
                jedisPoolConfig.setMaxIdle(Integer.parseInt(properties.get("redis.maxIdle").toString()));//最大闲置个数
                jedisPoolConfig.setMinIdle(Integer.parseInt(properties.get("redis.minIdle").toString()));//最小闲置个数
                jedisPoolConfig.setMaxTotal(Integer.parseInt(properties.get("redis.maxTotal").toString()));//最大连接数
                //创建一个redis连接池
                jedisPool=new JedisPool(jedisPoolConfig,properties.getProperty("redis.url"),Integer.parseInt(properties.get("redis.port").toString()));
            }
            public static Jedis getJedis(){//从连接池中获取redis的连接资源
                return jedisPool.getResource();
            }
        public static void main(String[] args){
            Jedis jedis=getJedis();
            String add=jedis.get("河南");
            System.out.println(add);
        }
    }

    读取配置文件中的信息,在有关的参数改变时,只需要改变配置文件即可。

  • 相关阅读:
    Azure Bicep(三)变量控制
    FreeRedis分布式锁实现以及使用
    动态表单存储设计
    SixLabors.ImageSharp 实践小结
    你了解一条sql的执行顺序吗
    理解ASP.NET Core
    理解ASP.NET Core
    产品说,我只需要一个有亿点复杂的查询界面
    学习大数据可以考哪些证书(附资料)
    数据治理之元数据管理的利器——Atlas入门宝典
  • 原文地址:https://www.cnblogs.com/zhai1997/p/11725993.html
Copyright © 2011-2022 走看看