Redission和Zookeeper分別實現分散式鎖

2022年08月20日10:49:04 科技 1195

redission和zookeeper分別實現分散式鎖(windows)

1、Redission實現分散式事務

1.1 前提準備

  • 下載好nginx(windows版本)
  • 下載好Jmeter(模仿高並發)
  • 下載好redis(windows版)

1.2 代碼

  • pom文件
<?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 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.7.2</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>cn.lanqiao</groupId>
    <artifactId>arcdemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>arcdemo</name>
    <description>arcdemo</description>


    <properties>
        <java.version>8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>Spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- redisson -->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>Redisson-spring-boot-starter</artifactId>
            <version>3.17.5</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>
  • 配置文件
  • 因為實現分散式事務,所以一會再啟動一個9000埠的該項目
# 應用名稱
spring.application.name=arcdemo
# 應用服務 WEB 訪問埠
server.port=8000


# Redis資料庫索引(默認為0)
spring.redis.database=0
# Redis伺服器地址
spring.redis.host=127.0.0.1
# Redis伺服器連接埠
spring.redis.port=6379
# Redis伺服器連接密碼(默認為空)
spring.redis.password=
# 連接池最大連接數(使用負值表示沒有限制)
spring.redis.jedis.pool.max-active=20
# 連接池最大阻塞等待時間(使用負值表示沒有限制)
spring.redis.jedis.pool.max-wait=-1
# 連接池中的最大空閑連接
spring.redis.jedis.pool.max-idle=10
# 連接池中的最小空閑連接
spring.redis.jedis.pool.min-idle=0
# 連接超時時間(毫秒)
spring.redis.timeout=1000
  • 在主啟動類注入Redisson
package com.example;

import org.redisson.Redisson;
import org.redisson.config.Config;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;

@SpringBootApplication
@EnableRedisHttpSession
public class ArcdemoApplication {
 

    public static void main(String[] args) {
 
        SpringApplication.run(ArcdemoApplication.class, args);
    }
    @Bean
    public Redisson redission() {
 
        Config config = new Config();
        config.useSingleServer().setAddress("redis://localhost:6379").setDatabase(0);
        return (Redisson) Redisson.create(config);
    }

}
  • controller類
package com.example.controller;

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.RetryNTimes;
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.http.HttpRequest;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import java.util.concurrent.TimeUnit;

/**
 * @Author Devere19
 * @Date 2022/8/17 10:41
 * @Version 1.0
 */
@RestController
public class BiSheController {
 

    // private static final String ZK_ADDRESS = "127.0.0.1:2181";
    //
    // private static final String ZK_LOCK_PATH = "/zkLock";
    //
    // static CuratorFramework client = null;
    //
    // static {
 
    //     //連接zk
    //     client = CuratorFrameworkFactory.newClient(ZK_ADDRESS,
    //             new RetryNTimes(10, 5000));
    //     client.start();
    // }

    // 分散式鎖
    @Autowired
    private Redisson redisson;

    @Resource
    private StringRedisTemplate StringRedisTemplate;


    @GetMapping("/login")
    public String login(String username, HttpSession session, HttpServletRequest request) {
 
        session.setAttribute("username", username);
        return username + ",埠" + request.getLocalPort();
    }

    @GetMapping("/getUser")
    public String getUser(HttpSession session, HttpServletRequest request) {
 
        String username = (String) session.getAttribute("username");
        return session.getId() + "," + username + ",埠" + request.getLocalPort();
    }

    @PostMapping("/checkTeacher")
    public String checkteacher(String teacherName) {
 
        // SpringBoot操作Redis
        String lockKey = "lockKey";
        RLock redissonLock = null;
        String num = "";
        try {
 
            redissonLock = redisson.getLock("lockKey");//加鎖
            redissonLock.tryLock(30, TimeUnit.SECONDS);//超時時間:每間隔10秒(1/3)
            num = stringRedisTemplate.opsForValue().get(teacherName);
            int n = Integer.parseInt(num);

            if (n > 0) {
 
                n = n - 1;
                stringRedisTemplate.opsForValue().set("lkz", n + "");
                //正常選擇老師
                System.out.println("當前名額:" + n);
            } else {
 
                return "名額已滿";
            }
        } catch (InterruptedException e) {
 
            e.printStackTrace();
        } finally {
 
            redissonLock.unlock();//釋放鎖
        }
        return num;
    }
    // @PostMapping("/checkTeacher")
    // public String checkteacher(String teacherName) {
 
    //     InterProcessMutex lock = new InterProcessMutex(client, ZK_LOCK_PATH);
    //     String num = "";
    //     try {
 
    //         if (lock.acquire(6000, TimeUnit.SECONDS)) {
 
    //             // System.out.println("拿到了鎖");
    //             //業務邏輯
    //             num = stringRedisTemplate.opsForValue().get(teacherName);
    //             int n = Integer.parseInt(num);
    //             if (n > 0) {
 
