С какими сервисами интегрировался

С какими сервисами интегрировался

Типология интеграций

Этот вопрос проверяет:

• Практический опыт работы с внешними API
• Умение обрабатывать ошибки и rate limits
• Знание протоколов и форматов (REST, SOAP, GraphQL)
• Опыт с третьесторонними сервисами

Категории сервисов, с которыми часто интегрируются

1. Payment Gateways (платёжные системы)

Примеры: Stripe, PayPal, Yandex.Kassa, Sberbank

Интеграция Stripe:
```java

public class PaymentService { private Stripe stripe = new Stripe(apiKey);

public Payment createPayment(PaymentRequest request) {
    try {
        // Создать платёж
        ChargeCreateParams params = ChargeCreateParams.builder()
            .setAmount((long) request.getAmount() * 100) // в копейках
            .setCurrency("rub")
            .setSource(request.getTokenId())
            .setDescription("Order #" + request.getOrderId())
            .putMetadata("orderId", request.getOrderId())
            .build();
        
        Charge charge = Charge.create(params);
        
        // Обработать результат
        if (charge.getPaid()) {
            return Payment.builder()
                .status(PaymentStatus.SUCCESS)
                .transactionId(charge.getId())
                .amount(request.getAmount())
                .build();
        }
    } catch (StripeException e) {
        // Обработать ошибку
        if (e instanceof CardException) {
            // Карта отклонена
            throw new PaymentException("Card declined: " + e.getMessage());
        } else if (e instanceof RateLimitException) {
            // Слишком много запросов - retry
            return retry(request);
        } else if (e instanceof ApiException) {
            // Ошибка сервиса - логировать и уведомить
            logger.error("Stripe API error", e);
            throw new PaymentException("Payment service error");
        }
    }
}

}

Сложности:

• Различные типы ошибок карт
• Webhooks для асинхронных подтверждений
• PCI-DSS требования (никогда не хранить полные карты)
• Возвраты (refunds) требуют собственной логики

2. SMS/Email Gateway (уведомления)

Примеры: Twilio, SendGrid, SES (Amazon), Яндекс.Облако

Интеграция Twilio:
```java
@Component
public class NotificationService {
    private Twilio twilio = new Twilio(accountSid, authToken);
    
    public void sendSMS(String phoneNumber, String message) {
        try {
            Message sms = Message.creator(
                new PhoneNumber("+79991234567"), // From
                new PhoneNumber(phoneNumber),    // To
                message                          // Message
            ).create();
            
            logger.info("SMS sent: " + sms.getSid());
        } catch (Exception e) {
            // Retry logic
            handleError(phoneNumber, message, e);
        }
    }
    
    // SendGrid Email
    public void sendEmail(EmailRequest request) throws Exception {
        Mail mail = new Mail();
        mail.setFrom(new Email("noreply@company.com"));
        mail.setSubject(request.getSubject());
        
        Personalization personalization = new Personalization();
        personalization.addTo(new Email(request.getToEmail()));
        mail.addPersonalization(personalization);
        
        Content content = new Content(
            "text/html",
            request.getBodyHtml()
        );
        mail.addContent(content);
        
        SendGrid sg = new SendGrid(apiKey);
        Request httpRequest = new Request();
        httpRequest.setMethod(Method.POST);
        httpRequest.setEndpoint("mail/send");
        httpRequest.setBody(mail.build());
        
        Response response = sg.api(httpRequest);
        if (response.getStatusCode() >= 400) {
            throw new Exception("Email send failed: " + response.getBody());
        }
    }
}

Сложности:

• Bounces (неверные адреса)
• Spam folder (неправильная конфигурация SPF/DKIM)
• Rate limits (обычно 100 сообщений/сек)
• Async доставка требует webhook callbacks

3. Cloud Storage (хранилище файлов)

Примеры: AWS S3, Google Cloud Storage, Azure Blob Storage

