PHP 怎么用户行为分析

wen PHP项目 2026-08-09 195

本文目录导读：

PHP 怎么用户行为分析

用户行为分析的核心内容
实现方案
数据存储方案
分析与统计
实时监控
可视化仪表盘
最佳实践建议
推荐的工具/库

我来详细介绍PHP中实现用户行为分析的方法和最佳实践。

用户行为分析的核心内容

需要采集的行为数据

// 基本行为数据
$behavior_data = [
    'user_id' => $user_id,
    'session_id' => session_id(),
    'page_url' => $_SERVER['REQUEST_URI'],
    'referrer' => $_SERVER['HTTP_REFERER'] ?? '',
    'user_agent' => $_SERVER['HTTP_USER_AGENT'],
    'ip_address' => $_SERVER['REMOTE_ADDR'],
    'timestamp' => time(),
    'action_type' => 'page_view', // page_view, click, scroll, etc.
    'device_type' => detectDevice($_SERVER['HTTP_USER_AGENT']),
    'browser' => detectBrowser($_SERVER['HTTP_USER_AGENT'])
];

实现方案

方案1：客户端追踪（推荐）

<!-- HTML 埋点代码 -->
<script>
// 页面访问跟踪
document.addEventListener('DOMContentLoaded', function() {
    // 发送行为数据到服务器
    navigator.sendBeacon('/track.php', JSON.stringify({
        type: 'page_view',
        url: window.location.href,
        referrer: document.referrer,
        timestamp: Date.now(),
        duration: 0
    }));
});
// 点击跟踪
document.addEventListener('click', function(e) {
    const target = e.target;
    navigator.sendBeacon('/track.php', JSON.stringify({
        type: 'click',
        element: target.tagName,
        text: target.textContent?.substring(0, 100),
        x: e.clientX,
        y: e.clientY,
        url: window.location.href
    }));
});
// 滚动深度跟踪
let maxScroll = 0;
window.addEventListener('scroll', function() {
    const scrollPercent = (window.scrollY / (document.documentElement.scrollHeight - window.innerHeight)) * 100;
    if (scrollPercent > maxScroll) {
        maxScroll = scrollPercent;
        if (maxScroll % 25 === 0) { // 每25%记录一次
            navigator.sendBeacon('/track.php', JSON.stringify({
                type: 'scroll',
                depth: maxScroll,
                url: window.location.href
            }));
        }
    }
});
</script>

方案2：服务端追踪

// track.php - 接收行为数据的端点
<?php
class UserBehaviorTracker {
    private $db;
    private $redis;
    public function __construct() {
        $this->db = new PDO('mysql:host=localhost;dbname=analytics', 'user', 'pass');
        $this->redis = new Redis();
        $this->redis->connect('127.0.0.1', 6379);
    }
    public function track($data) {
        // 验证数据
        if (!$this->validateData($data)) {
            return false;
        }
        // 批量写入Redis（高性能）
        $this->redis->lPush('behavior_queue', json_encode($data));
        // 异步处理（通过队列）
        $this->enqueueJob($data);
        return true;
    }
    private function validateData($data) {
        return isset($data['type']) && isset($data['url']);
    }
    private function enqueueJob($data) {
        // 使用RabbitMQ或其他消息队列
        $amqp = new AMQPConnection();
        $channel = $amqp->channel();
        $channel->queue_declare('behavior_analytics', false, true, false, false);
        $channel->basic_publish(new AMQPMessage(json_encode($data)));
    }
}

数据存储方案

数据库表设计

-- 用户行为表
CREATE TABLE user_behaviors (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    user_id INT,
    session_id VARCHAR(64),
    action_type VARCHAR(50),
    page_url VARCHAR(500),
    referrer VARCHAR(500),
    device_type VARCHAR(20),
    browser VARCHAR(50),
    ip_address VARCHAR(45),
    user_agent TEXT,
    extra_data JSON,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    INDEX idx_user_time (user_id, created_at),
    INDEX idx_action (action_type),
    INDEX idx_page (page_url(100))
);
-- 用户会话表
CREATE TABLE user_sessions (
    session_id VARCHAR(64) PRIMARY KEY,
    user_id INT,
    start_time TIMESTAMP,
    end_time TIMESTAMP,
    pages_viewed INT DEFAULT 1,
    duration INT DEFAULT 0,
    entry_page VARCHAR(500),
    exit_page VARCHAR(500),
    INDEX idx_user (user_id)
);
-- 事件日志表
CREATE TABLE event_logs (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    event_name VARCHAR(100),
    event_category VARCHAR(50),
    event_label VARCHAR(200),
    event_value DECIMAL(10,2),
    user_id INT,
    session_id VARCHAR(64),
    page_url VARCHAR(500),
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    INDEX idx_event_time (event_name, created_at)
);

