Hystrix限流,熔断,降级入门

逃离我推掉我的手 2022-06-02 11:26 231阅读 0赞

概念:  
**限流**:比如我们的web系统所能承受的最大并发是500,但是在搞活动时人流量相当大，并发就可能超过我们系统的承受量,从而把系统搞崩。此时可以设置流量达到450时拒绝服务，保护系统。但是这并不友好。  
**熔断**:服务熔断一般是指软件系统中，由于某些原因使得服务出现了过载现象，为防止造成整个**重点内容**系统故障，从而采用的一种保护措施，所以很多地方把熔断亦称为过载保护.  
**降级**:当服务熔断后，快速响应用户的一种机制。如果获取订单信息失败时，返回从缓存取或直接返回用户 稍后再试。  
Hystrix实现:  
**1.pom.xml 依赖**

<dependency>
        <groupId>com.netflix.hystrix</groupId>
        <artifactId>hystrix-core</artifactId>
        <version>1.5.9</version>
    </dependency>

**2.业务入口*\****重点内容\*

@RequestMapping("/test")
    public String test(){
        Object obj = new CommandUserSafe().execute();
        System.out.println(++i+"访问:"+(String)obj);
        return (String)obj;
    }

**3.限流,熔断,降级控制**

public class CommandUserSafe extends HystrixCommand { 
        public CommandUserSafe(){
            super(HystrixCommandGroupKey.Factory.asKey("userGroup"));
        }
        @Override
        protected Object run() throws Exception {
            //调用真实的服务业务逻辑
            String user = "你好";
            //int a = 1/0;
            return user;
        }
    
        /** 当前调用方法发生异常时,降级执行此访问*/
        @Override
        protected Object getFallback() {
            return "错误了";
        }
    }

**4.配置相关参数**，在classpath下新建config.properties,Hystrix会自动加载此文件，如果没有就会使用默认的参数。

#########################################################
    #Execution：控制HystrixCommand.run() 的如何执行
    #Fallback: 控制HystrixCommand.getFallback() 如何执行
    #Circuit Breaker： 控制断路器的行为
    #Metrics: 捕获和HystrixCommand 和 HystrixObservableCommand 执行信息相关的配置属性
    #Request Context：设置请求上下文的属性
    #Collapser Properties：设置请求合并的属性
    #Thread Pool Properties：设置线程池的属性
    #########################################################
    #执行线程数,默认10
    hystrix.threadpool.default.coreSize=10
    #最大执行线程数,默认10
    hystrix.threadpool.default.maximumSize=10
    #设置最大的BlockingQueue队列的值。如果设置-1，则使用SynchronousQueue队列，如果设置正数，则使用LinkedBlockingQueue队列
    hystrix.threadpool.default.maxQueueSize=-1
    #因为maxQueueSize值不能被动态修改，所有通过设置此值可以实现动态修改等待队列长度。
    #即等待的队列的数量大于queueSizeRejectionThreshold时（但是没有达到maxQueueSize值），
    #则开始拒绝后续的请求进入队列。
    hystrix.threadpool.default.queueSizeRejectionThreshold=5
    
    #超时时间：默认1000毫秒,超过该时间会执行回退逻辑
    hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=1000
    #是否启用超时设置,默认true
    hystrix.command.default.execution.timeout.enabled=true
    #是否超时中断正在执行的run,默认true
    hystrix.command.default.execution.isolation.thread.interruptOnTimeout=true
    #是否执行取消动作时，中断正在执行的run,默认false
    hystrix.command.default.execution.isolation.thread.interruptOnCancel=false
    
    
    #如果超出该数，则后续的会被拒绝，如果没有实现回退逻辑的，则会抛出异常,默认10
    hystrix.command.default.fallback.isolation.semaphore.maxConcurrentRequests=10
    #是否当故障或者拒绝发生后，一个调用尝试调用getFallback()方法,默认true
    hystrix.command.default.fallback.enabled=true
    
    #是否开启断路器功能,默认true
    hystrix.command.default.circuitBreaker.enabled=true
    #该属性设置滚动窗口中将使断路器跳闸的最小请求数量,默认20
    #如果此属性值为20，则在窗口时间内（如10s内），如果只收到19个请求且都失败了，则断路器也不会开启。
    hystrix.command.default.circuitBreaker.requestVolumeThreshold=20
    #断路器跳闸后，在此值的时间的内，hystrix会拒绝新的请求，只有过了这个时间断路器才会打开闸门,默认5000
    hystrix.command.default.circuitBreaker.sleepWindowInMilliseconds=5000
    #设置失败百分比的阈值。如果失败比率超过这个值，则断路器跳闸并且进入fallback逻辑,默认50
    hystrix.command.default.circuitBreaker=50
    #如果设置true，则强制使断路器跳闸，则会拒绝所有的请求.此值会覆盖circuitBreaker.forceClosed的值,默认false
    hystrix.command.default.circuitBreaker.forceOpen=false
    #如果设置true，则强制使断路器进行关闭状态，此时会允许执行所有请求，无论是否失败的次数达到,默认false
    hystrix.command.default.circuitBreaker.forceClosed=false
    
    
    #是否开启请求缓存功能,默认值：true
    hystrix.command.default.requestCache.enabled=true
    #表示是否开启日志，打印执行HystrixCommand的情况和事件默认值：true
    hystrix.command.default.requestLog.enabled=true
    
    #设置同时批量执行的请求的最大数量,默认int的最大值
    hystrix.collapser.default.maxRequestsInBatch=
    #批量执行创建多久之后，再触发真正的请求，默认10
    hystrix.collapser.default.timerDelayInMilliseconds=10
    #是否对HystrixCollapser.execute() 和 HystrixCollapser.queue()开启请求缓存，默认值：true
    hystrix.collapser.default.requestCache.enabled=true

===================================================  
**参考文章:**  
[http://blog.csdn.net/liubenlong007/article/details/76648614][http_blog.csdn.net_liubenlong007_article_details_76648614]  
[http://blog.csdn.net/u012314558/article/details/78347219][http_blog.csdn.net_u012314558_article_details_78347219]  
[https://www.cnblogs.com/li3807/p/7501427.html][https_www.cnblogs.com_li3807_p_7501427.html]

[http_blog.csdn.net_liubenlong007_article_details_76648614]: http://blog.csdn.net/liubenlong007/article/details/76648614
[http_blog.csdn.net_u012314558_article_details_78347219]: http://blog.csdn.net/u012314558/article/details/78347219
[https_www.cnblogs.com_li3807_p_7501427.html]: https://www.cnblogs.com/li3807/p/7501427.html