在本篇文章中，我将分享一个基于 Cloudflare Workers + Telegram Bot + D1 数据库 的完全无服务器（Serverless）聊天系统。该机器人支持用户匿名与管理员双向通信，具备首访验证、自动诈骗检测、屏蔽管理、消息映射等功能，是一个非常适合作为客服、匿名反馈、小型 IM 系统的解决方案。

⭐ 系统亮点#

🚀 100% Serverless 无需服务器
🔐 首访用户自动加减法验证（防骚扰）
🔁 双向匿名对话（用户看不到管理员 ID）
🛡 管理员可屏蔽 / 解封任何用户
🧠 自动诈骗账号检测（基于 D1 fraud 表）
💾 D1 数据库存储用户状态与消息映射
📌 管理员收到用户消息时自动生成“用户资料卡”
🔔 可控频率的通知提醒机制

🧩 系统架构#

1
[Telegram User]
2
      ↓ 发送消息
3
[Cloudflare Workers /endpoint]
4
      ↓
5
[验证系统（加减法 1～10）]
6
      ↓ 通过后
7
[反诈检测(fraud)]
8
      ↓
9
[自动转发消息 → 管理员]
10

11
管理员 ←→ 用户 （双向聊天）

📦 使用技术#

技术	用途
Cloudflare Workers	核心逻辑执行环境
Telegram Bot API	双向聊天接口
Cloudflare D1	用户资料、屏蔽状态、验证码、消息映射存储
Webhooks	实时接收 Telegram 更新事件

🗄 数据库结构（D1）#

为保证机器人功能完整，需要创建以下表：

1
CREATE TABLE blocks (
2
  user_id TEXT PRIMARY KEY,
3
  is_blocked INTEGER
4
);
5

6
CREATE TABLE msg_map (
7
  admin_msg_id TEXT PRIMARY KEY,
8
  user_id TEXT
9
);
10

11
CREATE TABLE lastmsg (
12
  user_id TEXT PRIMARY KEY,
13
  ts INTEGER
14
);
15

16
CREATE TABLE fraud (
17
  user_id TEXT PRIMARY KEY
18
);
19

20
CREATE TABLE verify (
21
  user_id TEXT PRIMARY KEY,
22
  question TEXT,
23
  answer INTEGER,
24
  passed INTEGER
25
);
26

27
CREATE TABLE user_first (
28
  user_id TEXT PRIMARY KEY
29
);

🔢 首次验证系统（加减法 1～10）#

为了防止广告机器人、骚扰用户，系统会对第一次聊天的用户进行简单的数学验证：

✨ 验证示例#

1
为了防止骚扰，请先完成验证：
2

3
7 + 3 = ?
4

5
请直接回复数字答案。

答对后自动进入聊天流程；答错则重新生成题目。

🎯 核心功能说明#

1️⃣ 匿名聊天（Forward/Copy）#

用户发送消息 → 机器人自动转发给管理员
管理员「回复这条转发消息」→ 机器人将回复复制给用户

整个过程：

用户不会看到管理员的 UID
管理员同样看不到用户昵称（除资料卡）

实现完整“匿名双向通信”。

2️⃣ 用户资料卡（首次出现）#

管理员第一次收到用户消息时，自动生成用户信息卡：

管理员点按钮后 → 自动屏蔽

3️⃣ 屏蔽 / 解除屏蔽#

管理员可直接通过命令控制：

指令	说明
`/block`	屏蔽此用户
`/unblock`	解除屏蔽
`/checkblock`	查看用户是否被屏蔽

4️⃣ 诈骗检测（D1 fraud 表）#

只需点击按钮

或者

回复的是输入/block 也可以拉黑用户

5️⃣ 可控间隔的通知提醒系统#

为了避免管理员被刷屏，可设置提醒间隔（默认 1 小时）：

作用：

用户第一次联系 → 提醒
用户长时间没聊天，再次联系 → 再提醒一次
保证管理员不会被Spam

🛠 Worker 代码结构说明#

代码整体分为：

Webhook 接收器
Telegram API 封装
核心消息处理
加减法验证模块
管理员控制命令
D1 数据访问模块
首次资料卡发送模块（可扩展）

该架构清晰、可维护性高、支持未来扩展。

📚 使用教程#

1. 创建 Telegram Bot#

在 @BotFather 创建一个机器人，并获得：

Bot Token

