`

spring cloud微服务云架构-用java使用 redlock

 
阅读更多

一、 在pom文件引入redis和redisson依赖:

<!-- redis-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <!-- redisson-->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.3.2</version>
        </dependency>

 AquiredLockWorker接口类,,主要是用于获取锁后需要处理的逻辑:

/**
 * Created by fangzhipeng on 2017/4/5.
 * 获取锁后需要处理的逻辑
 */
public interface AquiredLockWorker<T> {
     T invokeAfterLockAquire() throws Exception;
}

 二、DistributedLocker 获取锁管理类:

/**
 * Created by fangzhipeng on 2017/4/5.
 * 获取锁管理类
 */
public interface DistributedLocker {
     /**
      * 获取锁
      * @param resourceName  锁的名称
      * @param worker 获取锁后的处理类
      * @param <T>
      * @return 处理完具体的业务逻辑要返回的数据
      * @throws UnableToAquireLockException
      * @throws Exception
      */
     <T> T lock(String resourceName, AquiredLockWorker<T> worker) throws UnableToAquireLockException, Exception;
     <T> T lock(String resourceName, AquiredLockWorker<T> worker, int lockTime) throws UnableToAquireLockException, Exception;
}

 nableToAquireLockException ,不能获取锁的异常类:

/**
 * Created by fangzhipeng on 2017/4/5.
 * 异常类
 */
public class UnableToAquireLockException extends RuntimeException {
    public UnableToAquireLockException() {
    }
    public UnableToAquireLockException(String message) {
        super(message);
    }
    public UnableToAquireLockException(String message, Throwable cause) {
        super(message, cause);
    }
}

 三、RedissonConnector 连接类:

/**
 * Created by fangzhipeng on 2017/4/5.
 * 获取RedissonClient连接类
 */
@Component
public class RedissonConnector {
    RedissonClient redisson;
    @PostConstruct
    public void init(){
        redisson = Redisson.create();
    }
    public RedissonClient getClient(){
        return redisson;
    }
}

 四、RedisLocker 类,实现了DistributedLocker:

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
/**
 * Created by fangzhipeng on 2017/4/5.
 */
@Component
public class RedisLocker  implements DistributedLocker{
    private final static String LOCKER_PREFIX = "lock:";
    @Autowired
    RedissonConnector redissonConnector;
    @Override
    public <T> T lock(String resourceName, AquiredLockWorker<T> worker) throws InterruptedException, UnableToAquireLockException, Exception {
        return lock(resourceName, worker, 100);
    }
    @Override
    public <T> T lock(String resourceName, AquiredLockWorker<T> worker, int lockTime) throws UnableToAquireLockException, Exception {
        RedissonClient redisson= redissonConnector.getClient();
        RLock lock = redisson.getLock(LOCKER_PREFIX + resourceName);
      // Wait for 100 seconds seconds and automatically unlock it after lockTime seconds
        boolean success = lock.tryLock(100, lockTime, TimeUnit.SECONDS);
        if (success) {
            try {
                return worker.invokeAfterLockAquire();
            } finally {
                lock.unlock();
            }
        }
        throw new UnableToAquireLockException();
    }
}

 五、测试类:

 @Autowired
    RedisLocker distributedLocker;
    @RequestMapping(value = "/redlock")
    public String testRedlock() throws Exception{
        CountDownLatch startSignal = new CountDownLatch(1);
        CountDownLatch doneSignal = new CountDownLatch(5);
        for (int i = 0; i < 5; ++i) { // create and start threads
            new Thread(new Worker(startSignal, doneSignal)).start();
        }
        startSignal.countDown(); // let all threads proceed
        doneSignal.await();
        System.out.println("All processors done. Shutdown connection");
        return "redlock";
    }
     class Worker implements Runnable {
        private final CountDownLatch startSignal;
        private final CountDownLatch doneSignal;
        Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {
            this.startSignal = startSignal;
            this.doneSignal = doneSignal;
        }
        public void run() {
            try {
                startSignal.await();
                distributedLocker.lock("test",new AquiredLockWorker<Object>() {
                    @Override
                    public Object invokeAfterLockAquire() {
                        doTask();
                        return null;
                    }
                });
            }catch (Exception e){
            }
        }
        void doTask() {
            System.out.println(Thread.currentThread().getName() + " start");
            Random random = new Random();
            int _int = random.nextInt(200);
            System.out.println(Thread.currentThread().getName() + " sleep " + _int + "millis");
            try {
                Thread.sleep(_int);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + " end");
            doneSignal.countDown();
        }
    }

 六、运行测试类:

 

Thread-48 start

Thread-48 sleep 99millis

Thread-48 end

Thread-49 start

Thread-49 sleep 118millis

Thread-49 end

Thread-52 start

Thread-52 sleep 141millis

Thread-52 end

Thread-50 start

Thread-50 sleep 28millis

Thread-50 end

Thread-51 start

Thread-51 sleep 145millis

Thread-51 end

不管怎么样,这是redis官方推荐的一种方案,可靠性比较高。

欢迎大家和我一起学习spring cloud构建微服务云架构,我这边会将近期研发的spring cloud微服务云架构的搭建过程和精髓记录下来,帮助更多有兴趣研发spring cloud框架的朋友,大家来一起探讨spring cloud架构的搭建过程及如何运用于企业项目。Spring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码请加企鹅求求:三五三六二四七二五九

 

分享到:
评论

相关推荐

    Spring Cloud微服务架构实战-视频教程网盘链接提取码下载 .txt

    本门课程围绕电商项目大觅网的业务场景,基于微服务原则设计电商项目,使用多种诸如Eureka、Feign、Hystrix、Ribbon、Zuul、Config等技术,另外基于虚拟化技术Docker+Jenkins实现程序自动发布、基于Mycat实现第三方...

    SpringCloud微服务架构笔记-共四部分四个PDF文件

    本套笔记全面覆盖了SpringCloud微服务架构的关键知识点,从理论到实践,帮助读者深入了解并掌握微服务设计原则和SpringCloud的实现方式,对于想要在微服务领域深化学习的Java开发者来说是一份宝贵的资料。

    SpringCloud微服务分布式架构开发实战-50000-05-作业及参考答案.rar.rar

    SpringCloud是Java领域中广泛使用的微服务开发工具集,它提供了众多服务发现、配置管理、负载均衡、熔断机制等组件,使得开发者能够轻松构建分布式系统。 首先,我们需要了解SpringCloud的核心组件。Eureka是服务...

    从天气项目看spring Cloud微服务治理--网盘地址----未加密

    从天气项目看spring Cloud微服务治理--网盘地址----未加密。文档中包含百度网盘的分享链接和密码,直接可以下载,没有加密,谢谢支持

    [云框架]基于SpringCloud的微服务架构-用户指南

    【云框架】基于Spring Cloud的微服务架构-用户指南 在现代软件开发中,微服务架构已经成为构建可扩展、高可用且易于维护的应用程序的重要模式。Spring Cloud作为Java开发领域内的一个主流微服务框架,为开发者提供...

    spring cloud 微服务架构集成-spring-cloud-framework.zip

    了解并熟练掌握这些核心组件的使用,是构建和维护高效稳定的Spring Cloud微服务架构的关键。在"spring-cloud-framework.zip"的项目中,你可以通过阅读源码、运行示例和调试,深入理解这些组件如何协同工作,提升你的...

    springcloud微服务技术栈-个人笔记文档(基础篇)

    【SpringCloud微服务技术栈详解】 SpringCloud 是一套完整的微服务解决方案,它为开发者提供了构建分布式...结合其他技术如 Docker、Redis 和 RabbitMQ,可以进一步优化微服务架构,实现更高效、更稳定的系统运行。

    spring-cloud 微服务系统架构 ppt

    7. **熔断与降级策略**:除了Hystrix的断路器模式,微服务架构中还经常使用降级策略,当系统压力过大时,可以选择牺牲部分功能,确保核心业务的正常运行。 8. **服务跟踪**:Spring Cloud Sleuth集成Zipkin或ELK...

    基于Spring Boot和Spring Cloud的微服务架构设计源码

    本设计源码提供了一个基于Spring Boot和Spring Cloud的微服务架构。项目包含399个文件,主要使用Java、Shell和HTML编程语言。文件类型包括223个Java源代码文件、48个XML配置文件、36个YAML配置文件、35个PNG图片文件...

    若依SpringCloud微服务版-傻瓜式教程模式

    【若依SpringCloud微服务版-傻瓜式教程模式】是一个面向初学者的教程,旨在帮助没有微服务架构经验的人快速上手搭建基于Spring Cloud的若依(RuoYi)微服务系统。若依是一个开源的Java管理框架,集成了Vue前端和Spring...

    SpringCloud 微服务注册中心 - Nacos高可用.md

    SpringCloud 微服务注册中心 - Nacos高可用.md

    基于SpringCloud微服务的dooleen-backend设计源码

    dooleen-backend项目是一款基于SpringCloud微服务架构设计的源码,共包含1141个文件,其中Java源文件占比最高,达946个,辅以PNG图片、Shell脚本、XML配置、属性文件、FTL模板、HTML、JavaScript、CSS和JPG图片等...

    springcloud项目实战微服务架构源代码+文档说明(电商版一套完整架构)

    微信商城+微信公众号开发,该项目根据上海某大型知名电商企业互联网互联网项目,改版而来,使用最新微服务架构技术,页面使用高仿小米界面。功能包含电商模块,会员、SSO、订单、商品、支付、消息、微信、H5和PC、...

    SpringCloud微服务架构.vsdx

    使用visio手绘的 Spring Cloud 微服务框架,包含路由、服务注册、服务交互、配置管理

    Spring Cloud 微服务权限系统搭建教程 脚手架

    Spring Cloud 是一个基于 Java 的微服务架构开发框架,旨在简化分布式系统的开发和部署。FEBS Cloud 是基于 Spring Cloud Hoxton.RELEASE、Spring Cloud OAuth2、Spring Cloud Alibaba 和 Element 构建的微服务权限...

    (完整版)基于SpringCloud微服务系统设计方案.pdf

    SpringCloud微服务系统设计方案是构建大规模、高可用应用程序的一种现代架构。它基于Spring Boot和Spring Framework,旨在简化微服务的开发、部署和管理。本文将深入探讨微服务的本质、面临的挑战、架构设计以及核心...

    SpringCloud微服务架构视频

    【SpringCloud微服务架构视频】是一系列视频教程,总计五十一课,专注于讲解SpringCloud的原理及实践操作,尤其适合初学者和希望深入理解微服务架构的开发者。本教程的前十二节已提供,后续内容可通过作者的博客获取...

    SpringCloud微服务开发实战教程idea版课件

    Spring Cloud是目前最流行的进行微服务架构的框架之一,是一个一站式的开发分布式系统的框架,为开发者提供了一系列的构建分布式系统的工具集。目前已经在各大互联网公司得到广泛应用,是进行微服务架构的优先选择...

    基于SpringCloud微服务实现的互联网招聘平台源码.zip

    基于SpringCloud微服务实现的互联网招聘平台源码 基于SpringCloud微服务实现的互联网招聘平台源码 基于SpringCloud微服务实现的互联网招聘平台源码 基于SpringCloud微服务实现的互联网招聘平台源码 基于...

    转载 仿百度能力开放平台的spring cloud 微服务框架 ,-open-capacity-platform.zip

    【标题】中的“仿百度能力开放平台的spring cloud 微服务框架”指的是一个基于Spring Cloud构建的微服务架构,该架构的设计灵感来源于百度的能力开放平台。Spring Cloud是Java平台上广泛使用的微服务开发框架,它...

Global site tag (gtag.js) - Google Analytics