update redission

Author: kimmking

Diff for: 08cache/redis/src/main/java/io/kimmking/cache/RedisApplication.java

@@ -1,6 +1,8 @@
 package io.kimmking.cache;
 
 import com.alibaba.fastjson.JSON;
+import io.kimmking.cache.cluster.ClusterJedis;
+import io.kimmking.cache.sentinel.SentinelJedis;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import redis.clients.jedis.Jedis;
@@ -54,7 +56,7 @@ public static void main(String[] args) {
 		//  3) 分配槽位，确认分配成功
 		//  4) 测试简单的get/set是否成功
 		// 然后运行如下代码
-//		JedisCluster cluster = ClusterJedis.getJedisCluster();
+// 		JedisCluster cluster = ClusterJedis.getJedisCluster();
 //		for (int i = 0; i < 100; i++) {
 //			cluster.set("cluster:" + i, "data:" + i);
 //		}

Diff for: 08cache/redis/src/main/java/io/kimmking/cache/ClusterJedis.java renamed to 08cache/redis/src/main/java/io/kimmking/cache/cluster/ClusterJedis.java

@@ -1,4 +1,4 @@
-package io.kimmking.cache;
+package io.kimmking.cache.cluster;
 
 import lombok.SneakyThrows;
 import redis.clients.jedis.HostAndPort;

Diff for: 08cache/redis/src/main/java/io/kimmking/cache/hazelcast/HazelcastDemo.java

@@ -0,0 +1,9 @@
+package io.kimmking.cache.hazelcast;
+
+public class HazelcastDemo {
+
+    public static void main(String[] args) {
+
+    }
+
+}

Diff for: 08cache/redis/src/main/java/io/kimmking/cache/redission/RedissionDemo.java

@@ -0,0 +1,43 @@
+package io.kimmking.cache.redission;
+
+import lombok.SneakyThrows;
+import org.redisson.Redisson;
+import org.redisson.RedissonMap;
+import org.redisson.api.RLock;
+import org.redisson.api.RMap;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+
+public class RedissionDemo {
+
+    @SneakyThrows
+    public static void main(String[] args) {
+        Config config = new Config();
+        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
+        //config.useSingleServer().setPassword("");
+
+        final RedissonClient client = Redisson.create(config);
+        RMap<String, String> rmap = client.getMap("map1");
+        RLock lock = client.getLock("lock1");
+
+        try{
+            lock.lock();
+
+            for (int i = 0; i < 15; i++) {
+                rmap.put("rkey:"+i, "rvalue:"+i);
+            }
+
+            // 如果代码块 W1 在这里会怎么样？
+
+        }finally{
+            lock.unlock();
+        }
+
+        // 代码块 W1
+        while(true) {
+            Thread.sleep(2000);
+            System.out.println(rmap.get("rkey:10"));
+        }
+    }
+
+}

Diff for: 08cache/redis/src/main/java/io/kimmking/cache/redission/RedissionDemo1.java

@@ -0,0 +1,35 @@
+package io.kimmking.cache.redission;
+
+import org.redisson.Redisson;
+import org.redisson.api.RLock;
+import org.redisson.api.RMap;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+
+public class RedissionDemo1 {
+
+    public static void main(String[] args) {
+        Config config = new Config();
+        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
+        //config.useSingleServer().setPassword("");
+
+        final RedissonClient client = Redisson.create(config);
+        RLock lock = client.getLock("lock1");
+
+        try{
+            lock.lock();
+
+            RMap<String, String> rmap = client.getMap("map1");
+
+            for (int i = 0; i < 15; i++) {
+                rmap.put("rkey:"+i, "rvalue:1-"+i);
+            }
+
+            System.out.println(rmap.get("rkey:10"));
+
+        }finally{
+            lock.unlock();
+        }
+    }
+
+}

Diff for: 08cache/redis/src/main/java/io/kimmking/cache/SentinelJedis.java renamed to 08cache/redis/src/main/java/io/kimmking/cache/sentinel/SentinelJedis.java

@@ -1,4 +1,4 @@
-package io.kimmking.cache;
+package io.kimmking.cache.sentinel;
 
 import redis.clients.jedis.HostAndPort;
 import redis.clients.jedis.Jedis;

Diff for: 08cache/redis/src/main/resources/application.yml

@@ -6,3 +6,5 @@ logging:
     io:
       kimmking:
         cache : info
+
+# 作业，在这里使用spring boot配置各项内容，