redis test

whatsmars-redis/pom.xml

@@ -29,6 +29,18 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-aop</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.11</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
 

whatsmars-redis/src/main/java/com/itlong/whatsmars/redis/client/cluster/Demo.java

-package com.itlong.whatsmars.redis.client.cluster;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.stereotype.Component;
-import redis.clients.jedis.JedisCluster;
-
-/**
- * Created by javahongxi on 2017/6/22.
- */
-@Component
-public class Demo {
-
-    @Autowired
-    @Qualifier("redisClusterClient")
-    private JedisCluster redisClient;
-
-    public void test() {
-        String cacheContent = null;
-        try {
-            cacheContent = redisClient.get("hello_world");
-        } catch (Exception e) {
-            //如果异常，你可以决定是否忽略
-        }
-        if(cacheContent == null) {
-            //如果cache中不存在，或者redis异常
-        }
-    }
-}

whatsmars-redis/src/main/java/com/itlong/whatsmars/redis/client/readwrite/Demo.java

-package com.itlong.whatsmars.redis.client.readwrite;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-/**
- * Created by javahongxi on 2017/6/22.
- */
-@Component
-public class Demo {
-
-    @Autowired
-    private ReadWriteRedisClient redisClient;
-
-    public void test() {
-        String cacheContent = null;
-        try {
-            cacheContent = redisClient.get("hello_world");
-        } catch (Exception e) {
-            //如果异常，你可以决定是否忽略
-        }
-        if(cacheContent == null) {
-            //如果cache中不存在，或者redis异常
-        }
-    }
-}

whatsmars-redis/src/main/java/com/itlong/whatsmars/redis/client/singleton/Demo.java

-package com.itlong.whatsmars.redis.client.singleton;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.stereotype.Component;
-import redis.clients.jedis.Jedis;
-import redis.clients.jedis.JedisPool;
-
-/**
- * Created by javahongxi on 2017/6/22.
- */
-@Component
-public class Demo {
-
-    @Autowired
-    @Qualifier("singletonRedisClient")
-    private JedisPool redisClient;
-
-    public void test() {
-        Jedis jedis = redisClient.getResource();
-        String cacheContent = null;
-        try {
-            cacheContent = jedis.get("hello_world");
-        }finally {
-            redisClient.close();
-        }
-        // 获取redis数据之后，立即释放连接，然后开始进行业务处理
-        if(cacheContent == null) {
-            // DB operation
-        }
-        // ..
-    }
-}

whatsmars-redis/src/test/java/com/itlong/whatsmars/redis/client/Demo.java

+package com.itlong.whatsmars.redis.client;
+
+import com.itlong.whatsmars.redis.client.readwrite.ReadWriteRedisClient;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisCluster;
+import redis.clients.jedis.JedisPool;
+
+/**
+ * Created by javahongxi on 2017/6/23.
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = "classpath:spring-redis.xml")
+public class Demo {
+
+    @Autowired
+    @Qualifier("singletonRedisClient")
+    private JedisPool singletonRedisClient;
+
+    @Autowired
+    private ReadWriteRedisClient readWriteRedisClient;
+
+    @Autowired
+    @Qualifier("redisClusterClient")
+    private JedisCluster jedisCluster;
+
+    @Test
+    public void testSingleton() {
+        Jedis jedis = singletonRedisClient.getResource();
+        String cacheContent = null;
+        try {
+            cacheContent = jedis.get("hello_world");
+        }finally {
+            singletonRedisClient.close();
+        }
+        // 获取redis数据之后，立即释放连接，然后开始进行业务处理
+        if(cacheContent == null) {
+            // DB operation
+        }
+        // ..
+    }
+
+    @Test
+    public void testReadWrite() {
+        String cacheContent = null;
+        try {
+            cacheContent = readWriteRedisClient.get("hello_world");
+        } catch (Exception e) {
+            //如果异常，你可以决定是否忽略
+        }
+        if(cacheContent == null) {
+            //如果cache中不存在，或者redis异常
+        }
+    }
+
+    @Test
+    public void testCluster() {
+        String cacheContent = null;
+        try {
+            cacheContent = jedisCluster.get("hello_world");
+        } catch (Exception e) {
+            //如果异常，你可以决定是否忽略
+        }
+        if(cacheContent == null) {
+            //如果cache中不存在，或者redis异常
+        }
+    }
+}