Что использовал в интеграционных ландшафтах

Инструменты и подходы в интеграционных ландшафтах

Интеграционный ландшафт — это набор систем (часто разнородных), которые нужно соединить между собой. В своей практике использовал множество инструментов и подходов для синхронизации данных и обмена сообщениями.

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

Самый популярный способ интеграции между микросервисами:

@Service
public class ExternalPaymentIntegration {
    private final RestTemplate restTemplate;
    private final PaymentProperties properties;
    
    public PaymentResponse processPayment(PaymentRequest request) {
        ResponseEntity<PaymentResponse> response = restTemplate.postForEntity(
            properties.getPaymentServiceUrl() + "/process",
            request,
            PaymentResponse.class
        );
        
        if (response.getStatusCode() != HttpStatus.OK) {
            throw new PaymentIntegrationException("Payment service error");
        }
        return response.getBody();
    }
}

Используемые технологии: RestTemplate, WebClient, Retrofit, OpenAPI.

2. Асинхронная интеграция через Message Brokers

Для несвязанных систем использовал очереди сообщений.

RabbitMQ (AMQP)

@Service
public class OrderEventPublisher {
    private final RabbitTemplate rabbitTemplate;
    
    public void publishOrderCreated(OrderCreatedEvent event) {
        rabbitTemplate.convertAndSend(
            "order.exchange",
            "order.created",
            event
        );
    }
}

@Service
public class OrderEventConsumer {
    @RabbitListener(queues = "order.created.queue")
    public void handleOrderCreated(OrderCreatedEvent event) {
        notificationService.sendOrderConfirmation(event.getOrderId());
    }
}

Apache Kafka

@Service
public class KafkaOrderProducer {
    private final KafkaTemplate<String, OrderEvent> kafkaTemplate;
    
    public void sendOrderEvent(OrderEvent event) {
        kafkaTemplate.send("orders-topic", event.getOrderId().toString(), event);
    }
}

3. SOAP интеграция (Legacy)

Для интеграции с устаревшими системами использовал SOAP.

4. ETL и Spring Batch

Для синхронизации больших объемов данных:

@Configuration
public class DataSyncJobConfig {
    @Bean
    public Job dataSyncJob(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
        return new JobBuilder("dataSyncJob", jobRepository)
            .start(dataSyncStep(jobRepository, transactionManager))
            .build();
    }
    
    @Bean
    public Step dataSyncStep(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
        return new StepBuilder("dataSyncStep", jobRepository)
            .<User, UserDTO>chunk(100, transactionManager)
            .reader(userReader())
            .processor(userProcessor())
            .writer(externalSystemWriter())
            .faultTolerant()
            .retry(IOException.class)
            .retryLimit(3)
            .build();
    }
}

5. File-based интеграция

Для обмена данными через файлы (EDI, CSV):

@Service
public class FileIntegrationService {
    public void importOrdersFromFile(File file) throws IOException {
        try (BufferedReader reader = new BufferedReader(new FileReader(file))) {
            String line;
            while ((line = reader.readLine()) != null) {
                Order order = parseOrderLine(line);
                orderRepository.save(order);
            }
        }
    }
}

6. API Gateway

Для управления потоком запросов между системами использовал Spring Cloud Gateway.

7. WebSocket для реального времени

@Component
public class InventoryWebSocketHandler extends TextWebSocketHandler {
    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) throws IOException {
        InventoryUpdate update = parseMessage(message);
        inventoryService.updateStock(update);
        broadcastToAllClients(update);
    }
}

8. Change Data Capture (CDC)

Использование Debezium для отслеживания изменений в БД.

9. Resilience Pattern

@Service
public class ExternalServiceClient {
    @CircuitBreaker(name = "externalService", fallbackMethod = "fallback")
    @Retry(name = "externalService", fallbackMethod = "fallback")
    public PaymentResponse callExternalPaymentService(PaymentRequest request) {
        return restTemplate.postForObject(
            "https://external-api.com/payment",
            request,
            PaymentResponse.class
        );
    }
    
    public PaymentResponse fallback(PaymentRequest request, Exception e) {
        return PaymentResponse.pending();
    }
}

10. Инструменты

• MuleSoft Anypoint — ESB для complex интеграций
• Apache Camel — маршрутизация и трансформация
• Talend — визуальная разработка ETL
• Spring Cloud Stream — для message-driven микросервисов

Мой подход к интеграциям

1. Асинхронность где возможно — избегаем блокирующих зависимостей
2. Resilience — retry, circuit breaker, timeouts
3. Monitoring — логируем, метриксим, алертим
4. Testability — мокируем external системы
5. Graceful degradation — система работает, даже если одна интеграция упала

Каждый интеграционный ландшафт уникален. Выбор инструмента зависит от требований к latency, throughput, надежности и scale.