服务治理【4】HTTP服务的降级和熔断

秒速五厘米 2022-04-16 04:19 446阅读 0赞

# 一、熔断与降级 #

熔断的意义: 熔断器是当依赖的服务已经出现故障，为了保证自身服务的正常运行不再访问依赖的服务，防止雪崩效应。  
降级的意义: 当服务器压力剧增时，根据业务策略降级，以此释放服务资源保证业务正常。

# 二、熔断器的原理 #

熔断器的状态:  
关闭状态：服务正常，维护失败率统计，达到失败率阈值时，转到开启状态  
开启状态：调用fallback函数，一段时间后，进入半开启状态  
半开启状态：尝试恢复服务，失败率高于阈值，进入开启状态，低于阈值，进入关闭状态。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTAwNTY1_size_16_color_FFFFFF_t_70_pic_center]

# 三、hystrix-go库 #

hystrix-go 是熔断、降级和限流集成类库

func main() { 
    	hystrixStreamHandler := hystrix.NewStreamHandler()
    	hystrixStreamHandler.Start()
    	go func() { 
    		log.Println("Start server at ::80")
    		log.Fatal(http.ListenAndServe(":80", hystrixStreamHandler))
    	}()
    	hystrix.ConfigureCommand("aaa", hystrix.CommandConfig{ 
    		Timeout:                1000, //单次请求超时时间
    		MaxConcurrentRequests:  1,    //最大并发量
    		SleepWindow:            5000, //熔断后5秒去尝试服务是否可用
    		RequestVolumeThreshold: 1,    //验证熔断的请求数量，10秒内采样
    		ErrorPercentThreshold:  1,    //验证熔断的错误百分比
    	})
    	for i := 0; i < 10000; i++ { 
    		// 异步调用方法hystrix.Go
    		err := hystrix.Do("aaa", func() error { 
    			if i == 0 { 
    				return errors.New("首次出错")
    			}
    			fmt.Print("->业务逻辑")
    			return nil
    		}, nil)
    		if err != nil { 
    			log.Println("hystrix err:" + err.Error())
    			time.Sleep(time.Second * 1)
    			log.Println("sleep 1 second")
    		}
    	}
    	time.Sleep(time.Second * 20)
    }

# 四、hystrix面板（dashboard） #

docker run -d -p 8080:9002 --name hystrix-dashboard mlabouardy/hystrix-dashboard:latest

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTAwNTY1_size_16_color_FFFFFF_t_70_pic_center 1]

# 五、构建熔断中间件并在路由Use该中间件 #

var (
    	gateway string = "127.0.0.1:10000"
    	first   int    = 0
    )
    
    func main() { 
    	// 开启流量统计
    	hystrixStreamHandler := hystrix.NewStreamHandler()
    	hystrixStreamHandler.Start()
    	go func() { 
    		log.Println("Start server at ::8074")
    		log.Fatal(http.ListenAndServe("172.17.15.207:8074", hystrixStreamHandler))
    	}()
    	hystrix.ConfigureCommand("test", hystrix.CommandConfig{ 
    		Timeout:                1000, //单次请求超时时间
    		MaxConcurrentRequests:  2,    //最大并发量
    		SleepWindow:            5000, //熔断后5秒去尝试服务是否可用
    		RequestVolumeThreshold: 1,    //验证熔断的请求数量，10秒内采样
    		ErrorPercentThreshold:  1,    //验证熔断的错误百分比
    	})
    
    	// 构建路由
    	router := middleware.NewSliceRouter()
    	router.Group("/gateway").Use(middleware.TraceLogSliceMW(), func(c *middleware.SliceRouterContext) { 
    		err := hystrix.Do("test", func() error { 
    			if first == 0 { 
    				first++
    				return errors.New("首次出错")
    			}
    			fmt.Print("->业务逻辑")
    			return nil
    		}, nil)
    		if err != nil { 
    			log.Println("hystrix err:" + err.Error())
    		}
    	})
    	handler := middleware.NewSliceRouterHandler(nil, router)
    	log.Println("Gateway start at: ", gateway)
    	log.Fatal(http.ListenAndServe(gateway, handler))
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTAwNTY1_size_16_color_FFFFFF_t_70_pic_center 2]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTAwNTY1_size_16_color_FFFFFF_t_70_pic_center]: /images/20220416/983d5ea11e89481c9f176b7e70730976.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTAwNTY1_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20220416/7dcb6f7b43ce4befbab5dfb9d3021366.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM4OTAwNTY1_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20220416/6af4f967ffce47afb5db3f01e8f323aa.png