PHP用户行为日志存储

wen PHP项目 2026-08-11 154

本文目录导读：

PHP用户行为日志存储

存储方案选型对比
核心设计原则与代码示例
必须注意的关键问题
推荐技术栈组合

在PHP开发中,用户行为日志的存储方案通常根据业务规模、查询频率和成本来选择，以下是几种主流的存储方案，从轻量级到重量级，以及对应的实现思路。

存储方案选型对比

方案	适用场景	优点	缺点
文件系统 (File)	小型项目、单机部署、调试日志	简单、零依赖、写入快	并发能力差、不支持SQL查询、分布式扩展困难
关系型数据库 (MySQL/PG)	中小型企业、需要复杂统计报表	事务支持、SQL分析方便、易于管理	高并发写入压力大、磁盘占用高、长期存储成本高
NoSQL (MongoDB/Redis)	高并发写入、数据格式灵活	写入极快、扩展性好、支持JSON文档	MongoDB：占用空间大；Redis：内存昂贵，适合做缓冲
专业日志系统 (ELK/Loki)	大型系统、微服务架构、需全文检索	海量日志、聚合分析秒级返回、可视化	运维成本高、资源消耗大、架构复杂
数据仓库 (ClickHouse)	海量行为分析、用户画像、数仓	列式存储压缩率高、查询极快	不适合单条事务更新，需批量导入

核心设计原则与代码示例

无论选哪种存储,最推荐的做法是：异步写入 + 队列缓冲，避免影响主业务流程。

基于 MySQL 的常见实现（中小型项目首选）

技术要点：使用 JSON 字段存储扩展信息，使用 事件表 + 详情表 分离常用字段和低频字段。

表结构设计：

