msb-public
/
spring-cloud-tencent
mirror of https://github.com/Tencent/spring-cloud-tencent
3
1
Code Issues Projects Releases Wiki Activity

feat: support custom quickstart circuitbreak delay time.

Browse Source
pull/1666/head
fishtailfu 2 months ago
parent 9b2d71850a
commit fd1bdd470b
1 changed files with 28 additions and 18 deletions
Show Stats Download Patch File Download Diff File

46
spring-cloud-tencent-examples/quickstart-example/quickstart-callee-service-b/src/main/java/com/tencent/cloud/quickstart/callee/QuickstartCalleeController.java
Unescape View File

@ -119,16 +119,19 @@ public class QuickstartCalleeController {
@GetMapping("/circuitBreak") @GetMapping("/circuitBreak")
public ResponseEntity<String> circuitBreak() throws InterruptedException { public ResponseEntity<String> circuitBreak() throws InterruptedException {
if (ifBadGateway) { if (ifBadGateway) {
LOG.info("Quickstart Callee Service [{}:{}] is called wrong.", ip, port); String result = String.format("Quickstart Callee Service [%s:%s] is called wrong.", ip, port);
return new ResponseEntity<>("failed for call quickstart callee service.", HttpStatus.BAD_GATEWAY); LOG.info(result);
return new ResponseEntity<>("failed for call quickstart callee service. " + result, HttpStatus.BAD_GATEWAY);
} }
if (delay > 0) { if (delay > 0) {
String result = String.format("Quickstart Callee Service [%s:%s] is called after %sms.", ip, port, delay);
Thread.sleep(delay); Thread.sleep(delay);
LOG.info("Quickstart Callee Service [{}:{}] is called after {}ms", ip, port, delay); LOG.info(result);
return new ResponseEntity<>(String.format("Quickstart Callee Service [%s:%s] is called after %sms.", ip, port, delay), HttpStatus.OK); return new ResponseEntity<>(result, HttpStatus.OK);
} }
LOG.info("Quickstart Callee Service [{}:{}] is called right.", ip, port); String result = String.format("Quickstart Callee Service [%s:%s] is called right.", ip, port);
return new ResponseEntity<>(String.format("Quickstart Callee Service [%s:%s] is called right.", ip, port), HttpStatus.OK); LOG.info(result);
return new ResponseEntity<>(result, HttpStatus.OK);
} }
/** /**
@ -139,16 +142,19 @@ public class QuickstartCalleeController {
@GetMapping("/circuitBreak/wildcard/{uid}") @GetMapping("/circuitBreak/wildcard/{uid}")
public ResponseEntity<String> circuitBreakWildcard(@PathVariable String uid) throws InterruptedException { public ResponseEntity<String> circuitBreakWildcard(@PathVariable String uid) throws InterruptedException {
if (ifBadGateway) { if (ifBadGateway) {
LOG.info("Quickstart Callee Service with uid {} [{}:{}] is called wrong.", uid, ip, port); String result = String.format("Quickstart Callee Service uid %s [%s:%s] is called wrong.", uid, ip, port);
return new ResponseEntity<>("failed for call quickstart callee service wildcard.", HttpStatus.BAD_GATEWAY); LOG.info(result);
return new ResponseEntity<>("failed for call quickstart callee service wildcard. " + result, HttpStatus.BAD_GATEWAY);
} }
if (delay > 0) { if (delay > 0) {
String result = String.format("Quickstart Callee Service uid %s [%s:%s] is called after %sms.", uid, ip, port, delay);
Thread.sleep(delay); Thread.sleep(delay);
LOG.info("Quickstart Callee Service uid {} [{}:{}] is called after {}ms", uid, ip, port, delay); LOG.info(result);
return new ResponseEntity<>(String.format("Quickstart Callee Service uid %s [%s:%s] is called after %sms.", uid, ip, port, delay), HttpStatus.OK); return new ResponseEntity<>(result, HttpStatus.OK);
} }
LOG.info("Quickstart Callee Service uid {} [{}:{}] is called right.", uid, ip, port); String result = String.format("Quickstart Callee Service uid %s [%s:%s] is called right.", uid, ip, port);
return new ResponseEntity<>(String.format("Quickstart Callee Service uid %s [%s:%s] is called right.", uid, ip, port), HttpStatus.OK); LOG.info(result);
return new ResponseEntity<>(result, HttpStatus.OK);
} }
@GetMapping("/setBadGateway") @GetMapping("/setBadGateway")
@ -178,18 +184,22 @@ public class QuickstartCalleeController {
return new ResponseEntity<>("delay must be non-negative", HttpStatus.BAD_REQUEST); return new ResponseEntity<>("delay must be non-negative", HttpStatus.BAD_REQUEST);
} }
@GetMapping("/faultDetect") @GetMapping("/faultDetect")
public ResponseEntity<String> health() throws InterruptedException { public ResponseEntity<String> health() throws InterruptedException {
if (ifBadGateway) { if (ifBadGateway) {
LOG.info("Quickstart Callee Service [{}:{}] is detected wrong.", ip, port); String result = String.format("Quickstart Callee Service [%s:%s] is detected wrong.", ip, port);
return new ResponseEntity<>(String.format("Quickstart Callee Service [%s:%s] is detected wrong.", ip, port), HttpStatus.BAD_GATEWAY); LOG.info(result);
return new ResponseEntity<>("failed for call quickstart callee service wildcard. " + result, HttpStatus.BAD_GATEWAY);
} }
if (delay > 0) { if (delay > 0) {
Thread.sleep(delay); Thread.sleep(delay);
LOG.info("Quickstart Callee Service [{}:{}] is detected slow.", ip, port); String result = String.format("Quickstart Callee Service [%s:%s] is detected after %s.", ip, port, delay);
return new ResponseEntity<>(String.format("Quickstart Callee Service [%s:%s] is detected slow.", ip, port), HttpStatus.OK); LOG.info(result);
return new ResponseEntity<>(result, HttpStatus.OK);
} }
LOG.info("Quickstart Callee Service [{}:{}] is detected right.", ip, port); String result = String.format("Quickstart Callee Service [%s:%s] is detected right.", ip, port);
return new ResponseEntity<>(String.format("Quickstart Callee Service [%s:%s] is detected right.", ip, port), HttpStatus.OK); LOG.info(result);
return new ResponseEntity<>(result, HttpStatus.OK);
} }
} }

Write Preview
Loading…
Cancel
Save