您的位置: 首页  >  文章  >  b站直播弹幕获取

b站直播弹幕获取

分类: 文章 • 2024-06-29 18:14:46

博主本人在空闲的时候比较喜欢看一些游戏直播，发现好多主播都在使用弹幕姬，便对弹幕姬的原理产生了兴趣，打算自己动手做一个弹幕播报的程序

网页分析

随便进入一个b站的直播间
（本次使用直播间链接：https://live.bilibili.com/528?spm_id_from=333.334.b_62696c695f6c697665.24）
b站直播弹幕获取按【F12】 打开开发者工具，然后按【F5】刷新网页，再点击【网络】，查看收发的网络请求包，发现其中有一个名为 “msg”的数据包
b站直播弹幕获取msg不就是消息的简写吗！（难道，这个就是传输弹幕信息的数据包吗？）
那就点击进入查看数据包的内容看看和我们想的一不一样，
【右键】这个数据包，选择【在新标签页打开】
b站直播弹幕获取打开后将会看到如下画面
b站直播弹幕获取点击【admin】前的倒三角折叠该字典 （room应该是房管的消息列表）
我们查看【room】字典的内容 （room应该是房间中的弹幕）
看到用户【zyvvcgnfdfy】，发送了一个消息【快乐】，在【18:09:24】时
b站直播弹幕获取，回到直播间中确认是否出现过这条消息（ps：这里就先不演示的，消息闪的太快没截到图），
经过验证后，发现确实是【msg】 这个数据包用来传输弹幕消息的。。

代码解析

import requests
import win32com.client
import time

old_list = []
#创建一个old_list列表用于辅助后面的text_danmu方法提取新消息
class Danmu():
#定义一个Danmu类
    def __init__(self):
        self.url = "https://api.live.bilibili.com/ajax/msg"
        self.headers ={
            "User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64; rv:65.0) Gecko/20100101 Firefox/65.0",
            "Referer": "https://live.bilibili.com/284165?spm_id_from=333.334.b_62696c695f6c697665.13",
            }
        self.data = {
            "roomid":"5441",
            "csrf_token":"",	
            "csrf":"",	
            "visit_id":""
            }
        #在 __init__方法中先定义好要使用的请求url,请求头，和请求参数
    def speak_text(self,text):
    #定义一个speak_text方法，并创建形参text，用于作为接下来读取的文字
        speak = win32com.client.Dispatch("SAPI.SpVoice")
        #创建发声对象
        speak.Speak(text)
        #使用发生对象读取文字
        
    def text_danmu(self,html):
    #创建一个text_danmu方法，用于提取弹幕信息
        global old_list
        #设置变量作用域，使得该方法可以修改全局变量old_list的值
        temp_list = []
        #创建一个temp_list列表用于作为临时列表辅助提取弹幕消息
        for text in html["data"]["room"]:
        #for循环提取html字典中嵌套的子字典data中嵌套的子字典room的内容赋值给text变量
        #这个html字典来自于get_danmu方法传递
            temp_list.append(text["text"])
            #将变量text字典中text键的值添加到temp_list中
        if temp_list == old_list:
            pass
        #检测temp_list临时列表的内容和old_list是否相同，如果相同则跳过
        else:
            for text_number in range (1,11):
            #创建for循环一次将1到10的数字赋给text_number
                if "".join(temp_list[:text_number]) in "".join(old_list):
                    pass
                #使用join方法以""为分割符提取temp_list切割后的列表的内容
                #使用join方法以""为分割符提取old_list列表的内容
                #比较内容是否相同，如果相同则跳过
                else:
                    try:
                        print (temp_list[text_number-1])
                    except:
                        pass
                    else:
                        self.speak_text(temp_list[text_number-1])
                    #尝试打印temp_list指定索引的内容，如果报错则跳过
                    #否则调用speak_text方法，进行文字转语言
            old_list = temp_list[:]
            #将temp_list的值赋给old_list，进行更新旧信息列表
            
    def get_danmu(self):
        html = requests.post(url=self.url,headers=self.headers,data=self.data)
        html.json()
        self.text_danmu(eval(html.text))
    #定义get_danmu方法
    #使用requests.post方法获取网页内容
    #将网页返回值以json的信息加载
    #调用之前定义的text_danmu方法，传递eval处理后的网页返回值的文本内容
bzhan = Danmu()
#创建一个bzhan实例
while True:
    bzhan.get_danmu()
    time.sleep(3)
    #每三秒钟调用一个bzhan实例的get_danmu方法

相关推荐