卜仙堂访问统计系统

这是一个基于 Cloudflare Workers 和 D1 数据库的访问统计系统，用于记录网站的页面浏览量（PV）和独立访客数（UV）。

功能特点

技术架构

数据库结构

stats 表

字段名 类型 说明
id INTEGER 主键，固定为 1
pv INTEGER 页面浏览量
uv INTEGER 独立访客数
last_update INTEGER 最后更新时间戳

visitors 表

字段名 类型 说明
id INTEGER 主键，自增
ip TEXT 访客 IP 地址（唯一）
last_visit INTEGER 最后访问时间戳

部署步骤

  1. 创建 D1 数据库

    • 登录 Cloudflare Dashboard
    • 进入 Workers & Pages
    • 点击 "D1" 标签
    • 点击 "Create database"
    • 输入数据库名称（如 "stats-db"）
    • 点击 "Create"

  2. 部署 Worker

    • 进入 Workers & Pages
    • 创建新的 Worker
    • 将 worker.js 代码复制到编辑器中(代码见文末)
    • 点击 "Save and Deploy"

  3. 绑定数据库

    • 在 Worker 的 "Settings" 标签中
    • 点击 "Add variable"
    • 选择 "D1 database binding"
    • 变量名输入：DB
    • 选择之前创建的数据库
    • 点击 "Save"

前端集成

在需要统计的页面中添加以下代码：

<script>
  async function updateStats() {
    try {
      const response = await fetch("https://liuyaoworker.buxiantang.top/stats");
      const data = await response.json();
      document.getElementById("site_pv").textContent = data.pv;
      document.getElementById("site_uv").textContent = data.uv;
    } catch (error) {
      console.error("统计更新失败:", error);
    }
  }

  // 页面加载时更新统计
  document.addEventListener("DOMContentLoaded", updateStats);

  // 每5分钟更新一次统计
  setInterval(updateStats, 5 * 60 * 1000);
</script>

<div class="site-stats" id="site-stats">
  <span class="stats-label">浏览量:</span>
  <span id="site_pv">0</span>
  |
  <span class="stats-label">访客数:</span>
  <span id="site_uv">0</span>
</div>

统计接口

请求

响应

{
  "pv": 123,
  "uv": 45,
  "lastUpdate": 1746004388417
}

错误处理

系统会自动处理以下情况：

在发生错误时会返回默认值：

{
  "pv": 0,
  "uv": 0,
  "lastUpdate": 1746004388417,
  "error": "错误信息"
}

维护建议

  1. 定期备份 D1 数据库
  2. 监控 Worker 的日志
  3. 定期清理过期的访客记录（可选）

注意事项

更新日志

v1.0.0 (2024-03-01)

workers.js代码：

点我展开看代码 

export default {
  async fetch(request, env) {
    // 获取请求的 URL
    const url = new URL(request.url)

// 如果是统计请求
if (url.pathname === '/stats') {
  try {
    console.log('开始处理统计请求')
    
    // 初始化数据库表（如果不存在）
    await env.DB.prepare(`
      CREATE TABLE IF NOT EXISTS stats (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        pv INTEGER DEFAULT 0,
        uv INTEGER DEFAULT 0,
        last_update INTEGER
      )
    `).run()

    await env.DB.prepare(`
      CREATE TABLE IF NOT EXISTS visitors (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        ip TEXT UNIQUE,
        last_visit INTEGER
      )
    `).run()

    // 获取当前统计数据
    let stats = await env.DB.prepare(`
      SELECT * FROM stats WHERE id = 1
    `).first()

    // 如果没有统计数据，创建初始记录
    if (!stats) {
      await env.DB.prepare(`
        INSERT INTO stats (id, pv, uv, last_update)
        VALUES (1, 0, 0, ?)
      `).bind(Date.now()).run()
      stats = { pv: 0, uv: 0, last_update: Date.now() }
    }

    // 更新 PV
    await env.DB.prepare(`
      UPDATE stats SET pv = pv + 1, last_update = ? WHERE id = 1
    `).bind(Date.now()).run()

    // 检查是否是新的访客
    const visitorId = request.headers.get('cf-connecting-ip')
    const visitor = await env.DB.prepare(`
      SELECT * FROM visitors WHERE ip = ?
    `).bind(visitorId).first()

    // 如果是新访客，增加 UV 并记录访客
    if (!visitor) {
      await env.DB.prepare(`
        UPDATE stats SET uv = uv + 1 WHERE id = 1
      `).run()

      await env.DB.prepare(`
        INSERT INTO visitors (ip, last_visit)
        VALUES (?, ?)
      `).bind(visitorId, Date.now()).run()
    } else {
      // 更新现有访客的最后访问时间
      await env.DB.prepare(`
        UPDATE visitors SET last_visit = ? WHERE ip = ?
      `).bind(Date.now(), visitorId).run()
    }

    // 获取最新的统计数据
    const latestStats = await env.DB.prepare(`
      SELECT * FROM stats WHERE id = 1
    `).first()

    // 返回统计数据
    return new Response(JSON.stringify({
      pv: latestStats.pv,
      uv: latestStats.uv,
      lastUpdate: latestStats.last_update
    }), {
      headers: {
        'Content-Type': 'application/json',
        'Access-Control-Allow-Origin': '*'
      }
    })
  } catch (error) {
    console.error('处理统计请求时发生错误:', error)
    // 如果发生错误，返回默认值
    return new Response(JSON.stringify({
      pv: 0,
      uv: 0,
      lastUpdate: Date.now(),
      error: error.message
    }), {
      headers: {
        'Content-Type': 'application/json',
        'Access-Control-Allow-Origin': '*'
      }
    })
  }
}

// 返回原始请求
return fetch(request)



}

}

🤞转载请注明出处🤞