Интеграция AWS S3:
```java
@Configuration

public class S3Config { @Bean public AmazonS3 amazonS3() { return AmazonS3ClientBuilder .standard() .withRegion(Regions.EU_WEST_1) .withCredentials( new AWSStaticCredentialsProvider( new BasicAWSCredentials(accessKey, secretKey) ) ) .build(); } }

@Service

public class FileStorageService { @Autowired private AmazonS3 s3;

public String uploadFile(MultipartFile file, String userId) throws IOException {
    String key = "users/" + userId + "/" + file.getOriginalFilename();
    
    try {
        // Upload файл
        ObjectMetadata metadata = new ObjectMetadata();
        metadata.setContentType(file.getContentType());
        metadata.setContentLength(file.getSize());
        
        s3.putObject(
            new PutObjectRequest(
                "my-bucket",
                key,
                file.getInputStream(),
                metadata
            ).withCannedAcl(CannedAccessControlList.Private)
        );
        
        return "s3://my-bucket/" + key;
    } catch (AmazonServiceException e) {
        logger.error("S3 upload failed", e);
        throw new FileStorageException("Upload failed: " + e.getMessage());
    }
}

public String generatePresignedUrl(String key, int expirationMinutes) {
    java.util.Date expiration = new java.util.Date();
    long expTimeMillis = expiration.getTime();
    expTimeMillis += 1000 * 60 * expirationMinutes;
    expiration.setTime(expTimeMillis);
    
    GeneratePresignedUrlRequest generatePresignedUrlRequest =
        new GeneratePresignedUrlRequest("my-bucket", key)
            .withMethod(HttpMethod.GET)
            .withExpiration(expiration);
    
    URL url = s3.generatePresignedUrl(generatePresignedUrlRequest);
    return url.toString();
}

}

Сложности:

• Access control (bucket policies, IAM)
• Presigned URLs для безопасного доступа
• Multipart upload для больших файлов
• CloudFront CDN для быстрого доступа

4. Map/Location Services (геолокация)

Примеры: Google Maps, Yandex Maps, OpenStreetMap

Интеграция Google Maps:
```java
@Service
public class LocationService {
    private GeoApiContext geoContext = new GeoApiContext
        .Builder()
        .apiKey(googleMapsApiKey)
        .build();
    
    // Геокодирование (адрес → координаты)
    public LatLng geocode(String address) throws Exception {
        GeocodingResult[] results = GeocodingApi.geocode(geoContext, address)
            .await();
        
        if (results.length == 0) {
            throw new LocationException("Address not found");
        }
        
        return results[0].geometry.location;
    }
    
    // Обратное геокодирование (координаты → адрес)
    public String reverseGeocode(double lat, double lng) throws Exception {
        GeocodingResult[] results = GeocodingApi
            .reverseGeocode(geoContext, new LatLng(lat, lng))
            .await();
        
        return results[0].formattedAddress;
    }
    
    // Расстояние между точками
    public long getDistanceMeters(LatLng from, LatLng to) throws Exception {
        DistanceMatrix result = DistanceMatrixApi.newRequest(geoContext)
            .origins(from)
            .destinations(to)
            .mode(TravelMode.DRIVING)
            .await();
        
        return result.rows[0].elements[0].distance.inMeters;
    }
    
    // Маршруты
    public List<LatLng> getRoute(LatLng from, LatLng to) throws Exception {
        DirectionsResult result = DirectionsApi.newRequest(geoContext)
            .origin(from)
            .destination(to)
            .mode(TravelMode.WALKING)
            .await();
        
        return Arrays.stream(result.routes[0].legs[0].steps)
            .map(step -> step.startLocation)
            .collect(Collectors.toList());
    }
}

Сложности:

• Rate limits (2500 requests/day бесплатно)
• Кеширование результатов geocoding
• Accuracy различается в разных странах
• Fallback на другой сервис при отказе

5. Authentication/Identity Services

Примеры: OAuth2 провайдеры (Google, Facebook, GitHub), Auth0, Keycloak

Общий паттерн OAuth2:
```java
@Configuration
@EnableWebSecurity

public class SecurityConfig { @Bean public SecurityFilterChain filterChain(HttpSecurity http) throws Exception { http .authorizeHttpRequests((authz) -> authz .requestMatchers("/", "/login").permitAll() .anyRequest().authenticated() ) .oauth2Login( oauth2 -> oauth2 .loginPage("/login") .defaultSuccessUrl("/dashboard") );

    return http.build();
}

}

@RestController

public class UserController { @GetMapping("/user") public Map<String, Object> user( @RegisteredOAuth2AuthorizedClient OAuth2AuthorizedClient client, @AuthenticationPrincipal OAuth2User principal ) { return Map.ofEntries( Map.entry("name", principal.getAttribute("name")), Map.entry("email", principal.getAttribute("email")), Map.entry("provider", client.getClientRegistration().getRegistrationId()) ); } }

Сложности:

• Различные scope требования
• Token refresh при истечении
• Синхронизация user data
• Social login versus enterprise SSO

6. Analytics/Tracking Services

Примеры: Google Analytics, Amplitude, Segment, Mixpanel

Интеграция Segment (universal analytics):
```java
@Service
public class AnalyticsService {
    private Analytics analytics;
    