CREATE TABLE `user_behavior_log` (
  `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
  `user_id` INT UNSIGNED NOT NULL COMMENT '用户ID (0为未登录)',
  `event_type` VARCHAR(50) NOT NULL COMMENT '事件类型 (CLICK, VIEW, SEARCH, BUY...)',
  `page_url` VARCHAR(255) NOT NULL COMMENT '当前页面URL',
  `referer_url` VARCHAR(255) DEFAULT NULL COMMENT '来源页面',
  `ip_address` VARCHAR(45) DEFAULT NULL COMMENT 'IPv4/IPv6',
  `user_agent` VARCHAR(255) DEFAULT NULL COMMENT '浏览器UA',
  `device_info` JSON DEFAULT NULL COMMENT '设备信息(浏览器,系统,屏幕尺寸)',
  `params` JSON DEFAULT NULL COMMENT '业务参数(商品ID, 搜索关键词等)',
  `request_id` VARCHAR(64) DEFAULT NULL COMMENT '全链路追踪ID',
  `created_at` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `idx_user_id_time` (`user_id`, `created_at`),
  KEY `idx_event_type_time` (`event_type`, `created_at`),
  KEY `idx_time` (`created_at`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户行为日志表';

PHP 写入代码（异步 + 队列）：

<?php
// 使用 Redis 做队列，Worker 脚本消费后写入 MySQL
class UserBehaviorLogger
{
    private $redis;
    public function __construct()
    {
        $this->redis = new Redis();
        $this->redis->connect('127.0.0.1', 6379);
    }
    public function log(array $data): bool
    {
        // 基础信息填充
        $log = [
            'user_id'    => $data['user_id'] ?? 0,
            'event_type' => $data['event_type'],
            'page_url'   => $data['page_url'] ?? '',
            'referer_url' => $data['referer_url'] ?? '',
            'ip_address' => $this->getClientIp(),
            'user_agent' => $_SERVER['HTTP_USER_AGENT'] ?? '',
            'params'     => json_encode($data['params'] ?? [], JSON_UNESCAPED_UNICODE),
            'created_at' => date('Y-m-d H:i:s'),
        ];
        // 写入 Redis 队列 (LPUSH 到 list)
        $result = $this->redis->lPush('user_behavior_logs', json_encode($log));
        // 如果写入队列失败，降级为文件日志，不阻塞主流程
        if ($result === false) {
            error_log(json_encode($log), 3, '/tmp/behavior_log_fallback.log');
        }
        return true; // 同步返回，不等待数据库写入
    }
    private function getClientIp(): string
    {
        // 注意：可信代理场景需调整
        return $_SERVER['HTTP_X_FORWARDED_FOR'] ?? $_SERVER['REMOTE_ADDR'] ?? '0.0.0.0';
    }
}
// 使用示例
$logger = new UserBehaviorLogger();
$logger->log([
    'user_id'    => 12345,
    'event_type' => 'PRODUCT_VIEW',
    'page_url'   => '/product/233',
    'params'     => ['product_id' => 233, 'source' => 'recommend']
]);

基于 MongoDB 的实现（高并发、格式灵活）

MongoDB 非常适合行为日志，因为它不需要预定义复杂的表结构，且水平扩展容易。

PHP 代码（MongoDB 驱动）：

<?php
use MongoDB\Driver\BulkWrite;
use MongoDB\Driver\Manager;
use MongoDB\Driver\Query;
class MongoLogger
{
    private $manager;
    private $collection = 'db.user_behavior';
    public function __construct()
    {
        // 连接 MongoDB
        $this->manager = new Manager('mongodb://localhost:27017');
    }
    public function log(array $data): bool
    {
        $document = array_merge([
            'event_type' => $data['event_type'],
            'user_id'    => $data['user_id'] ?? 0,
            'timestamp'  => new \MongoDB\BSON\UTCDateTime(time() * 1000), // 使用BSON时间类型
            'ip'         => $_SERVER['REMOTE_ADDR'] ?? '',
            'meta'       => new \stdClass(), // 空JSON对象
        ], $data);
        $bulk = new BulkWrite();
        // insertOne 写入
        $bulk->insert($document);
        try {
            $result = $this->manager->executeBulkWrite($this->collection, $bulk);
            return $result->getInsertedCount() > 0;
        } catch (\Exception $e) {
            error_log("Mongo日志写入失败: " . $e->getMessage());
            return false;
        }
    }
    // 查询示例（按用户和时间范围）
    public function getLogs(int $userId, string $startDate, string $endDate): array
    {
        $query = new Query([
            'user_id' => $userId,
            'timestamp' => [
                '$gte' => new \MongoDB\BSON\UTCDateTime(strtotime($startDate) * 1000),
                '$lte' => new \MongoDB\BSON\UTCDateTime(strtotime($endDate) * 1000)
            ]
        ], ['sort' => ['timestamp' => -1], 'limit' => 100]);
        $cursor = $this->manager->executeQuery($this->collection, $query);
        $logs = [];
        foreach ($cursor as $document) {
            $logs[] = json_decode(json_encode($document), true);
        }
        return $logs;
    }
}
// 使用
$logger = new MongoLogger();
$logger->log([
    'event_type' => 'SEARCH',
    'user_id'    => 888,
    'params'     => ['keyword' => 'iPhone 15'],
]);

基于 ELK / Elasticsearch 的实现（大型系统）

通常流程：

PHP 生成 JSON 日志 -> 通过 Filebeat 或采用日志方式异步发送。
Kafka (可选) 作为消息缓冲。
Logstash / FluentD 进行数据清洗。
Elasticsearch 存储索引。
Kibana 展示可视化仪表盘。

PHP 端侧重点： 标准化输出格式（通常输出到 stdout 或本地文件），由 Filebeat 收集。

<?php
// 推荐使用 Monolog 库
use Monolog\Logger;
use Monolog\Handler\StreamHandler;
use Monolog\Formatter\JsonFormatter;
$log = new Logger('behavior');
$stream = new StreamHandler('php://stdout', Logger::INFO);
$stream->setFormatter(new JsonFormatter()); // 输出为 JSON 行
$log->pushHandler($stream);
$log->info('用户行为记录', [
    'user_id' => 1024,
    'event'   => 'LOGIN',
    'ip'      => '1.2.3.4',
    'extra'   => ['platform' => 'WeChat', 'channel' => 'scan']
]);

(注意：Logstash 或 Fluentd 会监听 stdout 或 /var/log/app/behavior.log，将其输送到 ES)

必须注意的关键问题

高并发削峰：绝不要在 Controller 里直接 SQL INSERT，必须引入 Redis（List）或者 RabbitMQ 队列，后端写一个 Worker 脚本（php cli）循环消费队列，批量写入数据库（使用 INSERT ... ON DUPLICATE KEY UPDATE 或 批量 INSERT，合并多条数据一次提交）。
数据老化清理：
- MySQL：按时间分区，定时 DROP PARTITION 或删除旧数据，建议热数据保留30天，冷数据归档。
- Elasticsearch：使用 Index Lifecycle Management (ILM) 策略自动归档或删除。
敏感信息脱敏：日志中严禁记录用户明文密码、身份证号、信用卡号，需在记录前使用 preg_replace 配合号进行掩码处理。
字段设计优化：event_type 字段使用 TINYINT 枚举或者短字符串，并建立索引，避免全文搜索长字符串，IP 存储为 INT UNSIGNED（ip2long()）比 VARCHAR(45) 更节省空间。
入库失败降级策略：如果数据库或消息队列挂掉，必须在代码里 try-catch 捕获异常，写入本地文件（如 /var/log/behavior_fallback.log），防止日志丢失。