blog/Full-Stack-Notes
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
luoxiang 2020-01-01 17:42:05 +08:00
parent 62cb442117
commit 77d51e2f0d
3 changed files with 0 additions and 77 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
code/Distributed-Lock/pom.xml
View File

@ -1,38 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.heibaiying</groupId>
<artifactId>Distributed-Lock</artifactId>
<version>1.0</version>
<dependencies>
<!-- Redisson 依赖-->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.11.3</version>
</dependency>
<!--Curator 相关依赖-->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>4.0.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>4.0.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.13</version>
</dependency>
</dependencies>
</project>

19
code/Distributed-Lock/src/main/java/com/lock/RedisLock.java
View File

@ -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();
}
}

20
code/Distributed-Lock/src/main/java/com/lock/ZooKeeperLock.java
View File

@ -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();
}
}