    //                 n = n - 1;
    //                 stringRedisTemplate.opsForValue().set("lkz", n + "");
    //                 //正常選擇老師
    //                 System.out.println("當前名額:" + n);
    //             } else {
 
    //                 return "名額已滿";
    //             }
    //             // System.out.println("任務完畢,該釋放鎖了");
    //         }
    //     } catch (Exception e) {
 
    //         System.out.println("業務異常");
    //         e.printStackTrace();
    //     }finally {
 
    //         try {
 
    //             lock.release();
    //         } catch (Exception e) {
 
    //             System.out.println("釋放鎖異常");
    //             e.printStackTrace();
    //         }
    //     }
    //     return num;
    // }
}
  • redis需要有對應的key
set lkz 6

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

1.3 啟動項目

  • 第一步:啟動redis,並且給lkz賦值
  • 第二步:啟動nginx,nginx需要做配置,指向本地的8000和9000埠
upstream testdev{
            server   127.0.0.1:8000 weight=1;
            server   127.0.0.1:9000 weight=1;
   }

    server {
        listen       80;
        server_name  localhost;

        #charset koi8-r;

        #access_log  logs/host.access.log  main;

        location / {
            root   html;
            index  index.html index.htm;
            proxy_pass http://testdev;
            proxy_redirect default;
        }
  • 第三步:idea中啟動8000埠,並且再修改配置文件埠,再啟動9000埠

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

點擊這個,然後修改9000即可同時啟動8000和9000埠

  • 第三步:啟動Jmeter,發請求

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

1.4 結果

Redission的結果自行查看,博主偷懶了在下面的zookeeper實現分散式鎖的結果才截圖了。

2、Zookeeper實現分散式鎖

2.1 前提準備

  • 下載好nginx(windows版本)
  • 下載好Jmeter(模仿高並發)
  • 下載好redis(windows版)
  • 下載好zookeeper(windows版本)和ZooInspector(可視化工具,也可以不下載)

2.2 代碼

  • pom文件
<?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 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.7.2</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>cn.lanqiao</groupId>
    <artifactId>arcdemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>arcdemo</name>
    <description>arcdemo</description>


    <properties>
        <java.version>8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- redisson -->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson-spring-boot-starter</artifactId>
            <version>3.17.5</version>
        </dependency>
    <!--    zookeeper和curator-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.7</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-client</artifactId>
            <version>4.3.0</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>
  • controller
package com.example.controller;

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.RetryNTimes;
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.http.HttpRequest;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import java.util.concurrent.TimeUnit;

/**
 * @Author Devere19
 * @Date 2022/8/17 10:41
 * @Version 1.0
 */
@RestController
public class BiSheController {
 

    private static final String ZK_ADDRESS = "127.0.0.1:2181";

    private static final String ZK_LOCK_PATH = "/zkLock";

    static CuratorFramework client = null;

    static {
 
        //連接zk
        client = CuratorFrameworkFactory.newClient(ZK_ADDRESS,
                new RetryNTimes(10, 5000));
        client.start();
    }

    // 分散式鎖
    // @Autowired
    // private Redisson redisson;

    @Resource
    private StringRedisTemplate stringRedisTemplate;


    @GetMapping("/login")
    public String login(String username, HttpSession session, HttpServletRequest request) {
 
        session.setAttribute("username", username);
        return username + ",埠" + request.getLocalPort();
    }

    @GetMapping("/getUser")
    public String getUser(HttpSession session, HttpServletRequest request) {
 
        String username = (String) session.getAttribute("username");
        return session.getId() + "," + username + ",埠" + request.getLocalPort();
    }

    // @PostMapping("/checkTeacher")
    // public String checkteacher(String teacherName) {
 
    //     // SpringBoot操作Redis
    //     String lockKey = "lockKey";
    //     RLock redissonLock = null;
    //     String num = "";
    //     try {
 
    //         redissonLock = redisson.getLock("lockKey");//加鎖
    //         redissonLock.tryLock(30, TimeUnit.SECONDS);//超時時間:每間隔10秒(1/3)
    //         num = stringRedisTemplate.opsForValue().get(teacherName);
    //         int n = Integer.parseInt(num);
    //
    //         if (n > 0) {
 
    //             n = n - 1;
    //             stringRedisTemplate.opsForValue().set("lkz", n + "");
    //             //正常選擇老師
    //             System.out.println("當前名額:" + n);
    //         } else {
 
    //             return "名額已滿";
    //         }
    //     } catch (InterruptedException e) {
 
    //         e.printStackTrace();
    //     } finally {
 
    //         redissonLock.unlock();//釋放鎖
    //     }
    //     return num;
    // }
    @PostMapping("/checkTeacher")
    public String checkteacher(String teacherName) {
 
        InterProcessMutex lock = new InterProcessMutex(client, ZK_LOCK_PATH);
        String num = "";
        try {
 
            if (lock.acquire(6000, TimeUnit.SECONDS)) {
 
                // System.out.println("拿到了鎖");
                //業務邏輯
                num = stringRedisTemplate.opsForValue().get(teacherName);
                int n = Integer.parseInt(num);
                if (n > 0) {
 
                    n = n - 1;
                    stringRedisTemplate.opsForValue().set("lkz", n + "");
                    //正常選擇老師
                    System.out.println("當前名額:" + n);
                } else {
 
                    return "名額已滿";
                }
                // System.out.println("任務完畢,該釋放鎖了");
            }
        } catch (Exception e) {
 
            System.out.println("業務異常");
            e.printStackTrace();
        }finally {
 
            try {
 
                lock.release();
            } catch (Exception e) {
 
                System.out.println("釋放鎖異常");
                e.printStackTrace();
            }
        }
        return num;
    }
}

2.3 啟動項目

  • 第一步:啟動redis,並且給lkz賦值
  • 第二步:啟動nginx,nginx需要做配置,指向本地的8000和9000埠
upstream testdev{
            server   127.0.0.1:8000 weight=1;
            server   127.0.0.1:9000 weight=1;
   }

    server {
        listen       80;
        server_name  localhost;

        #charset koi8-r;

        #access_log  logs/host.access.log  main;

        location / {
            root   html;
            index  index.html index.htm;
            proxy_pass http://testdev;
            proxy_redirect default;
        }
  • 第三步:idea中啟動8000埠,並且再修改配置文件埠,再啟動9000埠

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

點擊這個,然後修改9000即可同時啟動8000和9000埠

  • 第三步:啟動zookeeper,並且啟動ZooInspector可視化工具
  • 第四步:啟動Jmeter,發請求

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

2.4 結果

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

看到控制台的輸出,可以看出來分散式鎖起作用了,並且可以觀看ZooInspector進行查看

Redission和Zookeeper分別實現分散式鎖 - 天天要聞

因為這裡採用的是有序臨時鎖,所以請求發完之後就刪除了鎖。必須在發起請求的一瞬間去刷新,才可能看到排好序的鎖。

3、 案例源碼地址

https://github.com/Guoleyuan/arcdemo

科技分類資訊推薦

大爺寫《我的母親》火爆全網!視頻發布者最新發聲 - 天天要聞

大爺寫《我的母親》火爆全網!視頻發布者最新發聲

連日來,一段關於大爺挑戰寫作1957年高考同題作文《我的母親》的視頻火爆全網。不少網民表示,文字質樸,催人淚下,深深被打動。7月11日,大皖新聞記者聯繫上了視頻發布者連文傑。對方表示,視頻中展示的作文內容由大爺獨立寫作,產生的版權收入也全給大爺。大爺寫作文視頻走紅網路。大爺寫的作文在網上爆火大皖新聞記者注...
10.38萬元起,吉利銀河A7發布預售價 - 天天要聞

10.38萬元起,吉利銀河A7發布預售價

7月11日,吉利銀河發布了預售價,預售價格範圍為10.38-13.38萬元,在發布預售價格的同時,官方也帶來了多項權益,包括500元訂金抵扣1500元,贈送價值8800元的Flyme Sound音響等。
「中欣卡」突然停擺,超150萬用戶退款難 - 天天要聞

「中欣卡」突然停擺,超150萬用戶退款難

覆蓋北京2000多家門店、擁有超150萬持卡用戶的預付卡「中欣卡」近日停擺,線上線下消費渠道均被暫停,恢復時間未知。大量持卡用戶面臨資金凍結困境。消費渠道全面「癱瘓」近日,中欣卡發布公告稱「因業務調整,全面暫停所有門店合作,無法消費」。中國新聞網《民生調查局》記者發現,其官網合作商戶名錄已清空,線上提貨渠...
突發,聊聊Manus「刪博跑路」 - 天天要聞

突發,聊聊Manus「刪博跑路」

摘要:「如果最後有不錯的結果,證明作為中國出生的創始人,也能在新的環境下做好全球化的產品,那就太好了」鳳凰網科技 出品作者|董雨晴7月11日,AI Agent產品Manus官方賬號清空了發布在微博、小紅書的內容。兩天前,Manus剛剛陷入裁
AI取代矽谷程序員?這些美國大廠高管這麼說 - 天天要聞

AI取代矽谷程序員?這些美國大廠高管這麼說

人工智慧(AI)正在加速重塑全球勞動力市場。 當地時間10日,美國招聘平台Indeed及員工評價網站Glassdoor宣布,為應對人工智慧帶來的產業變革,將裁減約1300個職位,占集團員工總數的6%。微軟首席商業官阿爾索夫(Judson Althoff)稱,AI已承擔35%的產品代碼編寫工作,顯著加快了產品開發周期。 美國威達信集團(Marsh McL...