Hystrix 熔断、降级实例

package com.example.demo.service.impl; import java.util.Date; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Service; import com.example.demo.service.PushMessageService; import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand; import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty; @Service public class PushMessageServiceImpl implements PushMessageService { private Logger logger = LoggerFactory.getLogger(PushMessageServiceImpl.class); @Override @HystrixCommand(fallbackMethod = "fallback_send", commandProperties = { //命令执行超时时间，默认1000ms @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000"), //一个rolling window内最小的请求数。如果设为20，那么当一个rolling window的时间内（比如说1个rolling window是10秒）收到19个请求，即使19个请求都失败，也不会触发circuit break。默认20 @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"), //触发短路的时间值，当该值设为5000时，则当触发circuit break后的5000毫秒内都会拒绝request，也就是5000毫秒后才会关闭circuit。默认5000 @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "60000") }) public String send(String param) throws Exception{ logger.error("发送"+new Date().getTime()); try { //double a =1/0; Thread.sleep(3000); }catch(Exception e) { logger.error("发送 catch"+new Date().getTime()); throw e; }finally { logger.error("发送 finally"+new Date().getTime()); } return "发送成功"; } private String fallback_send(String param,Throwable throwble) { //logger.error("异常",throwble); return "Send超時"+new Date().getTime(); } }