Add trace logging sleuth zipkin

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

README.md

@@ -15,4 +15,8 @@ Based on [Spring Boot Microservices Full Course](https://www.youtube.com/playlis
 start keycloak in docker
 ```
 docker run -p 8181:8080 -e KEYCLOAK_ADMIN=admin -e KEYCLOAK_ADMIN_PASSWORD=admin quay.io/keycloak/keycloak:18.0.0 start-dev
+```
+start zipkin in docker
+```
+docker run -d -p 9411:9411 openzipkin/zipkin
 ```

api-gateway/build.gradle

@@ -12,6 +12,8 @@ repositories {
 dependencies {
  implementation 'org.springframework.cloud:spring-cloud-starter-gateway'
  implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
+ implementation 'org.springframework.cloud:spring-cloud-starter-sleuth'
+ implementation 'org.springframework.cloud:spring-cloud-sleuth-zipkin'
  implementation 'org.springframework.boot:spring-boot-starter-oauth2-resource-server'
  implementation 'org.springframework.boot:spring-boot-starter-security'
 }

api-gateway/src/main/resources/application.properties

@@ -24,3 +24,6 @@ spring.cloud.gateway.routes[3].uri=http://localhost:8761
 spring.cloud.gateway.routes[3].predicates[0]=Path=/eureka/**
 
 spring.security.oauth2.resourceserver.jwt.issuer-uri=http://localhost:8181/realms/spring-boot-microservices-realm
+
+spring.zipkin.base-url=http://localhost:9411
+sping.sleuth.sampler.probability=1.0

discovery-server/build.gradle

@@ -12,4 +12,6 @@ repositories {
 dependencies {
  implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-server'
  implementation 'org.springframework.boot:spring-boot-starter-security'
+ implementation 'org.springframework.cloud:spring-cloud-starter-sleuth'
+ implementation 'org.springframework.cloud:spring-cloud-sleuth-zipkin'
 }

discovery-server/src/main/resources/application.properties

@@ -5,4 +5,7 @@ eureka.client.register-with-eureka=false
 eureka.client.fetch-registry=false
 
 eureka.username=${EUREKA_USERNAME:eureka}
-eureka.password=${EUREKA_PASSWORD:password}
+eureka.password=${EUREKA_PASSWORD:password}
+
+spring.zipkin.base-url=http://localhost:9411
+sping.sleuth.sampler.probability=1.0

inventory-service/build.gradle

@@ -11,6 +11,8 @@ repositories {
 
 dependencies {
 implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
+implementation 'org.springframework.cloud:spring-cloud-starter-sleuth'
+implementation 'org.springframework.cloud:spring-cloud-sleuth-zipkin'
 implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 implementation 'org.springframework.boot:spring-boot-starter-web'
 compileOnly 'org.projectlombok:lombok'

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

@@ -8,4 +8,7 @@ spring.datasource.password=postgres
 
 spring.jpa.hibernate.ddl-auto=create-drop
 
-eureka.client.service-url.defaultZone=http://eureka:password@localhost:8761/eureka
+eureka.client.service-url.defaultZone=http://eureka:password@localhost:8761/eureka
+
+spring.zipkin.base-url=http://localhost:9411
+sping.sleuth.sampler.probability=1.0

order-service/build.gradle

@@ -19,6 +19,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.cloud:spring-cloud-starter-sleuth'
+implementation 'org.springframework.cloud:spring-cloud-sleuth-zipkin'
 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'

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

@@ -7,6 +7,8 @@
 import com.alllexe.orderservice.model.OrderLineItems;
 import com.alllexe.orderservice.repository.OrderRepository;
 import lombok.RequiredArgsConstructor;
+import org.springframework.cloud.sleuth.Span;
+import org.springframework.cloud.sleuth.Tracer;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.reactive.function.client.WebClient;
@@ -21,6 +23,7 @@ public class OrderService {
 
  private final OrderRepository orderRepository;
  private final WebClient.Builder webClientBuilder;
+ private final Tracer tracer;
 
  @Transactional
  public String placeOrder(OrderRequest orderRequest) {
@@ -37,22 +40,27 @@ public String placeOrder(OrderRequest orderRequest) {
  .map(OrderLineItems::getSkuCode)
  .toList();
 
- // Call Inventory Service, and place order if product is in stock
- InventoryResponse[] inventoryResponseArray = webClientBuilder.build().get()
- .uri("http://inventory-service/api/inventory",
- uriBuilder -> uriBuilder.queryParam("skuCodes", skuCodes).build())
- .retrieve()
- .bodyToMono(InventoryResponse[].class)
- .block();
+ Span inventoryServiceLookup = tracer.nextSpan().name("InventoryServiceLookup");
+ try (Tracer.SpanInScope tracerInScope = tracer.withSpan(inventoryServiceLookup.start())) {
+ // Call Inventory Service, and place order if product is in stock
+ InventoryResponse[] inventoryResponseArray = webClientBuilder.build().get()
+ .uri("http://inventory-service/api/inventory",
+ uriBuilder -> uriBuilder.queryParam("skuCodes", skuCodes).build())
+ .retrieve()
+ .bodyToMono(InventoryResponse[].class)
+ .block();
 
- boolean allProductsInStock = Arrays.stream(inventoryResponseArray)
- .allMatch(InventoryResponse::isInStock);
+  boolean allProductsInStock = Arrays.stream(inventoryResponseArray)
+  .allMatch(InventoryResponse::isInStock);
 
- if (allProductsInStock) {
- orderRepository.save(order);
- return "Order placed successfully";
- } else {
- throw new IllegalArgumentException("Product is not in stock");
+ if (allProductsInStock) {
+ orderRepository.save(order);
+ return "Order placed successfully";
+ } else {
+ throw new IllegalArgumentException("Product is not in stock");
+ }
+ } finally {
+ inventoryServiceLookup.end();
  }
  }
 

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

@@ -34,4 +34,7 @@ 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
+spring.sleuth.integration.enabled=true
+
+spring.zipkin.base-url=http://localhost:9411
+sping.sleuth.sampler.probability=1.0