完善例子

yujiasun · yujiasun · commit c31aeb722e7b · 2016-02-28T23:31:11.000+08:00
diff --git a/src/test/java/com/distributed/limit/redis/AccessSpeedLimitTest.java b/src/test/java/com/distributed/limit/redis/AccessSpeedLimitTest.java
@@ -15,8 +15,6 @@ public class AccessSpeedLimitTest {
     @Test
     public void test1() throws InterruptedException {
         JedisPool jp=new JedisPool("127.0.0.1",6379);
-        final RedisDistributedLockTemplate template=new RedisDistributedLockTemplate(jp);
-
         AccessSpeedLimit accessSpeedLimit=new AccessSpeedLimit(jp);
         SimpleDateFormat sdf=new SimpleDateFormat(" mm:ss");
         while(true){
diff --git a/src/test/java/com/distributed/lock/redis/RedisReentrantLockTemplateTest.java b/src/test/java/com/distributed/lock/redis/RedisReentrantLockTemplateTest.java
@@ -56,4 +56,22 @@ public Object onTimeout() throws InterruptedException {
         startCountDownLatch.countDown();
         endDownLatch.await();
     }
+
+    public static void main(String[] args){
+        JedisPool jedisPool=new JedisPool("127.0.0.1",6379);//ʵ��Ӧ��ʱ��ͨ��springע��
+        final RedisDistributedLockTemplate template=new RedisDistributedLockTemplate(jedisPool);//������̰߳�ȫ,��ͨ��springע��
+        template.execute("������ˮ��", 5000, new Callback() {
+            @Override
+            public Object onGetLock() throws InterruptedException {
+                //TODO �������Ҫ������
+                return null;
+            }
+
+            @Override
+            public Object onTimeout() throws InterruptedException {
+                //TODO �������ʱ��Ҫ������
+                return null;
+            }
+        });
+    }
 }
diff --git a/src/test/java/com/distributed/lock/redis/SimpleTest.java b/src/test/java/com/distributed/lock/redis/SimpleTest.java
@@ -0,0 +1,32 @@
+package com.distributed.lock.redis;
+
+import com.distributed.lock.Callback;
+import org.junit.Test;
+import redis.clients.jedis.JedisPool;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ThreadLocalRandom;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.ReentrantLock;
+
+/**
+ * Created by sunyujia@aliyun.com on 2016/2/24.
+ */
+public class SimpleTest {
+
+
+
+    public static void main(String[] args) throws Exception {
+        JedisPool jedisPool=new JedisPool("127.0.0.1",6379);//ʵ��Ӧ��ʱ��ͨ��springע��
+        RedisReentrantLock lock=new RedisReentrantLock(jedisPool,"������ˮ��");
+        try {
+            if (lock.tryLock(5000L, TimeUnit.MILLISECONDS)) {
+                //TODO �������Ҫ������
+            }else{
+                //TODO �������ʱ��Ҫ������
+            }
+        }finally {
+            lock.unlock();
+        }
+    }
+}
diff --git a/src/test/java/com/distributed/lock/zk/ZkReentrantLockTemplateTest.java b/src/test/java/com/distributed/lock/zk/ZkReentrantLockTemplateTest.java
@@ -1,11 +1,13 @@
 package com.distributed.lock.zk;
 
 import com.distributed.lock.Callback;
+import com.distributed.lock.redis.RedisDistributedLockTemplate;
 import org.apache.curator.RetryPolicy;
 import org.apache.curator.framework.CuratorFramework;
 import org.apache.curator.framework.CuratorFrameworkFactory;
 import org.apache.curator.retry.ExponentialBackoffRetry;
 import org.junit.Test;
+import redis.clients.jedis.JedisPool;
 
 import java.util.concurrent.*;
 
@@ -55,4 +57,25 @@ public Object onTimeout() throws InterruptedException {
         startCountDownLatch.countDown();
         endDownLatch.await();
     }
+
+public static void main(String[] args){
+    RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
+    CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retryPolicy);
+    client.start();
+
+    final ZkDistributedLockTemplate template=new ZkDistributedLockTemplate(client);//������̰߳�ȫ,��ͨ��springע��
+    template.execute("������ˮ��", 5000, new Callback() {
+        @Override
+        public Object onGetLock() throws InterruptedException {
+            //TODO �������Ҫ������
+            return null;
+        }
+
+        @Override
+        public Object onTimeout() throws InterruptedException {
+            //TODO �������ʱ��Ҫ������
+            return null;
+        }
+    });
+}
 }
