Какие знаешь подходы к работе с интеграциями?

Подходы к работе с интеграциями

В моей практике я применял различные подходы к интеграции с внешними системами, которые выбираются в зависимости от требований, типа интеграции и архитектуры приложения.

1. REST API интеграция

REST — наиболее распространенный подход. Использую WebClient или HttpClient:

public class ExternalApiClient {
    private final WebClient webClient;
    
    public ExternalApiClient(WebClient.Builder builder) {
        this.webClient = builder.baseUrl("https://api.example.com").build();
    }
    
    public Mono<UserResponse> getUser(String id) {
        return webClient.get()
            .uri("/users/{id}", id)
            .header("Authorization", "Bearer " + getToken())
            .retrieve()
            .onStatus(HttpStatus::isError, response -> 
                Mono.error(new ApiException("Failed to get user")))
            .bodyToMono(UserResponse.class)
            .timeout(Duration.ofSeconds(5));
    }
}

Преимущества: простота, стандартность, хорошая поддержка в библиотеках.

Недостатки: синхронные операции могут блокировать потоки; высокая latency при частых запросах.

2. Event-driven интеграция (асинхронная)

Для асинхронной обработки использую очереди сообщений (RabbitMQ, Kafka):

@Service
public class OrderService {
    private final RabbitTemplate rabbitTemplate;
    
    public void createOrder(Order order) {
        orderRepository.save(order);
        rabbitTemplate.convertAndSend("orders.exchange", 
            "orders.created", 
            new OrderCreatedEvent(order.getId(), order.getAmount()));
    }
}

@Service
public class PaymentService {
    @RabbitListener(queues = "payment.queue")
    public void processPayment(OrderCreatedEvent event) {
        paymentGateway.charge(event.getAmount());
    }
}

Преимущества: слабая связанность, масштабируемость, надёжность через retry механизм.

3. Webhook интеграция

Для получения уведомлений от внешних систем:

@RestController
@RequestMapping("/webhooks")
public class WebhookController {
    @PostMapping("/payment-status")
    public ResponseEntity<Void> handlePaymentWebhook(@RequestBody WebhookPayload payload) {
        if (!validateSignature(payload)) {
            return ResponseEntity.status(HttpStatus.UNAUTHORIZED).build();
        }
        paymentEventQueue.add(payload);
        return ResponseEntity.ok().build();
    }
}

Преимущества: push-модель, низкая latency, не требует периодических опросов.

4. gRPC интеграция

Для высокопроизводительного взаимодействия микросервисов:

Преимущества: высокая производительность, бинарный протокол, встроенная поддержка streaming.

5. GraphQL интеграция

Для гибких запросов данных из нескольких источников — получают только нужные поля.

Преимущества: гибкость запросов, уменьшение overfetching, хороша для микросервисной архитектуры.

Best Practices

• Retry логика: используй exponential backoff для временных сбоев
• Taimeouts: ВСЕГДА устанавливай таймауты на интеграции
• Circuit Breaker: защищай систему через Resilience4j
• Логирование: логируй все запросы и ошибки
• Мониторинг: отслеживай метрики (latency, success rate, error rate)
• Тестирование: используй Mock или WireMock для unit тестов

Выбор подхода зависит от требований: REST для простых интеграций, события для масштабируемости, gRPC для производительности.