python实现B站直播自动弹幕发送

# 简单的代码
import requests

url = 'https://api.live.bilibili.com/msg/send'
data = {
    'bubble': '0',
    'msg': 'test',# 发送的信息
    'color': '16777215',
    'mode': '1',
    'fontsize': '25',
    'rnd': '1646460756',# 时间戳
    'room_type': '0',
    'roomid': '', # 直播间房间号
    'csrf': '', # 自己的csrf
    'csrf_token': '', 自己的csrf_token
}

headers = {
    'cookie': '', # 自己的cookie
    'origin': 'https://live.bilibili.com',
    'referer': '', # 自己的referer
    'user-agent': '' # 自己的user—agent
}
response = requests.post(url=url, data=data, headers=headers)

if response.status_code == 200:
    print("消息发送成功！")
    # print(response.json())
else:
    print(f"消息发送失败，状态码：{response.status_code}")
    print(response.text)

# 如果显示：消息发送成功，，但是却没有弹幕发送，可以刷新直播间，
# 如果还是没有，就可以取消` print(response.json())` 的注释，查看一下返回的响应，找出错的地方

import requests
import time
import random
import pymysql



connection = pymysql.connect(
                    host="localhost",
                    user="root",
                    passwd="",
                    # auth_plugin='mysql_native_password',  # 加密认证方式
                    database="danmaku",  # 连接的数据库
                    # autocommit=True  # 每次对数据库操作完自动提交
                )

cursor = connection.cursor()
sql = "SELECT COUNT(*) FROM test"

cursor.execute(sql)
table_length = cursor.fetchone()[0]

sql1 = "select comment from test where id= %s"


url = "https://api.live.bilibili.com/msg/send"



# 加密数据
salt_data1 = {
    'jumpfrom': '',
    'csrf': '',
    'csrf_token': '',
}

salt_data2 = {
    'jumpfrom': '',
    'csrf': '',
    'csrf_token': '',
}



headers1 = {
    'cookie':"",
    'Origin': 'https://live.bilibili.com',
    'Referer': "",
    "user-agent":""
}

headers2 = {
    'cookie':"",
    'Origin': 'https://live.bilibili.com',
    'Referer': "",
    "user-agent":""

salt_list = [salt_data1, salt_data2]
header_list = [headers1, headers2]


# print(data)
# print(select_header)


while True:
    time.sleep(2)
    # 获取当前时间戳（以秒为单位）
    timestamp = int(time.time())

    cursor.execute(sql1, random.randint(1, table_length))
    random_comment = cursor.fetchone()[0]

    # 通用数据
    com_data = {
        'bubble': '0',
        'msg': '{}'.format(random_comment),
        'color': '16777215',
        'mode': '1',
        'room_type': '0',
        'fontsize': '25',
        'rnd': '{}'.format(timestamp),  # 时间戳
        # 30899092
        'roomid': '13845655',
    }

    randint = random.randint(0, 1)

    select_salt = salt_list[randint]
    select_header = header_list[randint]

    data = {}

    for data_dict in [com_data, select_salt]:
        data.update(data_dict)

    response = requests.post(url=url, data=data, headers=select_header)

    if response.status_code == 200:
        print("消息发送成功！")
        # print(response.json())
    else:
        print(f"消息发送失败，状态码：{response.status_code}")
        print(response.text)

# 当然代码还能继续修改，但是作为一个临时使用已经完全足够了。