使用基于Zookeeper集群技术而实现的分布式锁InterProcessMutex解决商品秒杀等高并发产生的问题推荐

<!-- 基于Zookeeper原生的客户端类实现的分布式并发问题的解决方法
包含有Zookeeper相关技术方案
-->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <!-- 网友投票该版本最好 -->
    <version>4.2.0</version>
</dependency>

<?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.cy</groupId>
    <artifactId>zookeeper_lock_product</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!--声明项目打包方式：jar,war-->
    <packaging>war</packaging>

    <dependencies>
        <!--spring与springMVC相关依赖-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <!-- MyBatis-->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.5</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>2.0.5</version>
        </dependency>

        <!-- mysql连接池-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.10</version>
        </dependency>
        <!-- 数据库 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
        <!--单元测试-->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
        <!-- 基于Zookeeper原生的客户端类实现的分布式并发问题的解决方法
        包含有Zookeeper相关技术方案
        -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <!-- 网友投票该版本最好 -->
            <version>4.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.24</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

    <properties>
        <!--定义变量spring.version 内嵌TOMCAT，支持最高springMVC版本是5.3.0以下版本-->
        <spring.version>5.2.7.RELEASE</spring.version>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <!--构建项目环境-->
    <build>
        <!-- 插件配置-->
        <plugins>
            <!-- Maven内嵌的Tomcat插件-->
            <plugin>
                <groupId>org.apache.tomcat.maven</groupId>
                <!-- 目前Apache只提供Tomcat6和Tomcat7两个插件-->
                <artifactId>tomcat7-maven-plugin</artifactId>
                <version>2.2</version>
                <configuration>
                    <port>9001</port>
                    <path>/</path>
                </configuration>
                <executions>
                    <execution>
                        <!-- 点击Maven的pachage打包完成后，运行服务-->
                        <phase>package</phase>
                        <goals>
                            <goal>run</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

</project>

=

package com.DurkBlue.product.controller;

import com.durkblue.product.service.IProductService;
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;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 商品秒杀控制层
 */
@RestController
public class ProductController {
    @Autowired
    private IProductService productService;
    // 声明Zookeeper集群环境的IP
    private String connectionStr = "192.168.99.10:2181,192.168.99.11:2181,192.168.99.12:2181";

    @GetMapping("/product/reduce")
    public String reduceStock(Integer id) throws Exception {
        // 1.添加锁执行以下步骤
        /**
         * a.创建一个重试策略,防止连接zookeeper集群没有及时连接出现的问题,尝试多次连接.每次重试间隔时间设置为1s
         * 参数1：表示每一次重试的时间间隔(毫秒)
         * 参数2：表示重试多少次
         */
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);

        // b.创建Curator对象（表示Zookeeper连接的工具对象）
        CuratorFramework client = CuratorFrameworkFactory.newClient(connectionStr, retryPolicy);
        // c.开启客户端，表示连接上集群
        client.start();
        /**
         * d.根据工具类对象创建内部互斥锁对象
         * 参数1：表示目标客户端（client对象）
         * 参数2：表示这个锁在集群中的节点名称（要求唯一）
         */
        InterProcessMutex lock = new InterProcessMutex(client, "/product_" + id);
        try {
            // e.开启锁(在目标方法执行之前)
            lock.acquire();
            productService.reduceStock(id);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            // 2.释放锁(目标方法被调用，无论是否产生异常，都应该将锁释放)
            lock.release();
        }
        return "SUCCESS";
    }
}