From c044f7e77ca8dd6e060e5e03241e3b68811efac2 Mon Sep 17 00:00:00 2001
From: vitem <wangjunqiang@xdf.cn>
Date: Wed, 14 Jul 2021 14:02:12 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20redis=20sentinel=E7=9A=84?=
 =?UTF-8?q?=E9=85=8D=E7=BD=AE=E6=94=AF=E6=8C=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../klock/KlockAutoConfiguration.java         |  6 ++++
 .../klock/config/KlockConfig.java             | 34 +++++++++++++++++++
 2 files changed, 40 insertions(+)

diff --git a/src/main/java/org/springframework/boot/autoconfigure/klock/KlockAutoConfiguration.java b/src/main/java/org/springframework/boot/autoconfigure/klock/KlockAutoConfiguration.java
index d0a810f..edac617 100644
--- a/src/main/java/org/springframework/boot/autoconfigure/klock/KlockAutoConfiguration.java
+++ b/src/main/java/org/springframework/boot/autoconfigure/klock/KlockAutoConfiguration.java
@@ -44,6 +44,12 @@ public class KlockAutoConfiguration {
         if(klockConfig.getClusterServer()!=null){
             config.useClusterServers().setPassword(klockConfig.getPassword())
                     .addNodeAddress(klockConfig.getClusterServer().getNodeAddresses());
+        }if (klockConfig.getSentinelServer()!=null){
+            config.useSentinelServers()
+                    .setPassword(klockConfig.getPassword())
+                    .setDatabase(klockConfig.getDatabase())
+                    .setMasterName(klockConfig.getSentinelServer().getMasterName())
+                    .addSentinelAddress(klockConfig.getSentinelServer().getNodeAddresses());
         }else {
             config.useSingleServer().setAddress(klockConfig.getAddress())
                     .setDatabase(klockConfig.getDatabase())
diff --git a/src/main/java/org/springframework/boot/autoconfigure/klock/config/KlockConfig.java b/src/main/java/org/springframework/boot/autoconfigure/klock/config/KlockConfig.java
index 00c171e..2c0c869 100644
--- a/src/main/java/org/springframework/boot/autoconfigure/klock/config/KlockConfig.java
+++ b/src/main/java/org/springframework/boot/autoconfigure/klock/config/KlockConfig.java
@@ -14,6 +14,8 @@ public class KlockConfig {
     private String password;
     private int database=15;
     private ClusterServer clusterServer;
+
+    private SentinelServer sentinelServer;
     private String codec = "org.redisson.codec.JsonJacksonCodec";
     //lock
     private long waitTime = 60;
@@ -75,6 +77,14 @@ public class KlockConfig {
         this.clusterServer = clusterServer;
     }
 
+    public SentinelServer getSentinelServer() {
+        return sentinelServer;
+    }
+
+    public void setSentinelServer(SentinelServer sentinelServer) {
+        this.sentinelServer = sentinelServer;
+    }
+
     public static class ClusterServer{
 
         private String[] nodeAddresses;
@@ -87,4 +97,28 @@ public class KlockConfig {
             this.nodeAddresses = nodeAddresses;
         }
     }
+
+
+    public static class SentinelServer{
+
+        private String[] nodeAddresses;
+
+        private String masterName;
+
+        public String[] getNodeAddresses() {
+            return nodeAddresses;
+        }
+
+        public void setNodeAddresses(String[] nodeAddresses) {
+            this.nodeAddresses = nodeAddresses;
+        }
+
+        public String getMasterName() {
+            return masterName;
+        }
+
+        public void setMasterName(String masterName) {
+            this.masterName = masterName;
+        }
+    }
 }
-- 
Gitee