2. 部署到 Cloudflare Workers#

1
// ================== 常量区 ==================
2

3
const START_MESSAGE = `
4
🤖 你好，欢迎使用 @guaguawa_bot 双向聊天机器人！
5
请通过此机器人发送您的消息与我联系，我会立即为您传达。
6
`;
7

8
const START_MESSAGE_ADMIN = `
9
🤖 <b>关于本机器人</b>
10

11
本机器人用于 <b>双向匿名聊天</b>，旨在提高用户的沟通体验，并防止骚扰。
12

13
📌 <b>功能介绍：</b>
14
- 匿名聊天：用户可以自由交流，管理员可管理消息流转。
15
- 防骚扰功能：管理员可使用 /block 指令屏蔽不良用户。
16
- 诈骗检测：自动检测是否属于诈骗用户，并提醒管理员。
17

18
📜 <b>可用命令：</b>
19
- /start 获取欢迎信息
20
- /block 屏蔽用户（管理员）
21
- /unblock 解除屏蔽（管理员）
22
- /checkblock 查询用户状态（管理员）
23

24
🔹 机器人由 <b>匿名聊天管理系统</b> 提供支持。
25
`;
26

27

28
// ================== Worker 入口（ESM 格式） ==================
29

30
export default {
31
  async fetch(request, env, ctx) {
32
    const url = new URL(request.url);
33

34
    if (url.pathname === "/endpoint") {
35
      return handleWebhook(request, env, ctx);
36
    }
37
    if (url.pathname === "/registerWebhook") {
38
      return registerWebhook(request, env);
39
    }
40
    if (url.pathname === "/unRegisterWebhook") {
41
      return unRegisterWebhook(request, env);
42
    }
43

44
    return new Response("OK");
45
  }
46
};
47

48

49
// ===================== Telegram API 封装 ========================
50

51
function apiUrl(methodName, params = null, env) {
52
  let query = params ? "?" + new URLSearchParams(params).toString() : "";
53
  return `https://api.telegram.org/bot${env.ENV_BOT_TOKEN}/${methodName}${query}`;
54
}
55

56
function requestTelegram(method, body, env, params = null) {
57
  return fetch(apiUrl(method, params, env), body).then(r => r.json());
58
}
59

60
const makeReq = (body) => ({
61
  method: "POST",
62
  headers: { "content-type": "application/json" },
63
  body: JSON.stringify(body)
64
});
65

66
const sendMessage = (msg, env) =>
67
  requestTelegram("sendMessage", makeReq(msg), env);
68

69
const forwardMessage = (msg, env) =>
70
  requestTelegram("forwardMessage", makeReq(msg), env);
71

72
const copyMessage = (msg, env) =>
73
  requestTelegram("copyMessage", makeReq(msg), env);
74

75

76
// ===================== Webhook ========================
77

78
async function handleWebhook(request, env, ctx) {
79
  if (request.headers.get("X-Telegram-Bot-Api-Secret-Token") !== env.ENV_BOT_SECRET) {
80
    return new Response("Unauthorized", { status: 403 });
81
  }
82

83
  const update = await request.json();
84
  ctx.waitUntil(onUpdate(update, env));
85
  return new Response("OK");
86
}
87

88

89
// ===================== Update Routing ========================
90

91
async function onUpdate(update, env) {
92
  if (update.message) {
93
    await onMessage(update.message, env);
94
  }
95
  if (update.callback_query) {
96
    await onCallback(update.callback_query, env);
97
  }
98
}
99

100

101
// ===================== D1 数据库封装 ========================
102

103
// 拉黑
104
async function getBlock(env, userId) {
105
  const row = await env.TG_BOT_DB.prepare("SELECT is_blocked FROM blocks WHERE user_id=?").bind(userId).first();
106
  return row ? row.is_blocked === 1 : false;
107
}
108

109
async function setBlock(env, userId, val) {
110
  await env.TG_BOT_DB.prepare("INSERT OR REPLACE INTO blocks (user_id, is_blocked) VALUES (?, ?)").bind(userId, val ? 1 : 0).run();
111
}
112

113
// 消息映射
114
async function getMsgMap(env, adminMsgId) {
115
  const row = await env.TG_BOT_DB.prepare("SELECT user_id FROM msg_map WHERE admin_msg_id=?").bind(adminMsgId).first();
116
  return row ? row.user_id : null;
117
}
118

