实例代码:
package com.bijian.study; import java.util.ArrayList; import java.util.List; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import redis.clients.jedis.JedisShardInfo; import redis.clients.jedis.ShardedJedis; import redis.clients.jedis.ShardedJedisPool; public class TestPool { private Jedis jedis; private JedisPool jedisPool; private ShardedJedis shardedJedis; private ShardedJedisPool shardedJedisPool; public TestPool() { initialPool(); initialShardedPool(); shardedJedis = shardedJedisPool.getResource(); jedis = jedisPool.getResource(); } private void initialPool() { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxActive(20); config.setMaxIdle(5); config.setMaxWait(1000); config.setTestOnBorrow(false); jedisPool = new JedisPool(config, "192.168.128.129", 6379); } private void initialShardedPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxActive(20); config.setMaxIdle(5); config.setMaxWait(1000l); config.setTestOnBorrow(false); // slave链接 List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>(); shards.add(new JedisShardInfo("192.168.128.129", 6379, "master")); // 构造池 shardedJedisPool = new ShardedJedisPool(config, shards); } public static void main(String[] args) { new TestPool().show(); } public void show() { testKey(); testString(); testList(); testSet(); testSortedSet(); shardedJedisPool.returnResource(shardedJedis); jedisPool.returnResource(jedis);// add by lhs } private void testKey() { System.out.println("=============key=========================="); // 清空数据 System.out.println(jedis.flushDB());//OK System.out.println(jedis.echo("foo"));//foo // 判断key否存在 System.out.println(shardedJedis.exists("foo"));//false shardedJedis.set("key", "values"); System.out.println(shardedJedis.exists("key"));//true } private void testString() { System.out.println("=============String=========================="); // 清空数据 System.out.println(jedis.flushDB());//OK // 存储数据 shardedJedis.set("foo", "bar"); System.out.println(shardedJedis.get("foo"));//bar // 若key不存在,则存储 shardedJedis.setnx("foo", "foo not exits"); System.out.println(shardedJedis.get("foo"));//bar // 覆盖数据 shardedJedis.set("foo", "foo update"); System.out.println(shardedJedis.get("foo"));//foo update // 追加数据 shardedJedis.append("foo", " hello, world"); System.out.println(shardedJedis.get("foo"));//foo update hello, world // 设置key的有效期,并存储数据 shardedJedis.setex("foo", 2, "foo not exits"); System.out.println(shardedJedis.get("foo"));//foo not exits try { Thread.sleep(3000); } catch (InterruptedException e) { } System.out.println(shardedJedis.get("foo"));//null // 获取并更改数据 shardedJedis.set("foo", "foo update"); System.out.println(shardedJedis.getSet("foo", "foo modify"));//foo update // 截取value的值 System.out.println(shardedJedis.getrange("foo", 1, 3));//oo System.out.println(jedis.mset("mset1", "mvalue1", "mset2", "mvalue2", "mset3", "mvalue3", "mset4", "mvalue4"));//OK System.out.println(jedis.mget("mset1", "mset2", "mset3", "mset4"));//[mvalue1,mvalue2,mvalue3,mvalue4] System.out.println(jedis.del(new String[] { "foo", "foo1", "foo3" }));//1 } private void testList() { System.out.println("=============list=========================="); // 清空数据 System.out.println(jedis.flushDB());//OK // 添加数据 shardedJedis.lpush("lists", "80"); shardedJedis.lpush("lists", "75"); shardedJedis.lpush("lists", "100"); // 数组长度 System.out.println(shardedJedis.llen("lists"));//3 // 排序 System.out.println(shardedJedis.sort("lists"));//[75,80,100] // 字串 System.out.println(shardedJedis.lrange("lists", 0, 3));//[100,75,80] // 修改列表中单个值 shardedJedis.lset("lists", 0, "hello list!"); // 获取列表指定下标的值 System.out.println(shardedJedis.lindex("lists", 1));//75 // 删除列表指定下标的值 System.out.println(shardedJedis.lrem("lists", 1, "80"));//1 // 删除区间以外的数据[保留指定key的值范围内的数据] System.out.println(shardedJedis.ltrim("lists", 0, 1));//OK // 列表出栈 System.out.println(shardedJedis.lpop("lists"));//hello list! // 整个列表值 System.out.println(shardedJedis.lrange("lists", 0, -1));//[75] } private void testSet() { System.out.println("=============set=========================="); // 清空数据 System.out.println(jedis.flushDB());//OK // 添加数据 shardedJedis.sadd("sets", "HashSet"); shardedJedis.sadd("sets", "SortedSet"); shardedJedis.sadd("sets", "TreeSet"); // 判断value是否在列表中 System.out.println(shardedJedis.sismember("sets", "TreeSet"));//true // 整个列表值 System.out.println(shardedJedis.smembers("sets"));//[SortedSet, TreeSet, HashSet] // 删除指定元素 System.out.println(shardedJedis.srem("sets", "SortedSet"));//1 // 出栈 System.out.println(shardedJedis.spop("sets"));//TreeSet System.out.println(shardedJedis.smembers("sets"));//[HashSet] shardedJedis.sadd("sets1", "HashSet1"); shardedJedis.sadd("sets1", "SortedSet1"); shardedJedis.sadd("sets1", "TreeSet"); shardedJedis.sadd("sets2", "HashSet2"); shardedJedis.sadd("sets2", "SortedSet1"); shardedJedis.sadd("sets2", "TreeSet1"); // 交集 System.out.println(jedis.sinter("sets1", "sets2"));//[SortedSet1] // 并集 System.out.println(jedis.sunion("sets1", "sets2"));//[HashSet2, HashSet1, TreeSet1, SortedSet1, TreeSet] // 差集 System.out.println(jedis.sdiff("sets1", "sets2"));//[TreeSet, HashSet1] } private void testSortedSet() { System.out.println("=============zset=========================="); // 清空数据 System.out.println(jedis.flushDB());//OK // 添加数据 shardedJedis.zadd("zset", 10.1, "hello"); shardedJedis.zadd("zset", 10.0, ":"); shardedJedis.zadd("zset", 9.0, "zset"); shardedJedis.zadd("zset", 11.0, "zset!"); // 元素个数 System.out.println(shardedJedis.zcard("zset"));//4 // 元素下标 System.out.println(shardedJedis.zscore("zset", "zset"));//9.0 // 集合子集 System.out.println(shardedJedis.zrange("zset", 0, -1));//[zset, :, hello, zset!] // 删除元素 System.out.println(shardedJedis.zrem("zset", "zset!"));//1 // 返回集合中score在给定区间的数量 System.out.println(shardedJedis.zcount("zset", 9.5, 10.5));//2 // 整个集合值 System.out.println(shardedJedis.zrange("zset", 0, -1));//[zset, :, hello] } }
运行结果:
=============key========================== OK foo false true =============String========================== OK bar bar foo update foo update hello, world foo not exits null foo update oo OK [mvalue1, mvalue2, mvalue3, mvalue4] 1 =============list========================== OK 3 [75, 80, 100] [100, 75, 80] 75 1 OK hello list! [75] =============set========================== OK true [SortedSet, TreeSet, HashSet] 1 TreeSet [HashSet] [SortedSet1] [HashSet2, HashSet1, TreeSet1, SortedSet1, TreeSet] [TreeSet, HashSet1] =============zset========================== OK 4 9.0 [zset, :, hello, zset!] 1 2 [zset, :, hello]
PS:如上实例是基于jedis-2.0.0.jar、commons-pool-1.6.jar运行的。
文章来源:http://blog.sina.com.cn/s/blog_5d97745a01018gsh.html
相关推荐
Spring mvc整合redis实例(redis连接池) 将所有jedis 增删改进行事务的封装、查询单独做为有返回参数的封装。简化了很多代码
创建jedis池配置实例,redis各种crud方法,包括使用主从同步,读写分离。工具类中包括存放hash表键值对,键值对以map的方式储存,删除键值对,永久存放键值对,设置过期时间,需要的直接去gitHab上看...
实例化 Jedis 连接池: JedisPool pool = new JedisPool("localhost", 6379); 以下是如何在try-with-resources块中运行单个SET命令: try (Jedis jedis = pool.getResource()) { jedis.set("clientName", "Jedis")...
主要介绍了Jedis出现connection timeout问题解决方法,使用Jedis的JedisPool连接池解决了这个问题,需要的朋友可以参考下
redis工具类,初始化Redis连接池,获取Jedis实例,释放jedis资源
// 创建连接池的配置对象 JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxIdle(Integer.parseInt(pro.get("redis.maxIdle").toString()));// 最大闲置个数。只要超过30个闲置的,就开始关...
JedisTest JAVA实例eclipse项目 一个在 eclipse建的使用Jedis访问Redis的例子。 包括简单的连接,使用common-pool连接池、使用Spring整合。
分为两个部分: 1.获取连接池.创建redis实例 2.字符串、哈希、列表、集合、有序集合、HyperLogLog、发布与订阅这部分操作文档 详解,运行方法可见结果~
在不同的线程中使用相同的Jedis实例会...为了避免这些问题,可以使用是一个线程安全的网络连接池。可以用JedisPool创建一些可靠Jedis实例,可以从池中拿到Jedis的实例。 这种方式可以解决那些问题并且会实现高效的性能
Java-web旅游项目实战案例(四个)IDEA项目源码; 4 技术选型 4.1 Web层 a) Servlet:前端控制器 ...c) Filter:过滤器 d) BeanUtils:数据封装 ...j) Druid:数据库连接池 k) JdbcTemplate:jdbc的工具
利用JedisPool的池化技术,将对应的链接封装到地图中,可以自由根据DB取用,执行对应的redis命令,执行完毕会自动释放链接回到连接池。 约会依赖 <groupId>com.alidaodao.app</groupId> <artifactId>alidaodao-...
技术选型 Web层 Servlet:前端控制器 ...Filter:过滤器 BeanUtils:数据封装 Jackson:json序列化工具 Service层 Javamail:java发送邮件工具 Redis:nosql内存数据库 ...Druid:数据库连接池 JdbcTemplate:jdbc的工具