Zk

code/demo/build.gradle

@@ -95,6 +95,9 @@ dependencies {
 
 	compile "com.alibaba:druid:$druidVersion"
 
+	compile group: 'org.apache.zookeeper', name: 'zookeeper', version: '3.4.12'
+	compile 'org.apache.curator:curator-recipes:4.0.0'
+
 	// https://mvnrepository.com/artifact/com.google.guava/guava
 	compile group: 'com.google.guava', name: 'guava', version: '28.2-jre'
 	// https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis

code/demo/src/main/java/com/example/demo/control/StockControl.java

@@ -1,5 +1,7 @@
 package com.example.demo.control;
 
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.recipes.locks.InterProcessMutex;
 import org.redisson.Redisson;
 import org.redisson.api.RLock;
 import org.slf4j.Logger;
@@ -103,4 +105,23 @@ public String deductStockRedisson() throws Exception {
         return retVal;
     }
 
+    @Autowired
+    private CuratorFramework curatorFramework;
+
+    @PostMapping(value = "/deduct_stock_zk")
+    public String deductStockZk() throws Exception {
+        String path = "/stock";
+        InterProcessMutex interProcessMutex = new InterProcessMutex(curatorFramework, path);
+        String retVal;
+        try {
+            interProcessMutex.acquire();
+            retVal = stockReduce();
+        } catch (Exception e) {
+            throw new Exception("lock error");
+        } finally {
+            interProcessMutex.release();
+        }
+        return retVal;
+    }
+
 }

code/demo/src/main/java/com/example/demo/zk/CuratorConfiguration.java

@@ -0,0 +1,25 @@
+package com.example.demo.zk;
+
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+import org.springframework.context.annotation.Bean;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author mubi
+ * @Date 2020/7/23 19:28
+ */
+@Component
+public class CuratorConfiguration {
+
+    @Bean(initMethod = "start")
+    public CuratorFramework curatorFramework() {
+        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
+        CuratorFramework client = CuratorFrameworkFactory.newClient(
+                "127.0.0.1:2181", retryPolicy);
+        return client;
+    }
+
+}

code/demo/src/main/resources/application.properties

@@ -14,7 +14,7 @@ mybatis.mapperLocations= classpath:sqlmap/*.xml
 
 logging.level.com.example.demo.repository=info
 
-server.port=8089
+server.port=8088
 
 # Redis数据库索引（默认为0）
 spring.redis.database=0  

code/demo2/src/main/resources/application.properties

@@ -15,8 +15,16 @@ mybatis.mapperLocations=classpath:sqlmap/*.xml
 #server
 server.port=8088
 
-server.tomcat.uri-encoding=UTF-8
-server.tomcat.max-threads=100
-server.tomcat.max-connections=200
+#logging.config=classpath:logback-spring.xml
 
-#logging.config=classpath:logback-spring.xml
+#kafka相关配置
+spring.kafka.bootstrap-servers=localhost:9092
+#设置一个默认组
+spring.kafka.consumer.group-id=console-consumer-98672
+#key-value序列化反序列化
+spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
+spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
+spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.producer.batch-size=65536
+spring.kafka.producer.buffer-memory=524288