119
async function setMsgMap(env, adminMsgId, userId) {
120
  await env.TG_BOT_DB.prepare("INSERT OR REPLACE INTO msg_map (admin_msg_id, user_id) VALUES (?, ?)").bind(adminMsgId, userId).run();
121
}
122

123
// 通知节流
124
async function getLastMsg(env, userId) {
125
  const row = await env.TG_BOT_DB.prepare("SELECT ts FROM lastmsg WHERE user_id=?").bind(userId).first();
126
  return row ? row.ts : null;
127
}
128

129
async function setLastMsg(env, userId, ts) {
130
  await env.TG_BOT_DB.prepare("INSERT OR REPLACE INTO lastmsg (user_id, ts) VALUES (?, ?)").bind(userId, ts).run();
131
}
132

133
// 诈骗
134
async function isFraud(env, userId) {
135
  const row = await env.TG_BOT_DB.prepare("SELECT user_id FROM fraud WHERE user_id=?").bind(userId).first();
136
  return !!row;
137
}
138

139

140
// ===================== 首次加减验证 ========================
141

142
function genVerifyQuestion() {
143
  let a = Math.floor(Math.random() * 10) + 1;
144
  let b = Math.floor(Math.random() * 10) + 1;
145

146
  if (Math.random() < 0.5) {
147
    return { question: `${a} + ${b} = ?`, answer: a + b };
148
  } else {
149
    if (a < b) [a, b] = [b, a];
150
    return { question: `${a} - ${b} = ?`, answer: a - b };
151
  }
152
}
153

154
async function getVerify(env, userId) {
155
  return await env.TG_BOT_DB.prepare("SELECT * FROM verify WHERE user_id=?").bind(userId).first();
156
}
157

158
async function setVerify(env, userId, question, answer) {
159
  await env.TG_BOT_DB.prepare("INSERT OR REPLACE INTO verify (user_id, question, answer, passed) VALUES (?, ?, ?, 0)").bind(userId, question, answer).run();
160
}
161

162
async function passVerify(env, userId) {
163
  await env.TG_BOT_DB.prepare("UPDATE verify SET passed=1 WHERE user_id=?").bind(userId).run();
164
}
165

166

167
// ===================== 消息主处理 ========================
168

169
async function onMessage(message, env) {
170
  const chatId = message.chat.id.toString();
171
  const ADMIN_UID = env.ENV_ADMIN_UID;
172

173
  // /start
174
  if (message.text === "/start") {
175
    return sendMessage({ chat_id: chatId, text: chatId === ADMIN_UID ? START_MESSAGE_ADMIN : START_MESSAGE, parse_mode: "HTML" }, env);
176
  }
177

178
  // -------- 管理员 --------
179
  if (chatId === ADMIN_UID) {
180
    return handleAdminMessage(message, env);
181
  }
182

183
  // -------- 用户 --------
184
  return handleGuestMessage(message, env);
185
}
186

187

188
// ===================== 管理员逻辑 ========================
189

190
async function handleAdminMessage(message, env) {
191
  const ADMIN_UID = env.ENV_ADMIN_UID;
192

193
  if (!message.reply_to_message?.message_id) {
194
    return sendMessage({ chat_id: ADMIN_UID, text: START_MESSAGE_ADMIN, parse_mode: "HTML" }, env);
195
  }
196

197
  const guestId = await getMsgMap(env, message.reply_to_message.message_id.toString());
198

199
  if (!guestId) {
200
    return sendMessage({ chat_id: ADMIN_UID, text: "无法找到用户映射" }, env);
201
  }
202

203
  // 管理员命令
204
  if (message.text === "/block") return handleBlock(message, env);
205
  if (message.text === "/unblock") return handleUnblock(message, env);
206
  if (message.text === "/checkblock") return handleCheckBlock(message, env);
207

208
  // 正常回复
209
  return copyMessage({
210
    chat_id: guestId,
211
    from_chat_id: ADMIN_UID,
212
    message_id: message.message_id
213
  }, env);
214
}
215

216

217
// ===================== 用户逻辑（含验证 + 资料卡） ========================
218

