Над чем работаешь сейчас?

Разработка высоконагруженного REST API для агрегатора услуг

В данный момент я занят разработкой и оптимизацией микросервисной архитектуры для крупного агрегатора услуг (похожего на Яндекс.Услуги или Avito). Основной проект — это REST API на PHP 8.2, который обрабатывает запросы от мобильных приложений и веб-интерфейса. Работа сосредоточена на нескольких ключевых направлениях:

1. Оптимизация системы поиска и фильтрации

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

// Пример оптимизированного построения запроса в Elasticsearch с использованием агрегаций
$searchQuery = [
    'query' => [
        'bool' => [
            'filter' => [
                ['geo_distance' => ['distance' => '10km', 'location' => $userCoordinates]],
                ['term' => ['category_id' => $requestedCategory]],
                ['range' => ['rating' => ['gte' => 4.0]]]
            ]
        ]
    ],
    'aggs' => [
        'top_providers' => [
            'terms' => ['field' => 'provider_id', 'size' => 50],
            'aggs' => [
                'avg_rating' => ['avg' => ['field' => 'rating']],
                'relevance_score' => ['script' => 'combine_rating_distance']
            ]
        ]
    ],
    'sort' => [
        ['_score' => 'desc'],
        ['relevance_score' => 'desc']
    ]
];

Для решения:

• Переписали скрипты релевантности на Painless (Elasticsearch) для комбинирования рейтинга и расстояния
• Добавили пре-агрегацию данных для часто используемых фильтров
• Реализовали кеширование результатов поиска в Redis для популярных комбинаций параметров

2. Рефакторинг системы асинхронных задач

Старая система на базе RabbitMQ имела проблемы с потерями сообщений и сложностью мониторинга. Переходим на Symfony Messenger с улучшенной обработкой ошибок и retry-механизмами.

// Конфигурация асинхронного обработчика в Symfony
class NotificationHandler implements MessageHandlerInterface
{
    private NotificationService $service;
    private LoggerInterface $logger;

    public function __construct(NotificationService $service, LoggerInterface $logger)
    {
        $this->service = $service;
        $this->logger = $logger;
    }

    public function __invoke(SendNotificationMessage $message)
    {
        try {
            $this->service->sendBatch($message->getUserIds(), $message->getTemplate());
            
            // Логирование успешной обработки
            $this->logger->info('Notification batch processed', [
                'count' => count($message->getUserIds()),
                'template' => $message->getTemplate()
            ]);
        } catch (TransportException $e) {
            // Автоматический retry с exponential backoff
            throw new RetryableException('Notification service unavailable', 0, $e);
        }
    }
}

Ключевые улучшения:

• Дедупликация сообщений на основе хешей содержимого
• Приоритизация очередей для критических уведомлений
• Интеграция с Prometheus для мониторинга backlog

3. Работа с производительностью и нагрузкой

Система испытывает пиковые нагрузки до 5000 RPS в часы активности. Проводим:

• Профилирование с помощью Blackfire.io для поиска узких мест
• Оптимизацию Nginx + PHP-FPM конфигурации (динамическое управление процессами)
• Внедрение HTTP/2 и компрессии ответов для мобильных клиентов

4. Улучшение безопасности API

В свете новых требований PCI DSS и GDPR:

• Переход на JWT-токены с коротким временем жизни и refresh-механизмом
• Реализация rate-limiting на уровне IP и пользователя с использованием Redis
• Аудит всех точек входа для предотвращения инъекций и несанкционированного доступа

// Rate-limiting middleware с использованием Redis
class RateLimitMiddleware
{
    private RedisConnection $redis;
    private int $limit;
    private int $window;

    public function __construct(RedisConnection $redis, int $limit = 100, int $window = 60)
    {
        $this->redis = $redis;
        $this->limit = $limit;
        $this->window = $window;
    }

    public function handle(Request $request): ?Response
    {
        $key = 'rate_limit:' . $request->getClientIp() . ':' . $request->getPathInfo();
        $current = $this->redis->incr($key);
        
        if ($current === 1) {
            $this->redis->expire($key, $this->window);
        }
        
        if ($current > $this->limit) {
            return new Response('Too Many Requests', 429);
        }
        
        return null;
    }
}

5. Подготовка к миграции на частично serverless-архитектуру

Планируем перенести некоторые не критические сервисы (генерация отчетов, отправка email) на AWS Lambda ( через Bref для PHP), чтобы уменьшить нагрузку на основные серверы.

Этот проект сочетает в себе высокую нагрузку, требования к безопасности и необходимость быстрой разработки новых функций, что требует баланса между оптимизацией существующего кода и внедрением современных практик микросервисной архитектуры.