nodejs+playwright获取抖音弹幕

alwaysol

原理是直接后台浏览器打开直播网页,实时获取页面弹幕信息,简单粗暴,缺点是有点占内存
获取弹幕在终端显示,适合上班摸鱼看

[JavaScript] 纯文本查看 复制代码

?

01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83

const { chromium, firefox, webkit, devices } = require('playwright');   (async () => {       const browser = await chromium.launch({         headless: true, // 无头模式     });       try {           const context = await browser.newContext({             userAgent: 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36'         });           // 创建新页面并访问网站         const page = await context.newPage();           // 拦截请求并阻止加载图片和视频流         await page.route('**/*', (route) => {             const url = route.request().url();             const request = route.request();             const resourceType = request.resourceType();             if (resourceType == 'image' || resourceType == 'media') {                 //console.log(`阻止资源加载: ${url}`);                 route.abort();  // 阻止加载图片和视频             }             else {                 route.continue();  // 继续加载其他资源             }         });           await page.goto('https://live.douyin.com/6096197105');//改成自己想看的主播直播地址         await page.waitForTimeout(1000 * 5); // 等待 5 秒           const element = await page.locator('.basicPlayer');         await element.waitFor({ timeout: 1000 * 5 }); // 等待元素出现         const text = await element.textContent();         if(text.includes('直播已结束')){             console.log('直播已结束,退出程序....');             await browser.close();             return;         }           //选择目标元素         await page.waitForSelector('.webcast-chatroom___item-wrapper');         console.log('页面加载完成....');           await page.evaluate(() => {             const elements = document.querySelectorAll('.basicPlayer');             elements.forEach(element => {                 element.remove();             });         });           let init_text = null;         setInterval(async () => {               const elements = await page.$$('.webcast-chatroom___item-wrapper');               let texts = [];             for (let element of elements) {                 const text = await element.innerText();                 //console.log(text);                 texts.push(text);             }               if (init_text == null) {                 texts.map(x => console.log(x));             }             else {                 const diff1 = texts.filter(item => !init_text.includes(item));                 diff1.map(x => console.log(x));             }             init_text = texts;           }, 1000);       } catch (error) {         console.log('出现错误:', error);         await browser.close();     }   })();