|
|
@ -39,6 +39,7 @@ import org.springframework.stereotype.Service;
|
|
|
|
import org.springframework.test.annotation.DirtiesContext;
|
|
|
|
import org.springframework.test.annotation.DirtiesContext;
|
|
|
|
import org.springframework.test.context.junit4.SpringRunner;
|
|
|
|
import org.springframework.test.context.junit4.SpringRunner;
|
|
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
|
|
|
|
|
|
import org.springframework.web.bind.annotation.RequestParam;
|
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
|
|
|
|
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat;
|
|
|
|
import static org.assertj.core.api.Assertions.assertThat;
|
|
|
@ -59,21 +60,24 @@ public class SentinelCircuitBreakerIntegrationTest {
|
|
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@Test
|
|
|
|
public void testSlow() throws Exception {
|
|
|
|
public void testSlow() throws Exception {
|
|
|
|
// The first 5 requests should pass.
|
|
|
|
assertThat(service.slow(true)).isEqualTo("slow");
|
|
|
|
assertThat(service.slow()).isEqualTo("slow");
|
|
|
|
assertThat(service.slow(true)).isEqualTo("slow");
|
|
|
|
assertThat(service.slow()).isEqualTo("slow");
|
|
|
|
assertThat(service.slow(true)).isEqualTo("slow");
|
|
|
|
assertThat(service.slow()).isEqualTo("slow");
|
|
|
|
assertThat(service.slow(false)).isEqualTo("slow");
|
|
|
|
assertThat(service.slow()).isEqualTo("slow");
|
|
|
|
assertThat(service.slow(false)).isEqualTo("slow");
|
|
|
|
assertThat(service.slow()).isEqualTo("slow");
|
|
|
|
assertThat(service.slow(true)).isEqualTo("slow");
|
|
|
|
|
|
|
|
assertThat(service.slow(true)).isEqualTo("slow");
|
|
|
|
|
|
|
|
|
|
|
|
// Then in the next 10s, the fallback method should be called.
|
|
|
|
// Then in the next 10s, the fallback method should be called.
|
|
|
|
for (int i = 0; i < 10; i++) {
|
|
|
|
for (int i = 0; i < 5; i++) {
|
|
|
|
assertThat(service.slow()).isEqualTo("fallback");
|
|
|
|
assertThat(service.slow(true)).isEqualTo("fallback");
|
|
|
|
Thread.sleep(1000);
|
|
|
|
Thread.sleep(1000);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Try a normal request.
|
|
|
|
|
|
|
|
assertThat(service.slow(false)).isEqualTo("slow");
|
|
|
|
// Recovered.
|
|
|
|
// Recovered.
|
|
|
|
assertThat(service.slow()).isEqualTo("slow");
|
|
|
|
assertThat(service.slow(true)).isEqualTo("slow");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@Test
|
|
|
@ -97,8 +101,10 @@ public class SentinelCircuitBreakerIntegrationTest {
|
|
|
|
protected static class Application {
|
|
|
|
protected static class Application {
|
|
|
|
|
|
|
|
|
|
|
|
@GetMapping("/slow")
|
|
|
|
@GetMapping("/slow")
|
|
|
|
public String slow() throws InterruptedException {
|
|
|
|
public String slow(@RequestParam(required = false) Boolean slow) throws InterruptedException {
|
|
|
|
Thread.sleep(500);
|
|
|
|
if (slow == null || slow) {
|
|
|
|
|
|
|
|
Thread.sleep(80);
|
|
|
|
|
|
|
|
}
|
|
|
|
return "slow";
|
|
|
|
return "slow";
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -112,14 +118,15 @@ public class SentinelCircuitBreakerIntegrationTest {
|
|
|
|
String slowId = "slow";
|
|
|
|
String slowId = "slow";
|
|
|
|
List<DegradeRule> rules = Collections.singletonList(
|
|
|
|
List<DegradeRule> rules = Collections.singletonList(
|
|
|
|
new DegradeRule(slowId).setGrade(RuleConstant.DEGRADE_GRADE_RT)
|
|
|
|
new DegradeRule(slowId).setGrade(RuleConstant.DEGRADE_GRADE_RT)
|
|
|
|
.setCount(100).setTimeWindow(10));
|
|
|
|
.setCount(50).setSlowRatioThreshold(0.7).setMinRequestAmount(5)
|
|
|
|
|
|
|
|
.setStatIntervalMs(30000).setTimeWindow(5));
|
|
|
|
return factory -> {
|
|
|
|
return factory -> {
|
|
|
|
factory.configure(builder -> builder.rules(rules), slowId);
|
|
|
|
factory.configure(builder -> builder.rules(rules), slowId);
|
|
|
|
factory.configureDefault(id -> new SentinelConfigBuilder()
|
|
|
|
factory.configureDefault(id -> new SentinelConfigBuilder()
|
|
|
|
.resourceName(id)
|
|
|
|
.resourceName(id)
|
|
|
|
.rules(Collections.singletonList(new DegradeRule(id)
|
|
|
|
.rules(Collections.singletonList(new DegradeRule(id)
|
|
|
|
.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT)
|
|
|
|
.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT)
|
|
|
|
.setCount(0.5).setTimeWindow(10)))
|
|
|
|
.setCount(10).setStatIntervalMs(10000).setTimeWindow(10)))
|
|
|
|
.build());
|
|
|
|
.build());
|
|
|
|
};
|
|
|
|
};
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -137,9 +144,9 @@ public class SentinelCircuitBreakerIntegrationTest {
|
|
|
|
this.cbFactory = cbFactory;
|
|
|
|
this.cbFactory = cbFactory;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public String slow() {
|
|
|
|
public String slow(boolean slow) {
|
|
|
|
return cbFactory.create("slow").run(
|
|
|
|
return cbFactory.create("slow").run(
|
|
|
|
() -> rest.getForObject("/slow", String.class), t -> "fallback");
|
|
|
|
() -> rest.getForObject("/slow?slow=" + slow, String.class), t -> "fallback");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public String normal() {
|
|
|
|
public String normal() {
|
|
|
|