首页 > 代码库 > java操作Redis
java操作Redis
需要使用如下jar包
<!-- https://mvnrepository.com/artifact/redis.clients/jedis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.8.1</version> </dependency> <!-- https://mvnrepository.com/artifact/commons-pool/commons-pool --> <dependency> <groupId>commons-pool</groupId> <artifactId>commons-pool</artifactId> <version>1.6</version> </dependency>
1.建立连接池
package com.spring.wzy;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;public class JedisPoolUtil { /** * 双重锁形式的单例 * */ private static volatile JedisPool jedisPool = null; private JedisPoolUtil(){} public static JedisPool getJedisPoolInstance(){ if(null == jedisPool){ synchronized (JedisPoolUtil.class) { if(null == jedisPool){ // GenericObjectPoolConfig poolConfig = new JedisPoolConfig(); JedisPoolConfig poolConfig = new JedisPoolConfig(); // poolConfig.setMaxActive(1000);//最大实例数 poolConfig.setMaxWaitMillis(100*1000);//最大等待时间 poolConfig.setMaxIdle(50);//最多空闲实例 poolConfig.setTestOnBorrow(true);//获得一个实例时检查连接可用性 jedisPool = new JedisPool(poolConfig, "192.168.23.128", 6379); } } } return jedisPool; } public static void release(JedisPool jedisPool, Jedis jedis){ if(null != jedis){ //jedis.close(); jedisPool.returnResourceObject(jedis); } }}
2.使用实例
public static void main(String[] args) throws InterruptedException { JedisPool jedisPool = JedisPoolUtil.getJedisPoolInstance(); Jedis j = null; try{ j = jedisPool.getResource(); // j.select(0);//选中数据库,默认是0号库// j.flushAll();//清空数据库 // j.del("key"); //删除key // j.set("k1", "v1");// j.set("k2", "v2");// j.set("k2", "v3");//新值会把旧值覆盖 // System.out.println(j.exists("k2"));//返回ture/false// System.out.println(j.exists("k1","k3"));//返回存在的个数 // System.out.println(new String(j.get("k1".getBytes())));// System.out.println(j.get("k2")); // Set<String> keys = j.keys("*");// for(String k:keys){// System.out.println(k);// } // j.move("k1", 2);//把k1剪切到2号库 // System.out.println(j.expire("k2", 10));//设置key的存活时间(s),执行成功返回1,否则返回0// Thread.sleep(3000);// System.out.println(j.ttl("k2"));//查看key的过期时间 }catch (Exception e) { e.printStackTrace(); }finally{ JedisPoolUtil.release(jedisPool, j); }
java操作Redis
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。