Init project

Author: kaixinbaba

Diff for: .gitignore

@@ -0,0 +1,3 @@
+.idea
+*.iml
+target

Diff for: pom.xml

@@ -0,0 +1,45 @@
+<?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>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.3.6.RELEASE</version>
+    </parent>
+    <groupId>com.github.helllogithub</groupId>
+    <artifactId>curator-springboot-demo</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-integration</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.integration</groupId>
+            <artifactId>spring-integration-zookeeper</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>curator-springboot-demo</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

Diff for: src/main/java/com/github/hellogithub/Boot.java

@@ -0,0 +1,16 @@
+package com.github.hellogithub;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author: junjiexun
+ * @date: 2020/12/8 4:09 下午
+ * @description:
+ */
+@SpringBootApplication(scanBasePackages = {"com.github"})
+public class Boot {
+
+    public static void main(String[] args) {
+        SpringApplication.run(Boot.class, args);
+    }
+}

Diff for: src/main/java/com/github/hellogithub/TestController.java

@@ -0,0 +1,55 @@
+package com.github.hellogithub;
+
+import org.springframework.integration.support.locks.LockRegistry;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Lock;
+
+/**
+ * @author: junjiexun
+ * @date: 2020/12/8 4:31 下午
+ * @description:
+ */
+@RestController
+public class TestController {
+
+    @Resource
+    private LockRegistry lockRegistry;
+
+    @GetMapping("debug")
+    public String dubug() {
+        System.out.println(lockRegistry);
+        return "SSSS";
+    }
+
+    @GetMapping("/lock10")
+    public String lock10() {
+        System.out.println("lock10 start " + System.currentTimeMillis());
+        final Lock lock = lockRegistry.obtain("lock");
+        try {
+            lock.lock();
+            System.out.println("lock10 get lock success " + System.currentTimeMillis());
+            TimeUnit.SECONDS.sleep(10);
+        } catch (Exception e) {
+        } finally {
+            lock.unlock();
+        }
+        return "OK";
+    }
+
+    @GetMapping("/immediate")
+    public String immediate() {
+        System.out.println("immediate start " + System.currentTimeMillis());
+        final Lock lock = lockRegistry.obtain("lock");
+        try {
+            lock.lock();
+            System.out.println("immediate get lock success " + System.currentTimeMillis());
+        } finally {
+            lock.unlock();
+        }
+        return "immediate return";
+    }
+}

Diff for: src/main/java/com/github/hellogithub/ZookeeperLockConfiguration.java

@@ -0,0 +1,30 @@
+package com.github.hellogithub;
+
+import org.apache.curator.framework.CuratorFramework;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean;
+import org.springframework.integration.zookeeper.lock.ZookeeperLockRegistry;
+
+/**
+ * @author: junjiexun
+ * @date: 2020/12/8 4:34 下午
+ * @description:
+ */
+@Configuration
+public class ZookeeperLockConfiguration {
+    @Value("${zookeeper.host:127.0.0.1:2181}")
+    private String zkUrl;
+
+    @Bean
+    public CuratorFrameworkFactoryBean curatorFrameworkFactoryBean() {
+        return new CuratorFrameworkFactoryBean(zkUrl);
+    }
+
+    @Bean
+    public ZookeeperLockRegistry zookeeperLockRegistry(CuratorFramework curatorFramework) {
+
+        return new ZookeeperLockRegistry(curatorFramework, "/HG-lock");
+    }
+}

Diff for: src/main/resources/application.yml

@@ -0,0 +1,2 @@
+server:
+  port: 9999