Создание микросервисов со Spring Boot и Docker

@SpringBootApplication
public class ProductServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProductServiceApplication.class, args);
    }
}
 
@RestController
@RequestMapping("/products")
class ProductController {
    private final ProductRepository repository;
    
    // Внедрение зависимостей через конструктор
    ProductController(ProductRepository repository) {
        this.repository = repository;
    }
    
    @GetMapping
    public List<Product> findAll() {
        return repository.findAll();
    }
    
    @PostMapping
    public Product create(@RequestBody Product product) {
        return repository.save(product);
    }
}

FROM openjdk:11-jre-slim
WORKDIR /app
COPY target/product-service.jar app.jar
ENTRYPOINT ["java", "-jar", "app.jar"]

@Configuration
public class GatewayConfig {
@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
    return builder.routes()
        .route("product_route", r -> r.path("/products/**")
            .uri("lb://product-service"))
        .route("order_route", r -> r.path("/orders/[B]")
            .uri("lb://order-service"))
        .build();
}
}

src/
 ├── main/
 │   ├── java/
 │   │   └── com/example/demo/
 │   │       ├── DemoApplication.java
 │   │       ├── controller/
 │   │       ├── service/
 │   │       ├── repository/
 │   │       └── model/
 │   └── resources/
 │       ├── application.yml
 │       ├── bootstrap.yml
 │       └── static/
 └── test/
     └── ...

@Entity
public class Task {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    
    private String title;
    private String description;
    private LocalDateTime dueDate;
    private boolean completed;
    
    // Геттеры, сеттеры, конструкторы
}

public interface TaskRepository extends JpaRepository<Task, Long> {
    List<Task> findByCompleted(boolean completed);
    List<Task> findByDueDateBefore(LocalDateTime date);
}

@RestController
@RequestMapping("/tasks")
public class TaskController {
    private final TaskService taskService;
    
    public TaskController(TaskService taskService) {
        this.taskService = taskService;
    }
    
    @GetMapping
    public List<Task> getAllTasks() {
        return taskService.findAll();
    }
    
    @PostMapping
    public Task createTask(@Valid @RequestBody Task task) {
        return taskService.save(task);
    }
    
    // Другие методы CRUD
}

@Service
public class OrderService {
    private final RestTemplate restTemplate;
    
    // Предположим, URL сервиса приходит из конфига или сервиса обнаружения
    @Value("${services.payment.url}")
    private String paymentServiceUrl;
    
    public OrderService(RestTemplateBuilder builder) {
        this.restTemplate = builder.build();
    }
    
    public PaymentResponse processPayment(Order order) {
        PaymentRequest request = new PaymentRequest(order.getId(), order.getAmount());
        return restTemplate.postForObject(paymentServiceUrl + "/process", request, PaymentResponse.class);
    }
}

@Service
public class OrderService {
    private final RabbitTemplate rabbitTemplate;
    
    public OrderService(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }
    
    public void submitOrder(Order order) {
        // Сохраняем заказ локально
        orderRepository.save(order);
        
        // Отправляем событие в очередь для асинхронной обработки
        OrderCreatedEvent event = new OrderCreatedEvent(order.getId(), order.getItems());
        rabbitTemplate.convertAndSend("order-exchange", "order.created", event);
    }
}

# Многоэтапная сборка для минимизации размера итогового образа
FROM openjdk:11-jdk-slim as builder
WORKDIR /app
COPY . .
RUN ./mvnw clean package -DskipTests
 
FROM openjdk:11-jre-slim
WORKDIR /app
# Копируем только скомпилированный JAR
COPY --from=builder /app/target/*.jar app.jar
# Открываем порт и определяем точку входа
EXPOSE 8080
ENTRYPOINT ["java", "-XX:+UseContainerSupport", "-jar", "app.jar"]

@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {
   public static void main(String[] args) {
       SpringApplication.run(ConfigServerApplication.class, args);
   }
}

@CircuitBreaker(name = "paymentService", fallbackMethod = "processPaymentFallback")
public PaymentResponse processPayment(Order order) {
    // Вызов внешнего сервиса, который может упасть
    return paymentClient.processPayment(order);
}
 
public PaymentResponse processPaymentFallback(Order order, Exception e) {
    // Запасной вариант, когда сервис недоступен
    return new PaymentResponse(PaymentStatus.PENDING, "Payment service unavailable, will retry later");
}

@Bulkhead(name = "inventoryService")
public InventoryStatus checkInventory(String productId) {
    return inventoryClient.checkAvailability(productId);
}

implementation 'org.springframework.boot:spring-boot-starter-actuator'
implementation 'io.micrometer:micrometer-registry-prometheus'

@Configuration
@EnableResourceServer
public class ResourceServerConfig extends ResourceServerConfigurerAdapter {
    @Override
    public void configure(HttpSecurity http) throws Exception {
        http
            .authorizeRequests()
            .antMatchers("/public/[B]").permitAll()
            .antMatchers("/api/[/B]").authenticated();
    }
}

@Bean
public CircuitBreakerConfig circuitBreakerConfig() {
    return CircuitBreakerConfig.custom()
        .failureRateThreshold(50)           // Порог ошибок для разрыва цепи
        .waitDurationInOpenState(Duration.ofMillis(1000))  // Время в открытом состоянии
        .permittedNumberOfCallsInHalfOpenState(10)  // Количество тестовых вызовов
        .slidingWindowSize(100)             // Размер окна для расчёта частоты ошибок
        .build();
}

@Saga
public OrderResponse createOrder(OrderRequest request) {
    // Шаг 1: Проверка наличия товара
    InventoryReservation reservation = inventoryService.reserve(request.getItems());
    
    try {
        // Шаг 2: Обработка платежа
        Payment payment = paymentService.processPayment(request.getPaymentDetails());
        
        try {
            // Шаг 3: Создание заказа
            Order order = orderService.createOrder(request, reservation.getId(), payment.getId());
            return new OrderResponse(order.getId(), OrderStatus.CREATED);
        } catch (Exception e) {
            // Компенсация шага 2
            paymentService.refund(payment.getId());
            throw e;
        }
    } catch (Exception e) {
        // Компенсация шага 1
        inventoryService.cancelReservation(reservation.getId());
        throw e;
    }
}