redis java 相关api
2017-11-09 11:36
183 查看
转自:http://www.blogchong.com/?act=view&id=63&mod=pad
Redis Java API操作实例
Redis的API操作实例,其使用类似类似于普通数据库操作,先进行redis客户端的链接,然后进行相应的类似增删改查操作,相关API接口与命令行命令基本是一一对应的。
进行实例操作前,先在maven中添加依赖(我把source包也添加进去了,只是为了查看源码),需要注意的是pool也需要添加,如下:
代码如下,包括了连接客户端,初始化连接池,set操作,get操作等等。
Redis Java API操作实例
Redis的API操作实例,其使用类似类似于普通数据库操作,先进行redis客户端的链接,然后进行相应的类似增删改查操作,相关API接口与命令行命令基本是一一对应的。
进行实例操作前,先在maven中添加依赖(我把source包也添加进去了,只是为了查看源码),需要注意的是pool也需要添加,如下:
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.5.2</version> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.5.2</version> <classifier>sources</classifier> </dependency> <dependency> <groupId>commons-pool</groupId> <artifactId>commons-pool</artifactId> <version>1.6</version> </dependency>
代码如下,包括了连接客户端,初始化连接池,set操作,get操作等等。
package com.blogchong.mite.util; 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; /** * @author: blogchong * @Blog: http://www.blogchong.com * @email: blogchong@gmail.com * @QQ_G: 191321336 * @version: 2014年12月21日 下午10:05:02 * @Des:Redis的java操作实例 */ public class OptRedis { // 非切片客户端链接对象 private Jedis jedis; // 非切片链接池对象 private JedisPool jedisPool; // 切片客户端链接对象 private ShardedJedis shardedJedis; // 切片链接池 private ShardedJedisPool shardedJedisPool; // IP以及端口 private String ip = "192.168.4.201"; private int port = 6379; // 构造函数,完成客户端连接的工作 public OptRedis() { initialPool(); initialShardedPool(); shardedJedis = shardedJedisPool.getResource(); jedis = jedisPool.getResource(); } private void initialPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(20); config.setMaxIdle(5); config.setMaxWaitMillis(1000l); config.setTestOnBorrow(false); jedisPool = new JedisPool(config, ip, port); } // 初始化切片池 private void initialShardedPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(20); config.setMaxIdle(5); config.setMaxWaitMillis(1000l); config.setTestOnBorrow(false); // slave链接 List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>(); shards.add(new JedisShardInfo(ip, 6379, "master")); // 构造池 shardedJedisPool = new ShardedJedisPool(config, shards); } public void show() { // key检测 testKey(); // string检测 testString(); // list检测 testList(); // set检测 testSet(); // sortedSet检测 testSortedSet(); // hash检测 testHash(); shardedJedisPool.returnResource(shardedJedis); } private void testKey() { System.out.println("=============Test key=========================="); // 清空数据 System.out.println(jedis.flushDB()); System.out.println(jedis.echo("foo")); // 判断key否存在 System.out.println(shardedJedis.exists("foo")); shardedJedis.set("key", "values"); System.out.println(shardedJedis.exists("key")); 100fd } private void testString() { System.out.println("=============Set Value========================"); // 清空数据 System.out.println(jedis.flushDB()); // 存储数据 shardedJedis.set("foo", "bar"); System.out.println(shardedJedis.get("foo")); // 若key不存在,则存储 shardedJedis.setnx("foo", "foo not exits"); System.out.println(shardedJedis.get("foo")); // 覆盖数据 shardedJedis.set("foo", "foo update"); System.out.println(shardedJedis.get("foo")); // 追加数据 shardedJedis.append("foo", " hello, world"); System.out.println(shardedJedis.get("foo")); // 设置key的有效期,并存储数据 shardedJedis.setex("foo", 2, "foo not exits"); System.out.println(shardedJedis.get("foo")); try { Thread.sleep(3000); } catch (InterruptedException e) { } System.out.println(shardedJedis.get("foo")); // 获取并更改数据 shardedJedis.set("foo", "foo update"); System.out.println(shardedJedis.getSet("foo", "foo modify")); // 截取value的值 System.out.println(shardedJedis.getrange("foo", 1, 3)); System.out.println(jedis.mset("mset1", "mvalue1", "mset2", "mvalue2", "mset3", "mvalue3", "mset4", "mvalue4")); System.out.println(jedis.mget("mset1", "mset2", "mset3", "mset4")); System.out.println(jedis.del(new String[] { "foo", "foo1", "foo3" })); } private void testList() { System.out.println("=============Test list=========================="); // 清空数据 System.out.println(jedis.flushDB()); // 添加数据 shardedJedis.lpush("lists", "vector"); shardedJedis.lpush("lists", "ArrayList"); shardedJedis.lpush("lists", "LinkedList"); // 数组长度 System.out.println(shardedJedis.llen("lists")); // 排序 // System.out.println(shardedJedis.sort("lists")); // 字串 System.out.println(shardedJedis.lrange("lists", 0, 3)); // 修改列表中单个值 shardedJedis.lset("lists", 0, "hello list!"); // 获取列表指定下标的值 System.out.println(shardedJedis.lindex("lists", 1)); // 删除列表指定下标的值 System.out.println(shardedJedis.lrem("lists", 1, "vector")); // 删除区间以外的数据 System.out.println(shardedJedis.ltrim("lists", 0, 1)); // 列表出栈 System.out.println(shardedJedis.lpop("lists")); // 整个列表值 System.out.println(shardedJedis.lrange("lists", 0, -1)); } private void testSet() { System.out.println("=============Test Set=========================="); // 清空数据 System.out.println(jedis.flushDB()); // 添加数据 shardedJedis.sadd("sets", "HashSet"); shardedJedis.sadd("sets", "SortedSet"); shardedJedis.sadd("sets", "TreeSet"); // 判断value是否在列表中 System.out.println(shardedJedis.sismember("sets", "TreeSet")); // 整个列表值 System.out.println(shardedJedis.smembers("sets")); // 删除指定元素 System.out.println(shardedJedis.srem("sets", "SortedSet")); // 出栈 System.out.println(shardedJedis.spop("sets")); System.out.println(shardedJedis.smembers("sets")); // 进行sadd操作 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")); // 并集 System.out.println(jedis.sunion("sets1", "sets2")); // 差集 System.out.println(jedis.sdiff("sets1", "sets2")); } private void testSortedSet() { System.out.println("=============Test Zset=========================="); // 清空数据 System.out.println(jedis.flushDB()); // 添加数据 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")); // 元素下标 System.out.println(shardedJedis.zscore("zset", "zset")); // 集合子集 System.out.println(shardedJedis.zrange("zset", 0, -1)); // 删除元素 System.out.println(shardedJedis.zrem("zset", "zset!")); System.out.println(shardedJedis.zcount("zset", 9.5, 10.5)); // 整个集合值 System.out.println(shardedJedis.zrange("zset", 0, -1)); } private void testHash() { System.out.println("=============Test Hash=========================="); // 清空数据 System.out.println(jedis.flushDB()); // 添加数据 shardedJedis.hset("hashs", "entryKey", "entryValue"); shardedJedis.hset("hashs", "entryKey1", "entryValue1"); shardedJedis.hset("hashs", "entryKey2", "entryValue2"); // 判断某个值是否存在 System.out.println(shardedJedis.hexists("hashs", "entryKey")); // 获取指定的值 System.out.println(shardedJedis.hget("hashs", "entryKey")); // 批量获取指定的值 System.out .println(shardedJedis.hmget("hashs", "entryKey", "entryKey1")); // 删除指定的值 System.out.println(shardedJedis.hdel("hashs", "entryKey")); // 为key中的域 field 的值加上增量 increment System.out.println(shardedJedis.hincrBy("hashs", "entryKey", 123456)); // 获取所有的keys System.out.println(shardedJedis.hkeys("hashs")); // 获取所有的values System.out.println(shardedJedis.hvals("hashs")); } // 测试主类 public static void main(String[] args) { new OptRedis().show(); } }
相关文章推荐
- redis java 相关api
- VS C# WebApi 发布,部署到IIS上及数据库权限相关问题
- Hibernate基础学习(二)—Hibernate相关API介绍
- FFMPEG Filter相关API
- Spark SQL原理与DataFrame、DataSet相关API操作以及代码介绍
- 淘宝API开发系列-淘宝API相关了解
- 自定义相关api探究:
- windows 内存分配尝试(AWE相关API编译器没找到库,所以全部注释)
- QC API相关对象模型
- Win32路径操作相关API
- WeX5之xid相关API
- 原生 JS 中对象相关 API 合集
- 跟ini文件相关的api
- ES技术团队划重点 | ES5.X,你必须知道的API和相关技巧
- AutoLayout以来UIView和UIViewController新增的相关API
- objc 并发编程的相关API
- Symbian编程总结-文件、流与数据库-文件系统及相关API
- S3C24XX体系的Linux GPIO控制相关API实现
- Kobject Kset 解释 已及 相关注册函数API
- 2卷积神经网络相关API详解-2.3/2.4TensorFlow之激活函数API详解(上/下)