網頁關鍵詞檢測

1. addEventListener("scheduled", event => {
   
2.   event.waitUntil(checkKeywordsAndNotify());
   
3. });
   
4. 
   
5. async function checkKeywordsAndNotify() {
   
6.   const url = 'https://hostloc.com';  // 要检测的网页URL
   
7.   const keyword = '全球主机交流';  // 要检测的关键词
   
8.   const telegramToken = '##';  // TG机器人Token
   
9.   const chatId = '##';  //要推送的TG用户ID
   
10.   
    
11.   try {
    
12.     const urlWithTimestamp = `${url}?t=${Date.now()}`;
    
13.    
    
14.     const response = await fetch(urlWithTimestamp, {
    
15.       method: 'GET',
    
16.       headers: {
    
17.         'Cache-Control': 'no-cache',
    
18.         'Pragma': 'no-cache'
    
19.       }
    
20.     });
    
21.     const text = await response.text();
    
22. 
    
23.     if (!text.includes(keyword)) {
    
24.       await sendTelegramNotification(telegramToken, chatId, `关键词 "${keyword}" 已从 ${url} 上消失`);
    
25.     }
    
26.   } catch (error) {
    
27.     await sendTelegramNotification(telegramToken, chatId, `获取或处理URL时出错: ${error.message}`);
    
28.   }
    
29. }
    
30. 
    
31. async function sendTelegramNotification(token, chatId, message) {
    
32.   const telegramUrl = `https://api.telegram.org/bot${token}/sendMessage`;
    
33.   const response = await fetch(telegramUrl, {
    
34.     method: 'POST',
    
35.     headers: { 'Content-Type': 'application/json' },
    
36.     body: JSON.stringify({
    
37.       chat_id: chatId,
    
38.       text: message
    
39.     })
    
40.   });
    
41.   return response.json();
    
42. }

複製代碼

1，無需服務器，支持部署到cloudflare的workers
2，設定→觸發程序→Cron


可以檢測優質服務器是否補貨，也可以檢測自己的網站是不是掉線了

有個缺點，一旦傳家寶補貨了，機器人會一直提醒你。數據庫可以解決這個問題，但是想法就是簡單穩定快捷。數據庫增加了不確定因素

相關優化版

1. /**
   
2. * Cloudflare Workers 入口：处理所有的 HTTP 请求
   
3. * 每当有请求到达时，都会调用此方法并传递请求对象
   
4. */
   
5. addEventListener('fetch', event => {
   
6.   // 使用 event.respondWith 方法，传入我们自定义的 handleRequest 函数来处理请求
   
7.   event.respondWith(handleRequest(event.request));
   
8. });
   
9. 
   
10. /**
    
11. * 处理传入的 HTTP 请求
    
12. * @param {Request} request - HTTP 请求对象
    
13. * @returns {Response} - 返回处理结果的 HTTP 响应对象
    
14. */
    
15. async function handleRequest(request) {
    
16.   try {
    
17.     // 从请求体中解析 JSON 数据，假设请求体包含需要检测的任务列表
    
18.     const { tasks } = await request.json();
    
19. 
    
20.     // 使用 Promise.all 同时执行多个任务
    
21.     const results = await Promise.all(tasks.map(task => checkKeywordsAndNotify(task.url, task.keyword, task.telegramToken, task.chatId)));
    
22. 
    
23.     // 返回一个包含所有任务结果的 JSON 响应
    
24.     return new Response(JSON.stringify({ success: true, results }), {
    
25.       headers: { 'Content-Type': 'application/json' },
    
26.     });
    
27.   } catch (error) {
    
28.     // 如果有错误，返回错误信息
    
29.     return new Response(JSON.stringify({ success: false, error: error.message }), {
    
30.       headers: { 'Content-Type': 'application/json' },
    
31.     });
    
32.   }
    
33. }
    
34. 
    
35. /**
    
36. * 检查指定 URL 是否包含关键字，并发送 Telegram 通知
    
37. * @param {string} url - 要检测的网页 URL
    
38. * @param {string} keyword - 要检测的关键词
    
39. * @param {string} telegramToken - Telegram 机器人的 Token
    
40. * @param {string} chatId - 要发送通知的 Telegram 用户 ID
    
41. * @returns {Object} - 返回检测结果
    
42. */
    
43. async function checkKeywordsAndNotify(url, keyword, telegramToken, chatId) {
    
44.   try {
    
45.     // 为了防止缓存，给 URL 添加时间戳参数
    
46.     const urlWithTimestamp = `${url}?t=${Date.now()}`;
    
47.    
    
48.     // 发送 GET 请求获取网页内容，禁止缓存
    
49.     const response = await fetch(urlWithTimestamp, {
    
50.       method: 'GET',
    
51.       headers: {
    
52.         'Cache-Control': 'no-cache',
    
53.         'Pragma': 'no-cache',
    
54.       },
    
55.     });
    
56.     const text = await response.text();
    
57. 
    
58.     // 检查网页内容是否包含指定的关键词
    
59.     if (!text.includes(keyword)) {
    
60.       // 如果关键词不包含在网页中，发送 Telegram 通知
    
61.       await sendTelegramNotification(telegramToken, chatId, `关键词 "${keyword}" 已从 ${url} 上消失`);
    
62.       return { url, keyword, status: 'missing' };  // 返回状态：关键词消失
    
63.     }
    
64.     return { url, keyword, status: 'found' };  // 返回状态：关键词仍然存在
    
65.   } catch (error) {
    
66.     // 如果请求或处理过程中出错，发送错误通知
    
67.     await sendTelegramNotification(telegramToken, chatId, `获取或处理URL时出错: ${error.message}`);
    
68.     return { url, keyword, status: 'error', error: error.message };  // 返回错误信息
    
69.   }
    
70. }
    
71. 
    
72. /**
    
73. * 发送 Telegram 消息通知
    
74. * @param {string} token - Telegram 机器人的 Token
    
75. * @param {string} chatId - 要发送消息的 Telegram 用户 ID
    
76. * @param {string} message - 要发送的消息内容
    
77. * @returns {Object} - 返回 Telegram API 的响应
    
78. */
    
79. async function sendTelegramNotification(token, chatId, message) {
    
80.   const telegramUrl = `https://api.telegram.org/bot${token}/sendMessage`;
    
81.   const response = await fetch(telegramUrl, {
    
82.     method: 'POST',
    
83.     headers: { 'Content-Type': 'application/json' },
    
84.     body: JSON.stringify({
    
85.       chat_id: chatId,
    
86.       text: message,
    
87.     }),
    
88.   });
    
89.   return response.json();
    
90. }

複製代碼

相關軟件：https://github.com/Xinslive/NotifyMe