219
async function handleGuestMessage(message, env) {
220
  const chatId = message.chat.id.toString();
221
  const ADMIN_UID = env.ENV_ADMIN_UID;
222

223
  // --- 1. 验证 ---
224
  const verify = await getVerify(env, chatId);
225

226
  if (!verify) {
227
    const q = genVerifyQuestion();
228
    await setVerify(env, chatId, q.question, q.answer);
229

230
    return sendMessage({
231
      chat_id: chatId,
232
      text: `为了防止骚扰，请先完成验证：\n\n<b>${q.question}</b>`,
233
      parse_mode: "HTML"
234
    }, env);
235
  }
236

237
  if (verify.passed !== 1) {
238
    const ans = parseInt(message.text);
239

240
    if (ans === verify.answer) {
241
      await passVerify(env, chatId);
242

243
      return sendMessage({
244
        chat_id: chatId,
245
        text: "验证通过！你现在可以给管理员发送消息了 🎉"
246
      }, env);
247
    }
248

249
    const q = genVerifyQuestion();
250
    await setVerify(env, chatId, q.question, q.answer);
251

252
    return sendMessage({
253
      chat_id: chatId,
254
      text: `❌ 错误，请重新验证：\n\n<b>${q.question}</b>`,
255
      parse_mode: "HTML"
256
    }, env);
257
  }
258

259
  // --- 2. 是否被屏蔽 ---
260
  if (await getBlock(env, chatId)) {
261
    return sendMessage({ chat_id: chatId, text: "🚫 你被拉黑了" }, env);
262
  }
263

264
  // --- 3. 首次与管理员建立联系 → 发送资料卡 ---
265
  const firstRow = await env.TG_BOT_DB.prepare("SELECT user_id FROM user_first WHERE user_id=?").bind(chatId).first();
266

267
  if (!firstRow) {
268
    await env.TG_BOT_DB.prepare("INSERT INTO user_first (user_id) VALUES (?)").bind(chatId).run();
269

270
    const fullname = (message.from.first_name || "") + (message.from.last_name ? " " + message.from.last_name : "");
271
    const username = message.from.username ? "@" + message.from.username : "无";
272

273
    const now = new Date();
274
    const timeDisplay = now.toLocaleString("zh-CN", { hour12: false });
275

276
    const userCard = `
277
<b>用户资料卡</b>
278
---
279
• 昵称名称: <b>${fullname}</b>
280
• 用户名: <b>${username}</b>
281
• ID: <code>${chatId}</code>
282
• 首次连接时间: <code>${timeDisplay}</code>
283
`;
284

285
    const blockKeyboard = {
286
      inline_keyboard: [
287
        [{ text: "🚫 屏蔽此人 (Block)", callback_data: `block:${chatId}` }]
288
      ]
289
    };
290

291
    await sendMessage({
292
      chat_id: ADMIN_UID,
293
      text: userCard,
294
      parse_mode: "HTML",
295
      reply_markup: blockKeyboard
296
    }, env);
297
  }
298

299
  // --- 4. 转发消息 ---
300
  const fw = await forwardMessage({
301
    chat_id: ADMIN_UID,
302
    from_chat_id: chatId,
303
    message_id: message.message_id
304
  }, env);
305

306
  if (fw.ok) {
307
    await setMsgMap(env, fw.result.message_id.toString(), chatId);
308
  }
309
}
310

311

312
// ===================== 回调按钮（屏蔽） ========================
313

314
async function onCallback(query, env) {
315
  const ADMIN_UID = env.ENV_ADMIN_UID;
316

317
  if (query.from.id.toString() !== ADMIN_UID) {
318
    return;
319
  }
320

321
  const data = query.data;
322

323
  if (data.startsWith("block:")) {
324
    const userId = data.split(":")[1];
325

326
    await setBlock(env, userId, true);
327

328
    await requestTelegram(
329
      "answerCallbackQuery",
330
      makeReq({ callback_query_id: query.id, text: "已拉黑该用户" }),
331
      env
332
    );
333

334
    await requestTelegram(
335
      "editMessageReplyMarkup",
336
      makeReq({
337
        chat_id: query.message.chat.id,
338
        message_id: query.message.message_id,
339
        reply_markup: {
340
          inline_keyboard: [[{ text: "✔ 已拉黑", callback_data: "noop" }]]
341
        }
342
      }),
343
      env
344
    );
345
  }
346
}
347

348

349
// ===================== 管理员命令 ========================
350

