Redis入门学习
2016-05-16 16:37
781 查看
一、摘要
二、五种数据类型的基本命令操作
三、Redis连接池
四、普通同步方式
五、事务方式(Transactions)
六、管道(Pipelining)
七、管道中调用事务
八、分布式直连同步调用
九、分布式直连异步管道调用
十、分布式连接池同步调用
十一、分布式连接池异步调用
十二、需要注意的地方
一、摘要:
Redis是一个著名的key-value存储系统,而作为其官方推荐的java版客户端jedis也非常强大和稳定,支持事务、管道及有jedis自身实现的分布式。
二、五种数据类型的基本命令操作:
三、Redis连接池
四、普通同步方式
最简单和基础的调用方式:
五、事务方式(Transactions)
redis的事务很简单,他主要目的是保障,一个client发起的事务中的命令可以连续的执行,而中间不会插入其他client的命令。一般情况下 redis 在接受到一个 client 发来的命令后会立即处理并返回处理结果,但是当一个 client在一个连接中发 multi命令,这个连接会进入一个事务上下文,该连接后续的命令并不是立即执行,而是先放到一个队列中。当从此连接受到 exec 命令后,redis会顺序的执行队列中的所有命令。并将所有命令的运行结果打包到一起返回给 client.然后此连接就结束事务上下文。
示例1说明,只要提交事务了,不管事务中的命令执行成功与否都会执行,即使有命令执行错误,也不会在java中抛出异常。其中tx.lset("mylist", 10, "world");的处理结果是错误的,但是其后边的命令继续执行。
我们调用jedis.watch(…)方法来监控key,如果调用后key值发生变化,则整个事务会执行失败。另外,事务中某个操作失败,并不会回滚其他操作。这一点需要注意。还有,我们可以使用discard()方法来取消事务。
六、管道(Pipelining)
有时,我们需要采用异步方式,一次发送多个指令,不同步等待其返回结果。批量发送请求,减少网络通信时间,最后将多条命令的执行结果打包返回给客户端。
七、管道中调用事务
但是经测试(见本文后续部分),发现其效率和单独使用事务差不多,甚至还略微差点。
八、分布式直连同步调用
这个是分布式直接连接,并且是同步调用,每步执行都返回执行结果。类似地,还有异步管道调用。
九、分布式直连异步管道调用
十、分布式连接池同步调用
如果,你的分布式调用代码是运行在线程中,那么上面两个直连调用方式就不合适了,因为直连方式是非线程安全的,这个时候,你就必须选择连接池调用。
十一、分布式连接池异步调用
十二、需要注意的地方
1.事务和管道都是异步模式。在事务和管道中不能同步查询结果。比如下面两个调用,都是不允许的:
2. 事务和管道都是异步的,个人感觉,在管道中再进行事务调用,没有必要,不如直接进行事务模式。
3. 分布式中,连接池的性能比直连的性能略好(见后续测试部分)。
4.分布式调用中不支持事务。因为事务是在服务器端实现,而在分布式中,每批次的调用对象都可能访问不同的机器,所以没法进行事务。
参考文章:
1.http://my.oschina.net/sphl520/blog/312514#OSC_h3_3
2.http://www.cnblogs.com/liuling/p/2014-4-19-04.html
3.Redis实战《红丸出品》
4.http://www.2cto.com/kf/201504/395403.html
二、五种数据类型的基本命令操作
三、Redis连接池
四、普通同步方式
五、事务方式(Transactions)
六、管道(Pipelining)
七、管道中调用事务
八、分布式直连同步调用
九、分布式直连异步管道调用
十、分布式连接池同步调用
十一、分布式连接池异步调用
十二、需要注意的地方
一、摘要:
Redis是一个著名的key-value存储系统,而作为其官方推荐的java版客户端jedis也非常强大和稳定,支持事务、管道及有jedis自身实现的分布式。
二、五种数据类型的基本命令操作:
package sy.test; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import org.junit.Before; import org.junit.Test; import redis.clients.jedis.Jedis; import sy.util.RedisUtil; public class TestJedis { private Jedis jedis; @Before public void setUp() throws Exception { //连接redis服务器,192.168.0.100:6379 jedis = new Jedis("192.168.0.16", 6379); //登陆权限认证 jedis.auth("123456"); } /** * redis存储字符串 */ @Test public void testString() { jedis.set("name", "itme"); System.out.println(jedis.get("name")); jedis.append("name", " is my lover"); //拼接 System.out.println(jedis.get("name")); //删除某个键 jedis.del("name"); System.out.println(jedis.get("name")); //添加多个键值对 jedis.mset("name","mset","age","25","qq","123456"); System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq")); //自增1操作 jedis.incr("age"); System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq")); //关闭jedis连接 jedis.disconnect(); } /** * 操作map */ @Test public void testMap(){ //添加数据 Map<String, String> map = new HashMap<String,String>(); map.put("name", "xinxin"); map.put("age", "22"); map.put("qq", "123456"); jedis.hmset("user", map); List<String> list = jedis.hmget("user", "name","age","qq"); System.out.println(list); //删除数据 jedis.hdel("user", "name"); System.out.println(jedis.hmget("user", "age")); //因为删除了,所以返回的是null System.out.println(jedis.hlen("user")); //返回key为user的键中存放的值的个数2 System.out.println(jedis.exists("user"));//是否存在key为user的记录 返回true System.out.println(jedis.hkeys("user"));//返回map对象中的所有key System.out.println(jedis.hvals("user"));//返回map对象中的所有value Iterator<String> iter=jedis.hkeys("user").iterator(); while (iter.hasNext()){ String key = iter.next(); System.out.println(key+":"+jedis.hmget("user",key)); } //关闭jedis连接 jedis.disconnect(); } /** * 操作List * 底层是双向链表 */ @Test public void testList(){ //开始前,先移除所有的内容 jedis.del("java framework"); System.out.println(jedis.lrange("java framework",0,-1)); //先向key java framework中存放三条数据 jedis.lpush("java framework","spring"); jedis.lpush("java framework","struts"); jedis.lpush("java framework","hibernate"); //再取出所有数据jedis.lrange是按范围取出, // 第一个是key,第二个是起始位置,第三个是结束位置,jedis.llen获取长度 -1表示取得所有 System.out.println(jedis.lrange("java framework",0,-1)); jedis.del("java framework"); jedis.rpush("java framework","spring"); jedis.rpush("java framework","struts"); jedis.rpush("java framework","hibernate"); System.out.println(jedis.lrange("java framework",0,-1)); //关闭jedis连接 jedis.disconnect(); } /** * jedis操作set */ @Test public void testSet(){ //添加 jedis.sadd("user1","liuling"); jedis.sadd("user1","xinxin"); jedis.sadd("user1","ling"); jedis.sadd("user1","zhangxinxin"); jedis.sadd("user1","who"); //移除noname jedis.srem("user1","who"); System.out.println(jedis.smembers("user1"));//获取所有加入的value System.out.println(jedis.sismember("user1", "who"));//判断 who 是否是user集合的元素 System.out.println(jedis.srandmember("user1")); System.out.println(jedis.scard("user1"));//返回集合的元素个数 //关闭jedis连接 jedis.disconnect(); } @Test public void testSortList(){ //jedis 排序 //注意,此处的rpush和lpush是List的操作。是一个双向链表(但从表现来看的) jedis.del("a");//先清除数据,再加入数据进行测试 jedis.rpush("a", "1"); jedis.lpush("a","6"); jedis.lpush("a","3"); jedis.lpush("a","9"); System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1] //输入排序后结果 不影响原来的顺序。 System.out.println(jedis.sort("a")); //[1, 3, 6, 9] System.out.println(jedis.lrange("a",0,-1)); //关闭jedis jedis.disconnect(); } @Test public void testRedisPool(){ RedisUtil.getJedis().set("newname", "中文测试"); System.out.println(RedisUtil.getJedis().get("newname")); } }
三、Redis连接池
package sy.util; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public final class RedisUtil { //Redis服务器IP private static String ADDR = "192.168.0.16"; //Redis的端口号 private static int PORT = 6379; //访问密码 private static String AUTH = "123456"; //可用连接实例的最大数目,默认值为8; //如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。 private static int MAX_ACTIVE = 1024; //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。 private static int MAX_IDLE = 200; //等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException; private static int MAX_WAIT = 10000; private static int TIMEOUT = 10000; //在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的; private static boolean TEST_ON_BORROW = true; private static JedisPool jedisPool = null; /** * 初始化Redis连接池 */ static { try { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(MAX_ACTIVE); config.setMaxIdle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT); config.setTestOnBorrow(TEST_ON_BORROW); jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH); } catch (Exception e) { e.printStackTrace(); } } /** * 获取Jedis实例 * @return */ public synchronized static Jedis getJedis() { try { if (jedisPool != null) { Jedis resource = jedisPool.getResource(); return resource; } else { return null; } } catch (Exception e) { e.printStackTrace(); return null; } } /** * 释放jedis资源 * @param jedis */ public static void returnResource(final Jedis jedis) { if (jedis != null) { jedisPool.returnResource(jedis); } } }
四、普通同步方式
最简单和基础的调用方式:
/** * jedis redis普通同步方式 */ @Test public void testNormal(){ Jedis jedis = RedisUtil.getJedis(); long start = System.currentTimeMillis(); for(int i=0;i<10000;i++){ jedis.set("n" + i, "n" + i); } long end = System.currentTimeMillis(); System.out.println("Simple set" + ((end-start)/1000.0) + " seconds"); }
五、事务方式(Transactions)
redis的事务很简单,他主要目的是保障,一个client发起的事务中的命令可以连续的执行,而中间不会插入其他client的命令。一般情况下 redis 在接受到一个 client 发来的命令后会立即处理并返回处理结果,但是当一个 client在一个连接中发 multi命令,这个连接会进入一个事务上下文,该连接后续的命令并不是立即执行,而是先放到一个队列中。当从此连接受到 exec 命令后,redis会顺序的执行队列中的所有命令。并将所有命令的运行结果打包到一起返回给 client.然后此连接就结束事务上下文。
@Test public void testTransaction1(){ Jedis jedis = RedisUtil.getJedis(); long start = System.currentTimeMillis(); jedis.flushDB(); jedis.lpush("mylist", "hello"); //开启事务 Transaction tx = jedis.multi(); tx.set("testtran1", "testtran1"); tx.lset("mylist", 10, "world"); tx.set("testtran1-1", "testtran1-1"); //提交事务 List<Object> results = tx.exec(); long end = System.currentTimeMillis(); System.out.println(jedis.get("testtran1")); System.out.println(jedis.lrange("mylist", 0, -1)); System.out.println(jedis.get("testtran1-1")); System.out.println("Test Transaction1 " + ((end-start)/1000.0) + " seconds"); jedis.disconnect(); } @Test public void testTransaction2(){ Jedis jedis = RedisUtil.getJedis(); long start = System.currentTimeMillis(); jedis.flushDB(); jedis.set("testtran2", "testtran2"); jedis.set("testtran2-1", "testtran2-1"); //开启事务 Transaction tx = jedis.multi(); tx.set("testtran2", "testtran2_new"); tx.set("testtran2-1", "testtran2-1_new"); //回滚事务 tx.discard(); long end = System.currentTimeMillis(); System.out.println(jedis.get("testtran2")); System.out.println(jedis.get("testtran2-1")); System.out.println("Test Transaction2 " + ((end-start)/1000.0) + " seconds"); jedis.disconnect(); }
示例1说明,只要提交事务了,不管事务中的命令执行成功与否都会执行,即使有命令执行错误,也不会在java中抛出异常。其中tx.lset("mylist", 10, "world");的处理结果是错误的,但是其后边的命令继续执行。
我们调用jedis.watch(…)方法来监控key,如果调用后key值发生变化,则整个事务会执行失败。另外,事务中某个操作失败,并不会回滚其他操作。这一点需要注意。还有,我们可以使用discard()方法来取消事务。
六、管道(Pipelining)
有时,我们需要采用异步方式,一次发送多个指令,不同步等待其返回结果。批量发送请求,减少网络通信时间,最后将多条命令的执行结果打包返回给客户端。
/** * 管道pipeline */ @Test public void testPipeline(){ Jedis jedis = RedisUtil.getJedis(); jedis.flushDB(); //使用管道的方式 Pipeline pipeline = jedis.pipelined(); long start1 = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { pipeline.set("pipeline" + i, "pipeline" + i); } long end1 = System.currentTimeMillis(); System.out.println("使用Pipeline的方式 " + ((end1-start1)/1000.0) + " seconds"); //普通方式 long start2 = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { pipeline.set("normal" + i, "normal" + i); } long end2 = System.currentTimeMillis(); System.out.println("普通方式 " + ((end2-start2)/1000.0) + " seconds"); }
七、管道中调用事务
@Test public void test4combPipelineTrans() { jedis = new Jedis("192.168.0.16", 6379);long start = System.currentTimeMillis(); Pipeline pipeline = jedis.pipelined(); pipeline.multi(); for (int i = 0; i < 100000; i++) { pipeline.set("" + i, "" + i); } pipeline.exec(); List<Object> results = pipeline.syncAndReturnAll(); long end = System.currentTimeMillis(); System.out.println("Pipelined transaction: " + ((end - start)/1000.0) + " seconds"); jedis.disconnect(); }
但是经测试(见本文后续部分),发现其效率和单独使用事务差不多,甚至还略微差点。
八、分布式直连同步调用
@Test public void test5shardNormal() { List<JedisShardInfo> shards = Arrays.asList( new JedisShardInfo("localhost",6379), new JedisShardInfo("localhost",6380)); ShardedJedis sharding = new ShardedJedis(shards); long start = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { String result = sharding.set("sn" + i, "n" + i); } long end = System.currentTimeMillis(); System.out.println("Simple@Sharing SET: " + ((end - start)/1000.0) + " seconds"); sharding.disconnect(); }
这个是分布式直接连接,并且是同步调用,每步执行都返回执行结果。类似地,还有异步管道调用。
九、分布式直连异步管道调用
@Test public void test6shardpipelined() { List<JedisShardInfo> shards = Arrays.asList( new JedisShardInfo("localhost",6379), new JedisShardInfo("localhost",6380)); ShardedJedis sharding = new ShardedJedis(shards); ShardedJedisPipeline pipeline = sharding.pipelined(); long start = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { pipeline.set("sp" + i, "p" + i); } List<Object> results = pipeline.syncAndReturnAll(); long end = System.currentTimeMillis(); System.out.println("Pipelined@Sharing SET: " + ((end - start)/1000.0) + " seconds"); sharding.disconnect(); }
十、分布式连接池同步调用
如果,你的分布式调用代码是运行在线程中,那么上面两个直连调用方式就不合适了,因为直连方式是非线程安全的,这个时候,你就必须选择连接池调用。
@Test public void test7shardSimplePool() { List<JedisShardInfo> shards = Arrays.asList( new JedisShardInfo("localhost",6379), new JedisShardInfo("localhost",6380)); ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards); ShardedJedis one = pool.getResource(); long start = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { String result = one.set("spn" + i, "n" + i); } long end = System.currentTimeMillis(); pool.returnResource(one); System.out.println("Simple@Pool SET: " + ((end - start)/1000.0) + " seconds"); pool.destroy(); }
十一、分布式连接池异步调用
@Test public void test8shardPipelinedPool() { List<JedisShardInfo> shards = Arrays.asList( new JedisShardInfo("localhost",6379), new JedisShardInfo("localhost",6380)); ShardedJedisPool pool = new ShardedJedisPool(new JedisPoolConfig(), shards); ShardedJedis one = pool.getResource(); ShardedJedisPipeline pipeline = one.pipelined(); long start = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { pipeline.set("sppn" + i, "n" + i); } List<Object> results = pipeline.syncAndReturnAll(); long end = System.currentTimeMillis(); pool.returnResource(one); System.out.println("Pipelined@Pool SET: " + ((end - start)/1000.0) + " seconds"); pool.destroy(); }
十二、需要注意的地方
1.事务和管道都是异步模式。在事务和管道中不能同步查询结果。比如下面两个调用,都是不允许的:
Transaction tx = jedis.multi(); for (int i = 0; i < 100000; i++) { tx.set("t" + i, "t" + i); } System.out.println(tx.get("t1000").get()); //不允许 List<Object> results = tx.exec(); … … Pipeline pipeline = jedis.pipelined(); long start = System.currentTimeMillis(); for (int i = 0; i < 100000; i++) { pipeline.set("p" + i, "p" + i); } System.out.println(pipeline.get("p1000").get()); //不允许 List<Object> results = pipeline.syncAndReturnAll();
2. 事务和管道都是异步的,个人感觉,在管道中再进行事务调用,没有必要,不如直接进行事务模式。
3. 分布式中,连接池的性能比直连的性能略好(见后续测试部分)。
4.分布式调用中不支持事务。因为事务是在服务器端实现,而在分布式中,每批次的调用对象都可能访问不同的机器,所以没法进行事务。
参考文章:
1.http://my.oschina.net/sphl520/blog/312514#OSC_h3_3
2.http://www.cnblogs.com/liuling/p/2014-4-19-04.html
3.Redis实战《红丸出品》
4.http://www.2cto.com/kf/201504/395403.html
相关文章推荐
- 基于Redis的消息中心缓存搭建
- 在多台服务器上简单实现Redis的数据主从复制
- 【转载】Java中使用Jedis操作Redis
- Redis系列-存储篇sorted set使用小结
- centos下redis的安装
- Redis——java代码读写redis
- Redis——java代码读写redis
- CentOS7安装配置redis-3.0.0
- 30个php操作redis常用方法代码例子
- 使用Jedis 访问redis集群遇到的两个小问题
- linux系统上面安装redis 3.2
- linux安装redis及redis扩展
- 一步完成 MySQL 向 Redis 迁移
- nginx +lua +redis 构建自动缓存系统
- Linux Redis官方API和常用命令
- Redis发布订阅
- Linux redis 3.2环境搭建以及开启启动配置
- Redis开启远程登录连接。
- 6.Redis持久化--主从同步
- 转:Redis使用认证密码登录