    @PostConstruct
    public void init() {
        analytics = Analytics.builder(writeKey)
            .build();
    }
    
    // Трекинг события
    public void trackEvent(String userId, String eventName, Map<String, Object> properties) {
        analytics.enqueue(TrackMessage.builder(eventName)
            .userId(userId)
            .properties(properties)
            .timestamp(new Date())
            .build()
        );
    }
    
    // User identification
    public void identifyUser(User user) {
        analytics.enqueue(IdentifyMessage.builder()
            .userId(user.getId())
            .traits(Map.of(
                "firstName", user.getFirstName(),
                "email", user.getEmail(),
                "plan", user.getPlan()
            ))
            .build()
        );
    }
    
    @PreDestroy
    public void shutdown() {
        analytics.shutdown();
    }
}

Сложности:

• Батчирование событий
• Privacy regulations (GDPR, CCPA)
• User consent для tracking
• Асинхронная отправка без impact на UX

7. Messaging Services

Примеры: Slack, Discord, Telegram, RabbitMQ

Интеграция Slack Webhook:
```java
@Service

public class SlackNotificationService { private WebClient webClient;

public void notifySlack(String message, String channel) {
    Map<String, Object> payload = Map.of(
        "channel", channel,
        "text", message,
        "icon_emoji", ":robot_face:",
        "blocks", List.of(
            Map.of(
                "type", "section",
                "text", Map.of("type", "mrkdwn", "text", message)
            )
        )
    );
    
    webClient.post()
        .uri(slackWebhookUrl)
        .contentType(MediaType.APPLICATION_JSON)
        .bodyValue(payload)
        .retrieve()
        .toBodilessEntity()
        .doOnError(error -> logger.error("Slack notification failed", error))
        .subscribe();
}

}

8. Search Services

Примеры: Elasticsearch, Solr, Algolia

Интеграция Elasticsearch:
```java
@Service
public class SearchService {
    @Autowired
    private ElasticsearchTemplate elasticsearchTemplate;
    
    public List<Product> searchProducts(String query) {
        SearchQuery searchQuery = new SearchQuery();
        searchQuery.setQuery(QueryBuilders.multiMatchQuery(query)
            .field("name", 2.0)
            .field("description", 1.0)
            .fuzziness(Fuzziness.AUTO)
        );
        
        SearchHits<Product> searchHits = elasticsearchTemplate
            .search(searchQuery, Product.class);
        
        return searchHits.getSearchHits()
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
    }
}

Общие паттерны при интеграции

@Component
public class ExternalServiceClient {
    @Autowired
    private RestTemplate restTemplate;
    
    @Autowired
    private CircuitBreaker circuitBreaker;
    
    // 1. Retry при временных сбоях
    @Retryable(
        value = { RestClientException.class },
        maxAttempts = 3,
        backoff = @Backoff(delay = 1000)
    )
    public String callExternalAPI(String endpoint) {
        try {
            return restTemplate.getForObject(endpoint, String.class);
        } catch (ResourceAccessException e) {
            logger.warn("Retry attempt for " + endpoint);
            throw e;
        }
    }
    
    // 2. Circuit breaker при частых сбоях
    @CircuitBreaker(name = "externalAPI")
    public String callWithFallback(String endpoint) {
        return restTemplate.getForObject(endpoint, String.class);
    }
    
    // 3. Fallback метод
    @Recover
    public String fallback(Exception e) {
        logger.error("API failed, using fallback", e);
        return "";
    }
    
    // 4. Timeout
    public String callWithTimeout(String endpoint) {
        return restTemplate
            .getForObject(endpoint, String.class);
            // Сконфигурирован timeout в RestTemplateBuilder
    }
}

Резюме интеграций

Основные принципы при интеграции:

1. Error Handling — retry logic, fallbacks, graceful degradation
2. Rate Limiting — batch requests, cache результаты
3. Async Integration — webhooks, message queues
4. Timeouts — всегда используй timeout
5. Logging/Monitoring — трекируй все внешние вызовы
6. Security — никогда не коммитай API keys
7. Versioning — будьте готовы к изменению API

Наиболее часто используемые:

• Payment гейтвеи (Stripe, PayPal)
• Облако (AWS S3, Google Cloud)
• Authentication (OAuth2, SSO)
• Notifications (SMS, Email)
• Analytics (Google Analytics, Segment)