351
async function handleBlock(message, env) {
352
  const guest = await getMsgMap(env, message.reply_to_message.message_id.toString());
353

354
  await setBlock(env, guest, true);
355
  return sendMessage({ chat_id: env.ENV_ADMIN_UID, text: `UID:${guest} 已屏蔽` }, env);
356
}
357

358
async function handleUnblock(message, env) {
359
  const guest = await getMsgMap(env, message.reply_to_message.message_id.toString());
360

361
  await setBlock(env, guest, false);
362
  return sendMessage({ chat_id: env.ENV_ADMIN_UID, text: `UID:${guest} 已解除屏蔽` }, env);
363
}
364

365
async function handleCheckBlock(message, env) {
366
  const guest = await getMsgMap(env, message.reply_to_message.message_id.toString());
367
  const blocked = await getBlock(env, guest);
368

369
  return sendMessage({
370
    chat_id: env.ENV_ADMIN_UID,
371
    text: `UID:${guest} → ${blocked ? "已屏蔽" : "未屏蔽"}`
372
  }, env);
373
}
374

375

376
// ===================== Webhook 控制 ========================
377

378
async function registerWebhook(request, env) {
379
  const url = new URL(request.url);
380
  const webhookUrl = `${url.protocol}//${url.hostname}/endpoint`;
381

382
  const res = await fetch(apiUrl("setWebhook", { url: webhookUrl, secret_token: env.ENV_BOT_SECRET }, env)).then(r => r.json());
383
  return new Response(res.ok ? "OK" : JSON.stringify(res));
384
}
385

386
async function unRegisterWebhook(request, env) {
387
  const res = await fetch(apiUrl("setWebhook", { url: "" }, env)).then(r => r.json());
388
  return new Response(res.ok ? "OK" : JSON.stringify(res));
389
}

然后把上面的代码全部复制到里面去.

3. 绑定 D1 数据库#

D1的key为_BOT_DB

4. 设置环境变量#

变量	说明
`ENV_BOT_TOKEN`	Telegram Bot Token
`ENV_ADMIN_UID`	管理员 UID
`ENV_BOT_SECRET`	Webhook secret（可随意生成）

从@BotFather获取token，并且可以发送/setjoingroups来禁止此Bot被添加到群组
从uuidgenerator获取一个随机uuid作为secret
从@username_to_id_bot获取你的用户id
配置worker的变量
- 增加一个ENV_BOT_TOKEN变量，数值为从步骤1中获得的token
- 增加一个ENV_BOT_SECRET变量，数值为从步骤2中获得的secret
- 增加一个ENV_ADMIN_UID变量，数值为从步骤3中获得的用户id

5. 注册 Webhook#

访问：

1
https://你的worker域名/registerWebhook

6. 测试#

测试Bot: @guaguawa_bot

⭐ 系统亮点#

🧩 系统架构#

📦 使用技术#

🗄 数据库结构（D1）#

🔢 首次验证系统（加减法 1～10）#

✨ 验证示例#

🎯 核心功能说明#

1️⃣ 匿名聊天（Forward/Copy）#

2️⃣ 用户资料卡（首次出现）#

3️⃣ 屏蔽 / 解除屏蔽#

4️⃣ 诈骗检测（D1 fraud 表）#

5️⃣ 可控间隔的通知提醒系统#

🛠 Worker 代码结构说明#

📚 使用教程#

1. 创建 Telegram Bot#

2. 部署到 Cloudflare Workers#

3. 绑定 D1 数据库#

4. 设置环境变量#

5. 注册 Webhook#

6. 测试#

文章分享

评论区

基于 Cloudflare Workers + Telegram Bot + D1 的双向匿名聊天系统完整实现

⭐ 系统亮点#

🧩 系统架构#

📦 使用技术#

🗄 数据库结构（D1）#

🔢 首次验证系统（加减法 1～10）#

✨ 验证示例#

🎯 核心功能说明#

1️⃣ 匿名聊天（Forward/Copy）#

2️⃣ 用户资料卡（首次出现）#

3️⃣ 屏蔽 / 解除屏蔽#

4️⃣ 诈骗检测（D1 fraud 表）#

5️⃣ 可控间隔的通知提醒系统#

🛠 Worker 代码结构说明#

📚 使用教程#

1. 创建 Telegram Bot#

2. 部署到 Cloudflare Workers#

3. 绑定 D1 数据库#

4. 设置环境变量#

5. 注册 Webhook#

6. 测试#

文章分享

评论区