数据批量处理

// 批量处理脚本 - 每小时执行
class BehaviorBatchProcessor {
    public function processBatch() {
        $redis = new Redis();
        // 从Redis取数据
        $batch = [];
        while (count($batch) < 1000) {
            $data = $redis->rPop('behavior_queue');
            if ($data) {
                $batch[] = json_decode($data, true);
            } else {
                break;
            }
        }
        // 批量写入数据库
        $this->batchInsert($batch);
        // 更新用户会话
        $this->updateSessions($batch);
        // 生成统计报表
        $this->generateStats($batch);
    }
    private function batchInsert($data) {
        $db = new PDO('mysql:host=localhost;dbname=analytics', 'user', 'pass');
        $db->beginTransaction();
        try {
            $stmt = $db->prepare("INSERT INTO user_behaviors 
                (user_id, session_id, action_type, page_url, ...) 
                VALUES (?, ?, ?, ?, ...)");
            foreach ($data as $row) {
                $stmt->execute([
                    $row['user_id'],
                    $row['session_id'],
                    $row['action_type'],
                    $row['page_url'],
                    // ...
                ]);
            }
            $db->commit();
        } catch (Exception $e) {
            $db->rollback();
            error_log($e->getMessage());
        }
    }
}

分析与统计

页面分析

class PageAnalyzer {
    public function getPageStats($page_url, $date_start, $date_end) {
        $db = new PDO('mysql:host=localhost;dbname=analytics', 'user', 'pass');
        // 页面浏览量
        $pv = $db->prepare("SELECT COUNT(*) as count, COUNT(DISTINCT user_id) as uv 
                           FROM user_behaviors 
                           WHERE page_url = ? AND created_at BETWEEN ? AND ?");
        $pv->execute([$page_url, $date_start, $date_end]);
        $page_views = $pv->fetch();
        // 平均停留时间
        $time = $db->prepare("SELECT AVG(duration) as avg_time 
                             FROM user_sessions 
                             WHERE exit_page = ? AND end_time BETWEEN ? AND ?");
        $time->execute([$page_url, $date_start, $date_end]);
        $avg_time = $time->fetch();
        return [
            'page_views' => $page_views['count'],
            'unique_visitors' => $page_views['uv'],
            'avg_duration' => $avg_time['avg_time'],
            'bounce_rate' => $this->getBounceRate($page_url, $date_start, $date_end)
        ];
    }
    private function getBounceRate($page_url, $date_start, $date_end) {
        // 计算跳出率
        $db = new PDO('mysql:host=localhost;dbname=analytics', 'user', 'pass');
        $stmt = $db->prepare("SELECT 
                (SELECT COUNT(*) FROM user_sessions 
                 WHERE entry_page = ? AND pages_viewed = 1 
                 AND start_time BETWEEN ? AND ?) as bounced,
                (SELECT COUNT(*) FROM user_sessions 
                 WHERE entry_page = ? AND start_time BETWEEN ? AND ?) as total");
        $stmt->execute([$page_url, $date_start, $date_end, $page_url, $date_start, $date_end]);
        $result = $stmt->fetch();
        return $result['total'] > 0 ? ($result['bounced'] / $result['total']) * 100 : 0;
    }
}

漏斗分析

class FunnelAnalyzer {
    public function buildFunnel($steps, $date_start, $date_end) {
        // $steps = ['主页', '产品页', '购物车', '结算', '支付成功'];
        $funnel_data = [];
        $total_users = 0;
        foreach ($steps as $index => $step) {
            $data = $this->getStepData($step, $date_start, $date_end);
            if ($index === 0) {
                $total_users = $data['users'];
            }
            $funnel_data[] = [
                'step' => $step,
                'users' => $data['users'],
                'conversion_rate' => $total_users > 0 ? 
                    ($data['users'] / $total_users) * 100 : 0
            ];
        }
        return $funnel_data;
    }
    private function getStepData($step, $date_start, $date_end) {
        // 根据配置查询数据库
        $db = new PDO('mysql:host=localhost;dbname=analytics', 'user', 'pass');
        switch ($step) {
            case '主页':
                $query = "SELECT COUNT(DISTINCT user_id) as users 
                         FROM user_behaviors 
                         WHERE page_url LIKE '%index%' 
                         AND created_at BETWEEN ? AND ?";
                break;
            case '产品页':
                $query = "SELECT COUNT(DISTINCT user_id) as users 
                         FROM user_behaviors 
                         WHERE page_url LIKE '%product%' 
                         AND created_at BETWEEN ? AND ?";
                break;
            // ... 其他步骤
        }
        $stmt = $db->prepare($query);
        $stmt->execute([$date_start, $date_end]);
        return $stmt->fetch(PDO::FETCH_ASSOC);
    }
}

实时监控

// WebSocket实时推送
class RealtimeMonitor {
    private $redis;
    public function __construct() {
        $this->redis = new Redis();
    }
    public function getRealtimeData() {
        // 最近5分钟的活跃用户
        $active_users = $this->redis->zCount('active_users', time() - 300, time());
        // 当前在线用户数
        $online_users = $this->redis->zCard('online_users');
        // 热门页面
        $hot_pages = $this->redis->zRevRange('page_hits', 0, 9, true);
        return [
            'active_users' => $active_users,
            'online_users' => $online_users,
            'hot_pages' => $hot_pages
        ];
    }
    public function updateRealtimeData($user_id, $page_url) {
        $now = time();
        // 更新在线状态
        $this->redis->zAdd('online_users', $now, $user_id);
        $this->redis->zRemRangeByScore('online_users', 0, $now - 60);
        // 更新页面热度
        $this->redis->zIncrBy('page_hits', 1, $page_url);
        // 更新活跃用户
        $this->redis->zAdd('active_users', $now, $user_id);
        return true;
    }
}

可视化仪表盘

<!-- 简单仪表盘HTML -->
<!DOCTYPE html>
<html>
<head>用户行为分析仪表盘</title>
    <script src="https://cdn.jsdelivr.net/npm/chart.js"></script>
</head>
<body>
    <div class="dashboard">
        <h2>用户行为分析</h2>
        <div class="metrics">
            <div class="metric-card">
                <h3>今日访问量</h3>
                <p id="todayVisits"><?php echo getTodayVisits(); ?></p>
            </div>
            <div class="metric-card">
                <h3>活跃用户</h3>
                <p id="activeUsers"><?php echo getActiveUsers(); ?></p>
            </div>
            <div class="metric-card">
                <h3>转化率</h3>
                <p id="conversionRate"><?php echo getConversionRate(); ?>%</p>
            </div>
        </div>
        <div class="charts">
            <canvas id="trafficChart"></canvas>
            <canvas id="deviceChart"></canvas>
        </div>
    </div>
    <script>
    // 使用Chart.js绘制图表
    var ctx = document.getElementById('trafficChart').getContext('2d');
    var trafficChart = new Chart(ctx, {
        type: 'line',
        data: {
            labels: ['周一', '周二', '周三', '周四', '周五', '周六', '周日'],
            datasets: [{
                label: '访问量',
                data: [1200, 1500, 1300, 1800, 1600, 1400, 1900],
                borderColor: 'rgb(75, 192, 192)'
            }]
        }
    });
    </script>
</body>
</html>

最佳实践建议

性能优化

使用异步处理队列（Redis + 后台任务）
批量写入数据库,避免频繁I/O
使用缓存存储热门数据

数据安全

// 用户隐私保护
class PrivacyHandler {
    public function anonymizeIP($ip) {
        // 匿名化IP地址
        if (filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)) {
            return md5($ip . 'salt');
        }
        return null;
    }
    public function maskUserData($user_data) {
        // 掩码敏感信息
        $user_data['email'] = substr($user_data['email'], 0, 3) . '***';
        $user_data['phone'] = substr($user_data['phone'], 0, 3) . '****';
        return $user_data;
    }
}

数据采样

// 按比例采样以降低存储成本
class SampleRate {
    private $rate = 0.1; // 10%采样率
    public function shouldSample($user_id) {
        // 基于用户ID哈希决定是否采样，保证同一用户行为一致
        $hash = crc32($user_id);
        return ($hash % 100) < ($this->rate * 100);
    }
}