redisson 分布式锁

Author: chengxy-nds

springboot-redisson-lock/pom.xml

@@ -3,37 +3,20 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://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.2.5.RELEASE</version>
-        <relativePath/>
+        <groupId>com.notebook</groupId>
+        <artifactId>Springboot-Notebook</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
     </parent>
-    <groupId>com.chengxy</groupId>
     <artifactId>springboot-redisson-lock</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>springboot-redisson-lock</name>
-    <description>Demo project for Spring Boot</description>
-
-    <properties>
-        <java.version>1.8</java.version>
-    </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter</artifactId>
-        </dependency>
 
+        <!-- 模板引擎 -->
         <dependency>
             <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-test</artifactId>
-            <scope>test</scope>
-            <exclusions>
-                <exclusion>
-                    <groupId>org.junit.vintage</groupId>
-                    <artifactId>junit-vintage-engine</artifactId>
-                </exclusion>
-            </exclusions>
+            <artifactId>spring-boot-starter-thymeleaf</artifactId>
         </dependency>
 
         <dependency>
@@ -42,18 +25,11 @@
             <version>3.11.4</version>
         </dependency>
 
-        <!--<dependency>-->
-            <!--<groupId>org.springframework.boot</groupId>-->
-            <!--<artifactId>spring-boot-starter-data-redis</artifactId>-->
-            <!--<version>2.3.1.RELEASE</version>-->
-        <!--</dependency>-->
-
-        <!--<dependency>-->
-            <!--<groupId>org.redisson</groupId>-->
-            <!--&lt;!&ndash; for Spring Data Redis v.2.2.x &ndash;&gt;-->
-            <!--<artifactId>redisson-spring-data-22</artifactId>-->
-            <!--<version>2.3.1.RELEASE</version>-->
-        <!--</dependency>-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+            <version>2.3.1.RELEASE</version>
+        </dependency>
 
     </dependencies>
 

springboot-redisson-lock/src/main/java/com/xiaofu/redisson/config/RedissonConfig.java

@@ -6,7 +6,7 @@
 import org.springframework.context.annotation.Configuration;
 
 /**
- * @Author: xinzhifu
+ * @Author: xiaofu
  * @Description:
  */
 @Configuration

springboot-redisson-lock/src/main/java/com/xiaofu/redisson/controller/LiveObjectController.java

@@ -1,5 +1,6 @@
 package com.xiaofu.redisson.controller;
 
+
 import com.xiaofu.redisson.entity.OrderInfo;
 import org.redisson.api.RLiveObjectService;
 import org.redisson.api.RedissonClient;
@@ -9,7 +10,7 @@
 import org.springframework.web.bind.annotation.ResponseBody;
 
 /**
- * @Author: xinzhifu
+ * @Author: xiaofu
  * @Description:
  */
 @Controller

springboot-redisson-lock/src/main/java/com/xiaofu/redisson/controller/LockController.java

@@ -6,83 +6,75 @@
 import org.redisson.api.RedissonClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
 
 import java.util.concurrent.TimeUnit;
 
 /**
- * @Author: xinzhifu
+ * @Author: xiaofu
  * @Description:
  */
 @Controller
-@RequestMapping
+@RequestMapping("/lock")
 public class LockController {
 
     @Autowired
     private RedissonClient redissonClient;
 
-    @RequestMapping("/reduceStock")
-    @ResponseBody
-    public String reduceStock() {
-
-        RLock lock = redissonClient.getLock("order:A0001");
-        try {
-            lock.lock(5, TimeUnit.SECONDS);
-            Thread.currentThread().sleep(30000);
-            lock.unlock();
-            System.out.println("锁释放~");
-
-        } catch (Exception e) {
-            lock.unlock();
-        }
-        return null;
-    }
-
-
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 可重入锁-普通
      * @date 2020/7/16 15:20
      */
-    public void reentrantLock() {
+    @GetMapping("/reduceStock2")
+    @ResponseBody
+    public String reentrantLock(String order) {
 
-        RLock reentrantLock = redissonClient.getLock("order:A0002");
+        RLock reentrantLock = redissonClient.getLock(order);
         try {
-            reentrantLock.lock();
-            //TODO something
-            reentrantLock.unlock();
-
+            if (reentrantLock.tryLock(100, 8, TimeUnit.SECONDS)) {
+                System.out.println(Thread.currentThread().getName() + "---" + order + "---" + "加锁成功");
+                Thread.currentThread().sleep(10000);
+                return "YES";
+            } else {
+                System.out.println("线程 " + Thread.currentThread().getName() + "---" + order + "---" + "加锁失败");
+            }
         } catch (Exception e) {
-            reentrantLock.unlock();
+            //reentrantLock.unlock();
         } finally {
-            reentrantLock.unlock();
+            //reentrantLock.unlock();
         }
+        return "NO";
     }
 
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 可重入锁-设置过期时间
      * @date 2020/7/16 15:20
      */
-    public void reentrantLock2() {
+    public String reentrantLock2(String order) {
 
-        RLock reentrantLock = redissonClient.getLock("order:A0001");
+        RLock reentrantLock = redissonClient.getLock(order);
         try {
-
             // 100尝试加锁的时间 ，10锁过期时间
             if (reentrantLock.tryLock(100, 10, TimeUnit.SECONDS)) {
-                //TODO something
+                //Thread.currentThread().sleep(10000);
+                System.out.println(order + "加锁成功");
+            } else {
+                System.out.println(order + "已加锁");
             }
         } catch (Exception e) {
             reentrantLock.unlock();
         } finally {
             reentrantLock.unlock();
         }
+        return "success";
     }
 
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 异步可重入锁-设置过期时间
      * @date 2020/7/16 15:20
      */
@@ -104,7 +96,7 @@ public void reentrantLock2Async() {
     }
 
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 公平锁
      * @date 2020/7/16 15:20
      */
@@ -128,7 +120,7 @@ public void fairLock() {
     }
 
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 联锁
      * @date 2020/7/16 15:20
      */
@@ -151,7 +143,7 @@ public void multiLock() {
     }
 
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 红锁
      * @date 2020/7/16 15:20
      */
@@ -174,7 +166,7 @@ public void redLock() {
     }
 
     /**
-     * @author xinzhifu
+     * @author xiaofu
      * @description 读写锁
      * @date 2020/7/16 15:20
      */

springboot-redisson-lock/src/main/java/com/xiaofu/redisson/entity/OrderInfo.java

@@ -5,7 +5,7 @@
 import org.redisson.api.annotation.RIndex;
 
 /**
- * @Author: xinzhifu
+ * @Author: xiaofu
  * @Description:
  */
 @REntity

springboot-redisson-lock/src/main/resources/application.yml

@@ -1,4 +1,7 @@
 spring:
   redis:
     redisson:
-      config: "classpath:redisson.yml"
+      config: "classpath:redisson.yml"
+server:
+  port: 8083
+