Активность пользователей PHP: подходы к хранению логов и работа с ошибками

Расширенные примеры реализации логирования активности

Пример 1. Гибкий класс ActivityLogger с поддержкой нескольких обработчиков

<?php
class ActivityLogger
{
    private $logger;

    public function __construct(array $config)
    {
        $this->logger = new Logger('activity');
        if (isset($config['file'])) {
            $handler = new StreamHandler($config['file'], Logger::INFO);
            $this->logger->pushHandler($handler);
        }
        if (isset($config['gelf'])) {
            $transport = new TcpTransport($config['gelf']['host'], $config['gelf']['port']);
            $handler = new GelfHandler($transport, Logger::INFO);
            $this->logger->pushHandler($handler);
        }
    }

    public function log($action, array $context = [])
    {
        $this->logger->info($action, $context);
    }
}

// Использование
$config = [
    'file' => __DIR__ . '/logs/activity.log',
    'gelf' => ['host' => 'graylog.local', 'port' => 12201]
];
$logger = new ActivityLogger($config);
$logger->log('user_login', ['user_id' => 1, 'timestamp' => time()]);
?>

Пример 2. Пакетная запись в базу данных с использованием транзакции

<?php
$pdo = new PDO('mysql:host=localhost;dbname=logs;charset=utf8', 'user', 'pass');
$pdo->beginTransaction();
$stmt = $pdo->prepare('INSERT INTO user_activity (user_id, action, ip, created_at) VALUES (?, ?, ?, NOW())');

$batch = [
    [1, 'view_page', '192.168.1.1'],
    [1, 'click_link', '192.168.1.1'],
    [2, 'logout', '10.0.0.1']
];

foreach ($batch as $row) {
    $stmt->execute($row);
}
$pdo->commit();
?>

(в таблицу добавлены три записи, транзакция гарантирует атомарность)

Пример 3. Асинхронное логирование через RabbitMQ с подтверждением доставки

// Установка php-amqplib: composer require php-amqplib/php-amqplib
// Отправка сообщения
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('activity_log', false, true, false, false);

$msgData = json_encode([
    'action' => 'purchase',
    'user_id' => 42,
    'amount' => 1500
]);
$msg = new AMQPMessage($msgData, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);
$channel->basic_publish($msg, '', 'activity_log');
$channel->close();
$connection->close();

// Воркер (потребление)
$callback = function ($msg) {
    $data = json_decode($msg->body, true);
    // запись в лог
    file_put_contents('logs/activity.log', date('Y-m-d H:i:s') . " {$data['action']}: user {$data['user_id']}\n", FILE_APPEND);
    $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
};
$channel->basic_qos(null, 1, null);
$channel->basic_consume('activity_log', '', false, false, false, false, $callback);
while($channel->is_consuming()) {
    $channel->wait();
}
?>

Результат: воркер получает сообщения из очереди и записывает их, подтверждая обработку. При сбое воркера сообщение не теряется.

Пример 4. Интеграция с обработчиками ошибок PHP для логирования исключений вместе с контекстом пользователя

<?php
set_exception_handler(function (Throwable $e) use ($logger) {
    $context = [
        'file' => $e->getFile(),
        'line' => $e->getLine(),
        'trace' => $e->getTraceAsString(),
        'user_id' => $_SESSION['user_id'] ?? null,
        'request_uri' => $_SERVER['REQUEST_URI'] ?? ''
    ];
    $logger->error($e->getMessage(), $context);
    http_response_code(500);
    echo 'Произошла внутренняя ошибка';
});

set_error_handler(function ($severity, $message, $file, $line) use ($logger) {
    if (error_reporting() & $severity) {
        $logger->warning($message, ['file' => $file, 'line' => $line]);
    }
    // Не прерываем стандартный обработчик
    return false;
});
?>

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

Пример 5. Использование Filebeat и Elasticsearch для централизованного сбора логов

# Конфигурация Filebeat (filebeat.yml)
filebeat.inputs:
- type: log
  paths:
    - /var/www/html/logs/*.log
  fields:
    app: my_php_app
    type: activity

output.elasticsearch:
  hosts: ["localhost:9200"]
  index: "php-activity-%{+yyyy.MM.dd}"

# Настройка logstash или прямо в Elasticsearch

На стороне PHP просто пишем в файл в формате JSON. Filebeat считывает и отправляет в Elasticsearch, где индексы можно просматривать в Kibana.