resilience4j

Author: Абрамов Александр

inventory-service/src/main/java/com/alllexe/inventoryservice/service/InventoryService.java

@@ -3,19 +3,26 @@
 import com.alllexe.inventoryservice.dto.InventoryResponse;
 import com.alllexe.inventoryservice.repository.InventoryRepository;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 
 @Service
 @RequiredArgsConstructor
+@Slf4j
 public class InventoryService {
 
  private final InventoryRepository inventoryRepository;
 
  @Transactional(readOnly = true)
+ @SneakyThrows
  public List<InventoryResponse> isInStock(List<String> skuCodes) {
+// log.info("Wait started");
+// Thread.sleep(10000);
+// log.info("Wait ended");
  return inventoryRepository.findBySkuCodeIn(skuCodes).stream()
  .map(inventory -> InventoryResponse.builder()
  .skuCode(inventory.getSkuCode())

order-service/build.gradle

@@ -18,6 +18,8 @@ repositories {
 
 dependencies {
 implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
+implementation 'org.springframework.cloud:spring-cloud-starter-circuitbreaker-resilience4j'
+implementation 'org.springframework.boot:spring-boot-starter-actuator'
 implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 implementation 'org.springframework.boot:spring-boot-starter-web'
 implementation 'org.springframework.boot:spring-boot-starter-webflux'

order-service/src/main/java/com/alllexe/orderservice/controller/OrderController.java

@@ -2,6 +2,9 @@
 
 import com.alllexe.orderservice.dto.OrderRequest;
 import com.alllexe.orderservice.service.OrderService;
+import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
+import io.github.resilience4j.retry.annotation.Retry;
+import io.github.resilience4j.timelimiter.annotation.TimeLimiter;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpStatus;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -10,6 +13,8 @@
 import org.springframework.web.bind.annotation.ResponseStatus;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.concurrent.CompletableFuture;
+
 @RestController
 @RequestMapping("/api/order")
 @RequiredArgsConstructor
@@ -19,8 +24,14 @@ public class OrderController {
 
  @PostMapping
  @ResponseStatus(HttpStatus.CREATED)
- public String placeOrder(@RequestBody OrderRequest orderRequest) {
- orderService.placeOrder(orderRequest);
- return "Order placed successfully";
+ @CircuitBreaker(name = "inventory", fallbackMethod = "fallbackMethod")
+ @TimeLimiter(name = "inventory")
+ @Retry(name = "inventory")
+ public CompletableFuture<String> placeOrder(@RequestBody OrderRequest orderRequest) {
+ return CompletableFuture.supplyAsync(() -> orderService.placeOrder(orderRequest));
+ }
+
+ public CompletableFuture<String> fallbackMethod(OrderRequest orderRequest, RuntimeException runtimeException) {
+ return CompletableFuture.supplyAsync(() ->"Oops! Something went wrong. Please order after some time!");
  }
 }

order-service/src/main/java/com/alllexe/orderservice/service/OrderService.java

@@ -23,7 +23,7 @@ public class OrderService {
  private final WebClient.Builder webClientBuilder;
 
  @Transactional
- public void placeOrder(OrderRequest orderRequest) {
+ public String placeOrder(OrderRequest orderRequest) {
  Order order = new Order();
  order.setOrderNumber(UUID.randomUUID().toString());
  List<OrderLineItems> orderLineItems = orderRequest.getOrderLineItemsDtoList()
@@ -50,6 +50,7 @@ public void placeOrder(OrderRequest orderRequest) {
 
  if (allProductsInStock) {
  orderRepository.save(order);
+ return "Order placed successfully";
  } else {
  throw new IllegalArgumentException("Product is not in stock");
  }

order-service/src/main/resources/application.properties

@@ -9,3 +9,29 @@ spring.datasource.password=postgres
 spring.jpa.hibernate.ddl-auto=update
 
 eureka.client.service-url.defaultZone=http://eureka:password@localhost:8761/eureka
+
+management.health.circuitbreakers.enabled=true
+management.endpoints.web.exposure.include=*
+management.endpoint.health.show-details=always
+
+#Resilinece4j Properties
+resilience4j.circuitbreaker.instances.inventory.registerHealthIndicator=true
+resilience4j.circuitbreaker.instances.inventory.event-consumer-buffer-size=10
+resilience4j.circuitbreaker.instances.inventory.slidingWindowType=COUNT_BASED
+resilience4j.circuitbreaker.instances.inventory.slidingWindowSize=5
+resilience4j.circuitbreaker.instances.inventory.failureRateThreshold=50
+resilience4j.circuitbreaker.instances.inventory.waitDurationInOpenState=5s
+resilience4j.circuitbreaker.instances.inventory.permittedNumberOfCallsInHalfOpenState=3
+resilience4j.circuitbreaker.instances.inventory.automaticTransitionFromOpenToHalfOpenEnabled=true
+
+#Resilience4J Timeout Properties
+resilience4j.timelimiter.instances.inventory.timeout-duration=3s
+
+#Resilience4J Retry Properties
+resilience4j.retry.instances.inventory.max-attempts=3
+resilience4j.retry.instances.inventory.wait-duration=5s
+
+#Spring Cloud Stream Kafka Properties
+spring.cloud.stream.output-bindings=notificationEventSupplier
+spring.cloud.stream.bindings.notificationEventSupplier-out-0.destination=notification-events
+spring.sleuth.integration.enabled=true