Поддерживается ли контакт между Java и PHP частью последнего проекта

Взаимодействие между Java и PHP компонентами

Да, в моём последнем проекте мы имели дело с интеграцией между Java backend и PHP legacy системой. Это был интересный и достаточно сложный процесс, требовавший ясного протокола коммуникации.

Архитектурная ситуация

Проект состоял из:

• Java микросервис (новый, Spring Boot 2.7 на Kafka)
• PHP приложение (legacy, Symfony 4, существует 7+ лет)
• Общая PostgreSQL база (source of truth)

Оба компонента нужно было держать в синхронизированном состоянии по данным заказов и платежей.

Как мы организовали контакт

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

Ява часть предоставляла REST API, который использовалась PHP для:

// Java Spring Boot Controller
@RestController
@RequestMapping("/api/v1/orders")
public class OrderIntegrationController {
    
    @PostMapping("/sync")
    public ResponseEntity<OrderSyncResponse> syncOrder(
            @RequestBody OrderSyncRequest request,
            @RequestHeader("X-Legacy-System-Token") String token) {
        
        validateToken(token); // Аутентификация старой системы
        
        OrderSyncResponse response = orderService.syncFromLegacy(request);
        return ResponseEntity.ok(response);
    }
    
    @GetMapping("/{id}/status")
    public OrderStatus getOrderStatus(@PathVariable UUID id) {
        return orderService.getStatus(id);
    }
}

PHP код вызывал это:

// PHP Symfony code
class LegacyOrderSyncService {
    private $httpClient;
    
    public function syncOrderToJava(Order $order): void {
        $response = $this->httpClient->post(
            https://java-api.internal:8443/api/v1/orders/sync,
            [
                json => [
                    orderId => $order->getId(),
                    userId => $order->getUserId(),
                    amount => $order->getAmount(),
                    timestamp => $order->getCreatedAt()->format(DateTime::ISO8601),
                ],
                headers => [
                    X-Legacy-System-Token => getenv(LEGACY_TOKEN),
                ]
            ]
        );
        
        if ($response->getStatusCode() !== 200) {
            throw new SyncException("Ошибка синхронизации с Java сервисом");
        }
    }
}

2. Event-driven синхронизация через Kafka

Для более надёжного и масштабируемого подхода мы использовали Kafka message broker:

// Java Producer
@Component
public class OrderEventProducer {
    @Autowired
    private KafkaTemplate<String, OrderEvent> kafkaTemplate;
    
    public void publishOrderCreated(Order order) {
        OrderEvent event = new OrderEvent(
            EventType.ORDER_CREATED,
            order.getId(),
            order.toDTO(),
            Instant.now(ZoneOffset.UTC)
        );
        
        kafkaTemplate.send("orders.events", order.getId().toString(), event);
    }
}

PHP консьюмер (используя RdKafka):

// PHP Kafka Consumer
class OrderEventConsumer {
    public function consume(): void {
        $kafka = new \RdKafka\Consumer();
        $kafka->addBrokers("kafka:9092");
        
        $topic = $kafka->newTopic("orders.events");
        $topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);
        
        while (true) {
            $message = $topic->consume(0, 120000);
            
            if (null === $message) continue;
            
            if (RD_KAFKA_RESP_ERR_NO_ERROR !== $message->err) {
                // Handle error
                continue;
            }
            
            $event = json_decode($message->payload, true);
            $this->handleOrderEvent($event);
        }
    }
}

Проблемы и решения

Проблема 1: Data consistency

Проблема: Если Java создаст заказ, а PHP не синхронизирует его вовремя, возникает рассинхрон.

Решение: Использовали saga pattern для компенсирующих транзакций:

// Java Saga Orchestrator
@Service
public class OrderCreationSaga {
    
    public void executeOrderCreation(CreateOrderCommand cmd) throws Exception {
        // Шаг 1: Создать заказ в Java
        Order order = orderRepository.save(new Order(cmd));
        
        // Шаг 2: Уведомить PHP систему
        try {
            legacySystemClient.notifyOrderCreated(order);
        } catch (Exception e) {
            // Компенсирующая транзакция
            orderRepository.delete(order);
            throw new SagaException("Не удалось синхронизировать с legacy", e);
        }
        
        // Шаг 3: Опубликовать событие
        eventPublisher.publishOrderCreated(order);
    }
}

Проблема 2: Версионирование API

Проблема: PHP код отстал на несколько версий API, и новые поля ломали парсинг.

Решение: Внедрили API versioning с backward compatibility:

// Java API с версионированием
@RestController
@RequestMapping("/api/v1/orders")
public class OrderApi_V1 { ... }

@RestController
@RequestMapping("/api/v2/orders")
public class OrderApi_V2 {
    // Новые поля, но старые тоже поддерживаются
}

// Миграция PHP на v2 была постепенной

Проблема 3: Таймауты и переподключение

Проблема: PHP сервер медленнее, REST запросы иногда таймаут.

Решение: Реализовали retry mechanism с exponential backoff:

class RetryableHttpClient {
    public function request($method, $url, $data, $maxRetries = 3) {
        $attempt = 0;
        
        while ($attempt < $maxRetries) {
            try {
                return $this->httpClient->request($method, $url, $data);
            } catch (\Exception $e) {
                $attempt++;
                if ($attempt >= $maxRetries) throw $e;
                
                $delay = 1000 * (2 ** ($attempt - 1)); // exponential backoff
                usleep($delay * 1000);
            }
        }
    }
}

Мониторинг контакта

Мы установили health checks для обеспечения синхронизации:

// Java endpoint
@GetMapping("/health/legacy-sync")
public ResponseEntity<SyncHealthDto> getLegacySyncHealth() {
    // Проверяем, когда в последний раз PHP синхронизировал данные
    LocalDateTime lastSync = legacySyncRepository.getLastSuccessfulSync();
    Duration timeSinceSync = Duration.between(lastSync, now());
    
    if (timeSinceSync.toMinutes() > 5) {
        return ResponseEntity.status(503)
            .body(new SyncHealthDto("WARNING", "No sync for 5+ minutes"));
    }
    
    return ResponseEntity.ok(new SyncHealthDto("OK", lastSync));
}

Почему это работало

1. Четкие контракты — REST API контракт был документирован и версионирован
2. Асинхронность где возможно — Kafka для некритичных событий
3. Fault tolerance — retry logic, compensation transactions
4. Видимость — логирование и мониторинг каждого взаимодействия

Вывод

Интеграция между Java и PHP требует особой внимательности к контрактам, версионированию и обработке ошибок. Использование REST API для синхронных операций и Kafka для асинхронных событий дало нам хороший баланс между надёжностью и производительностью. Ключ — быть explicit в том, какие данные кто обновляет и когда.