Что реализовывал с помощью ETCD?

Использование ETCD в PHP Backend-разработке

В моей практике ETCD использовался как распределённое хранилище конфигураций и координатор для кластерных систем. Вот ключевые сценарии применения:

Хранение конфигураций микросервисов

Динамическая конфигурация стала основным кейсом - вместо статических config-файлов, все настройки хранились в ETCD:

use Etcd\Client;

class ConfigManager {
    private $etcdClient;
    
    public function __construct(string $etcdUrl) {
        $this->etcdClient = new Client($etcdUrl);
    }
    
    public function getServiceConfig(string $serviceName): array {
        $key = "/config/services/{$serviceName}";
        $response = $this->etcdClient->get($key);
        
        return json_decode($response['kvs'][0]['value'], true);
    }
    
    public function watchConfigChanges(string $serviceName): void {
        $key = "/config/services/{$serviceName}";
        
        $this->etcdClient->watch($key, function($events) {
            foreach ($events as $event) {
                $this->reloadConfiguration($event['kv']['value']);
            }
        });
    }
}

Service Discovery в микросервисной архитектуре

Реализовывал сервис-дискавери для автоматической регистрации и обнаружения инстансов:

class ServiceRegistry {
    private $leaseId;
    private $serviceId;
    
    public function registerService(string $serviceName, string $endpoint): void {
        // Создаем lease на 30 секунд
        $lease = $this->etcdClient->leaseGrant(30);
        $this->leaseId = $lease['ID'];
        
        $this->serviceId = uniqid("{$serviceName}-", true);
        $key = "/services/{$serviceName}/{$this->serviceId}";
        
        $this->etcdClient->put($key, json_encode([
            'endpoint' => $endpoint,
            'timestamp' => time(),
            'status' => 'healthy'
        ]), ['lease' => $this->leaseId]);
        
        // Продление lease каждые 15 секунд
        $this->keepAliveLease();
    }
    
    public function discoverServices(string $serviceName): array {
        $key = "/services/{$serviceName}";
        $response = $this->etcdClient->get($key, ['prefix' => true]);
        
        return array_map(function($kv) {
            return json_decode($kv['value'], true);
        }, $response['kvs']);
    }
}

Распределённые блокировки

Реализовывал механизм распределённых блокировок для координации задач между инстансами:

class DistributedLock {
    private $lockKey;
    private $leaseId;
    
    public function acquire(string $resource, int $ttl = 10): bool {
        $this->lockKey = "/locks/{$resource}";
        
        try {
            // Создаем временную блокировку
            $lease = $this->etcdClient->leaseGrant($ttl);
            $this->leaseId = $lease['ID'];
            
            // Пытаемся занять ключ
            $txnResponse = $this->etcdClient->transaction(
                [
                    'compare' => [
                        [
                            'key' => $this->lockKey,
                            'result' => 'EQUAL',
                            'target' => 'CREATE',
                            'create_revision' => 0
                        ]
                    ],
                    'success' => [
                        ['request_put' => [
                            'key' => $this->lockKey,
                            'value' => gethostname(),
                            'lease' => $this->leaseId
                        ]]
                    ],
                    'failure' => []
                ]
            );
            
            return $txnResponse['succeeded'];
        } catch (Exception $e) {
            return false;
        }
    }
}

Координация распределённых джобов

Использовал ETCD для координации периодических задач в кластере:

# Пример структуры в ETCD для распределённых задач
/cron/jobs/daily-report:
  leader: "server-123"
  last_run: "2024-01-15T00:00:00Z"
  next_run: "2024-01-16T00:00:00Z"
  instances:
    - server-123: "active"
    - server-456: "standby"

Особенности реализации

Ключевые моменты, которые учитывал при работе:

1. Согласованность данных - ETCD обеспечивает сильную согласованность через Raft-протокол
2. Надёжность lease-механизма - автоматическое удаление ключей при недоступности сервиса
3. Watch-механизм - подписка на изменения без постоянного опроса
4. Транзакционность - использование транзакций для атомарных операций

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

Столкнулся с несколькими типичными проблемами:

• Сетевые задержки - настраивал таймауты и ретраи с экспоненциальным откатом
• Раздувание хранилища - реализовывал TTL для временных данных
• Гонки условий - использовал транзакции с Compare-and-Swap (CAS)

Интеграция с PHP-экосистемой

Использовал библиотеку ETCD v3 API через gRPC с оптимизациями:

• Компрессия запросов
• Connection pooling
• Локальный кэш конфигураций с инвалидацией по watch-событиям

ETCD доказал свою эффективность как надёжное распределённое хранилище для критически важных метаданных, хотя для больших payload данных требовалось дополнительное решение (например, S3 или базы данных).