Redis客户端API操作 Jedis的八种调用方式详解

亦凉 2022-07-12 05:29 140阅读 0赞

package com.blogchong.example.nosqlclient;
     
    import java.util.Arrays;
    import java.util.List;
    import org.junit.AfterClass;
    import org.junit.BeforeClass;
    import org.junit.Test;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPoolConfig;
    import redis.clients.jedis.JedisShardInfo;
    import redis.clients.jedis.Pipeline;
    import redis.clients.jedis.ShardedJedis;
    import redis.clients.jedis.ShardedJedisPipeline;
    import redis.clients.jedis.ShardedJedisPool;
    import redis.clients.jedis.Transaction;
    import org.junit.FixMethodOrder;
    import org.junit.runners.MethodSorters;
     
    /**
     * @author: blogchong
     * @E-mail: blogchong@163.com
     * @blog：   http://www.blogchong.com
     * @Version:1.0
     * @weixin：博客虫(ID:blogchong)
     * @CreateTime：2015年5月1日 下午4:13:14
     * @Description: jedis的8种调用方式
     */
     
    @FixMethodOrder(MethodSorters.NAME_ASCENDING)
    public class TestJedis {
     
        private static Jedis jedis;
        private static ShardedJedis sharding;
        private static ShardedJedisPool pool;
     
        @BeforeClass
        public static void setUpBeforeClass() throws Exception {
            List<JedisShardInfo> shards = Arrays.asList(
                    new JedisShardInfo("localhost",6379),
                    new JedisShardInfo("localhost",6379)); //使用相同的ip:port,仅作测试
     
     
            jedis = new Jedis("localhost"); 
            sharding = new ShardedJedis(shards);
     
            pool = new ShardedJedisPool(new JedisPoolConfig(), shards);
        }
     
        @AfterClass
        public static void tearDownAfterClass() throws Exception {
            jedis.disconnect();
            sharding.disconnect();
            pool.destroy();
        }
     
        @Test
        public void jedisNormal() {
            long start = System.currentTimeMillis();
            for (int i = 0; i < 100000; i++) {
                String result = jedis.set("n" + i, "n" + i);
            }
            long end = System.currentTimeMillis();
            System.out.println("Simple SET: " + ((end - start)/1000.0) + " seconds");
        }
     
        @Test
        public void jedisTrans() {
            long start = System.currentTimeMillis();
            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();
            long end = System.currentTimeMillis();
            System.out.println("Transaction SET: " + ((end - start)/1000.0) + " seconds");
        }
     
        @Test
        public void jedisPipelined() {
            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();
            long end = System.currentTimeMillis();
            System.out.println("Pipelined SET: " + ((end - start)/1000.0) + " seconds");
        }
     
        @Test
        public void jedisCombPipelineTrans() {
            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");
        }
     
        @Test
        public void jedisShardNormal() {
            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");
        }
     
        @Test
        public void jedisShardpipelined() {
            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");
        }
     
        @Test
        public void jedisShardSimplePool() {
            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");
        }
     
        @Test
        public void jedisShardPipelinedPool() {
            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");
        }
    }