13518219792
服務(wù)短路(CircuitBreaker)
榆樹網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián),榆樹網(wǎng)站設(shè)計制作，有大型網(wǎng)站制作公司豐富經(jīng)驗。已為榆樹1000+提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站制作要多少錢，請找那個售后服務(wù)好的榆樹做網(wǎng)站的公司定做！
QPS：Query Per Second
TPS：Transaction Per Second
QPS：經(jīng)過全鏈路壓測，計算單機(jī)極限QPS，集群QPS=單機(jī)PQS*集群機(jī)器數(shù)量*可靠性比率
全鏈路壓測，除了壓極限QPS，還有錯誤數(shù)量
全鏈路：一個完整的業(yè)務(wù)流程操作
JMeter：可調(diào)整型比較靈活
Spring Cloud Hystrix Client
官網(wǎng)：https://github.com/Netflix/Hystrix
Reactive Java框架：
java9 Flow API
Reactor
RxJava(Reactive X)
激活Hystrix
通過@EnableHystrix激活
配置信息wiki：https//github.com/Netflix/Hystrix/wiki/Configuration
Hystrix
1. 注解方式
@HystrixCommand(defaultFallback= "errorContent",commandProperties =
{@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value= "100")})
@GetMapping("/user/count")
public String userCount() throws InterruptedException {
Random random = new Random();
int nextInt = random.nextInt(200);
System.out.println("random time > "+nextInt);
Thread.sleep(nextInt);
return userService.userCount();
}
public String errorContent() {
System.out.println("超時了");
return "-1";
}
2. 編程方式
@GetMapping("/user/count2")
public String userCount2() {
return new MyHystrixCommand().execute();
}
private class MyHystrixCommand extends com.netflix.hystrix.HystrixCommand{
protected MyHystrixCommand() {
super(HystrixCommandGroupKey.Factory.asKey(""), 100);
}
@Override
protected String run() throws Exception {
Random random = new Random();
int nextInt = random.nextInt(200);
System.out.println("random time > "+nextInt);
Thread.sleep(nextInt);
return "OK";
}
@Override
protected String getFallback() {
return UserServiceProviderRestApiController.this.errorContent();
}
}
對比其他Java執(zhí)行方式：
Feature
public class FutrueDemo {
public static void main(String[] args) {
Random random = new Random();
ExecutorService service = Executors.newFixedThreadPool(1);
Future futrue = service.submit(() -> {
int value = random.nextInt(200);
System.out.print("睡眠"+value+"ms.");
Thread.sleep(value);
return "OK";
});
try {
futrue.get(100,TimeUnit.MILLISECONDS);
}catch (Exception e) {
System.out.println("超時保護(hù)...");
}
service.shutdown();
}
}
Health Endpoint (/actuator/health)
{
"status": "UP",
"details": {
"diskSpace": {
"status": "UP",
"details": {
"total": 140382552064,
"free": 7376781312,
"threshold": 10485760
}
},
"refreshScope": {
"status": "UP"
},
"discoveryComposite": {
"status": "UP",
"details": {
"discoveryClient": {
"status": "UP",
"details": {
"services": ["user-service-consumer", "user-service-provider", "eureka-server"]
}
},
"eureka": {
"description": "Remote status from Eureka server",
"status": "UP",
"details": {
"applications": {
"USER-SERVICE-CONSUMER": 1,
"EUREKA-SERVER": 2,
"USER-SERVICE-PROVIDER": 2
}
}
}
}
},
"hystrix": {
"status": "UP"
}
}
}
激活熔斷保護(hù) 無錫婦科醫(yī)院排行 http://www.0510bhyy.com/
@EnableCircuitBreaker 激活：@EnableHystrix + Spring Cloud功能
@EnableHystrix 激活，沒有一些Spring Cloud功能，如 /hystrix.stream
hystrix Endpoint(/actuator/hystrix.stream)
data: {
"type": "HystrixCommand",
"name": "MyHystrixCommand",
"group": "",
"currentTime": 1563720628038,
"isCircuitBreakerOpen": false,
"errorPercentage": 50,
"errorCount": 2,
"requestCount": 4,
"rollingCountBadRequests": 0,
"rollingCountCollapsedRequests": 0,
"rollingCountEmit": 0,
"rollingCountExceptionsThrown": 0,
"rollingCountFailure": 0,
"rollingCountFallbackEmit": 0,
"rollingCountFallbackFailure": 0,
"rollingCountFallbackMissing": 0,
"rollingCountFallbackRejection": 0,
"rollingCountFallbackSuccess": 1,
"rollingCountResponsesFromCache": 0,
"rollingCountSemaphoreRejected": 0,
"rollingCountShortCircuited": 0,
"rollingCountSuccess": 2,
"rollingCountThreadPoolRejected": 0,
"rollingCountTimeout": 1,
"currentConcurrentExecutionCount": 0,
"rollingMaxConcurrentExecutionCount": 1,
"latencyExecute_mean": 0,
"latencyExecute": {
"0": 0,
"25": 0,
"50": 0,
"75": 0,
"90": 0,
"95": 0,
"99": 0,
"99.5": 0,
"100": 0
},
"latencyTotal_mean": 0,
"latencyTotal": {
"0": 0,
"25": 0,
"50": 0,
"75": 0,
"90": 0,
"95": 0,
"99": 0,
"99.5": 0,
"100": 0
},
"propertyValue_circuitBreakerRequestVolumeThreshold": 20,
"propertyValue_circuitBreakerSleepWindowInMilliseconds": 5000,
"propertyValue_circuitBreakerErrorThresholdPercentage": 50,
"propertyValue_circuitBreakerForceOpen": false,
"propertyValue_circuitBreakerForceClosed": false,
"propertyValue_circuitBreakerEnabled": true,
"propertyValue_executionIsolationStrategy": "THREAD",
"propertyValue_executionIsolationThreadTimeoutInMilliseconds": 100,
"propertyValue_executionTimeoutInMilliseconds": 100,
"propertyValue_executionIsolationThreadInterruptOnTimeout": true,
"propertyValue_executionIsolationThreadPoolKeyOverride": null,
"propertyValue_executionIsolationSemaphoreMaxConcurrentRequests": 10,
"propertyValue_fallbackIsolationSemaphoreMaxConcurrentRequests": 10,
"propertyValue_metricsRollingStatisticalWindowInMilliseconds": 10000,
"propertyValue_requestCacheEnabled": true,
"propertyValue_requestLogEnabled": true,
"reportingHosts": 1,
"threadPool": ""
}
Spring Cloud Hystrix Dashboard
使用@EnableHystrixDashboard激活
@SpringBootApplication
@EnableHystrixDashboard
public class SpringCloudHystrixDashboardApplication {
public static void main(String[] args) {
SpringApplication.run(SpringCloudHystrixDashboardApplication.class, args);
}
}
