Как реализовать Strangler Fig

Практическое руководство по внедрению паттерна Strangler Fig для постепенной миграции монолитного приложения в микросервисную архитектуру.

Шаг 1: Анализ и планирование

Аудит монолита

Проанализируйте текущую систему:

// Определите зависимости между модулями
interface DependencyMap {
  module: string;
  dependencies: string[];
  complexity: number;
  businessValue: number;
}

const modules: DependencyMap[] = [
  { module: 'auth', dependencies: [], complexity: 3, businessValue: 10 },
  { module: 'orders', dependencies: ['auth', 'inventory'], complexity: 8, businessValue: 9 },
  { module: 'notifications', dependencies: ['auth'], complexity: 2, businessValue: 5 }
];

Приоритизация

Выберите модули для миграции по критериям:

• Низкая связанность с другими модулями
• Высокая бизнес-ценность
• Частота изменений

Шаг 2: Создание прокси-слоя

Реализация роутера

class StranglerRouter {
  private routes: Map<string, 'legacy' | 'new'> = new Map();
  
  constructor(
    private legacyService: LegacyService,
    private newServices: Map<string, MicroService>
  ) {}
  
  async route(request: Request): Promise<Response> {
    const service = this.determineService(request.path);
    
    if (service === 'new') {
      const microservice = this.newServices.get(request.path);
      return await microservice.handle(request);
    }
    
    return await this.legacyService.handle(request);
  }
  
  private determineService(path: string): 'legacy' | 'new' {
    return this.routes.get(path) || 'legacy';
  }
}

Шаг 3: Миграция данных

Стратегия синхронизации

class DataSynchronizer {
  async syncToNewService(entity: Entity) {
    // Запись в обе системы
    await Promise.all([
      this.legacyDB.save(entity),
      this.newServiceDB.save(entity)
    ]);
  }
  
  async migrateHistoricalData(batchSize: number = 1000) {
    let offset = 0;
    while (true) {
      const batch = await this.legacyDB.fetch(offset, batchSize);
      if (batch.length === 0) break;
      
      await this.newServiceDB.bulkInsert(batch);
      offset += batchSize;
    }
  }
}

Шаг 4: Мониторинг и тестирование

Параллельное выполнение

class ShadowTraffic {
  async compareResponses(request: Request) {
    const [legacyResponse, newResponse] = await Promise.all([
      this.legacyService.handle(request),
      this.newService.handle(request)
    ]);
    
    this.logDifferences(legacyResponse, newResponse);
    return legacyResponse; // Возвращаем проверенный ответ
  }
}

Шаг 5: Переключение трафика

Постепенный роллаут

class TrafficSplitter {
  private newServicePercentage: number = 0;
  
  async route(request: Request): Promise<Response> {
    const useNewService = Math.random() * 100 < this.newServicePercentage;
    
    if (useNewService) {
      return await this.newService.handle(request);
    }
    return await this.legacyService.handle(request);
  }
  
  increaseNewServiceTraffic(percentage: number) {
    this.newServicePercentage = Math.min(100, this.newServicePercentage + percentage);
  }
}

Шаг 6: Удаление legacy кода

После полной миграции и стабилизации:

• Удалите старый код из монолита
• Обновите документацию
• Оптимизируйте новые сервисы

Best Practices

1. Начинайте с простого — выберите наименее связанный модуль
2. Автоматизируйте тестирование — сравнивайте результаты обеих систем
3. Мониторьте метрики — отслеживайте производительность и ошибки
4. Планируйте откат — всегда имейте план возврата к монолиту

Заключение

Реализация Strangler Fig требует тщательного планирования и постепенного подхода, но позволяет безопасно мигрировать к микросервисам без остановки бизнеса.