From 77d51e2f0d338cf92a1c14318997b8ca2ed92f13 Mon Sep 17 00:00:00 2001 From: luoxiang <2806718453@qq.com> Date: Wed, 1 Jan 2020 17:42:05 +0800 Subject: [PATCH] update --- code/Distributed-Lock/pom.xml | 38 ------------------- .../src/main/java/com/lock/RedisLock.java | 19 ---------- .../src/main/java/com/lock/ZooKeeperLock.java | 20 ---------- 3 files changed, 77 deletions(-) delete mode 100644 code/Distributed-Lock/pom.xml delete mode 100644 code/Distributed-Lock/src/main/java/com/lock/RedisLock.java delete mode 100644 code/Distributed-Lock/src/main/java/com/lock/ZooKeeperLock.java diff --git a/code/Distributed-Lock/pom.xml b/code/Distributed-Lock/pom.xml deleted file mode 100644 index 14f7881..0000000 --- a/code/Distributed-Lock/pom.xml +++ /dev/null @@ -1,38 +0,0 @@ - - - 4.0.0 - - com.heibaiying - Distributed-Lock - 1.0 - - - - - - org.redisson - redisson - 3.11.3 - - - - org.apache.curator - curator-framework - 4.0.0 - - - org.apache.curator - curator-recipes - 4.0.0 - - - org.apache.zookeeper - zookeeper - 3.4.13 - - - - - \ No newline at end of file diff --git a/code/Distributed-Lock/src/main/java/com/lock/RedisLock.java b/code/Distributed-Lock/src/main/java/com/lock/RedisLock.java deleted file mode 100644 index 90b9f1b..0000000 --- a/code/Distributed-Lock/src/main/java/com/lock/RedisLock.java +++ /dev/null @@ -1,19 +0,0 @@ -package com.lock; - -import org.redisson.Redisson; -import org.redisson.api.RLock; -import org.redisson.api.RedissonClient; -import org.redisson.config.Config; -import org.redisson.config.TransportMode; - -public class RedisLock { - - public static void main(String[] args) { - Config config = new Config(); - config.setTransportMode(TransportMode.EPOLL); - config.useSingleServer().setAddress("redis://127.0.0.1:7181"); - RedissonClient client = Redisson.create(config); - RLock mylock = client.getLock("mylock"); - mylock.lock(); - } -} diff --git a/code/Distributed-Lock/src/main/java/com/lock/ZooKeeperLock.java b/code/Distributed-Lock/src/main/java/com/lock/ZooKeeperLock.java deleted file mode 100644 index bd0a574..0000000 --- a/code/Distributed-Lock/src/main/java/com/lock/ZooKeeperLock.java +++ /dev/null @@ -1,20 +0,0 @@ -package com.lock; - -import org.apache.curator.RetryPolicy; -import org.apache.curator.framework.CuratorFramework; -import org.apache.curator.framework.CuratorFrameworkFactory; -import org.apache.curator.framework.recipes.locks.InterProcessMutex; -import org.apache.curator.retry.ExponentialBackoffRetry; - -public class ZooKeeperLock { - - public static void main(String[] args) throws Exception { - RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3); - CuratorFramework client = CuratorFrameworkFactory.newClient("hadoop001:2181", retryPolicy); - client.start(); - InterProcessMutex mutex = new InterProcessMutex(client, "/curator/lock"); - mutex.acquire(); - mutex.release(); - client.close(); - } -}