最近b站直播弹幕获取是否有点异常

[zhimingshenjun]

以前写的一直很稳的websocket抓包现在经常丢包 直播间刷了一堆了这边只能抓到几条信息

[ProgramRipper]

ws 连接时带上 User-Agent 头即可

[whiteeat]

亲测有效

[nailvcoronation]

ws 连接时带上 User-Agent 头即可

现在还好用吗...? 昨天开始加了UA也开始漏了，连了7000多个ws每秒只收得到十条弹幕。

而且只连一个或几个ws的时候还挺正常的，连多了就不行了。

[whiteeat]

ws 连接时带上 User-Agent 头即可

现在还好用吗...? 昨天开始加了UA也开始漏了，连了7000多个ws每秒只收得到十条弹幕。

前天我用还挺好，昨天没试

[nailvcoronation]

用python和go的两个弹幕库试了一下，连多了的时候都收不到弹幕。

Golang:

package main

import (
    "bytes"
    "encoding/json"
    "time"

    "github.com/Akegarasu/blivedm-go/client"
    "github.com/Akegarasu/blivedm-go/message"
    _ "github.com/Akegarasu/blivedm-go/utils"
    "github.com/go-resty/resty/v2"
    log "github.com/sirupsen/logrus"
)

type List = []interface{}
type Dict = map[string]interface{}

func main() {
    counterCh := make(chan int, 1000)
    startCh := make(chan int, 1000)
    go func() {
        count := 0
        runningClients := 0
        lastPollTime := time.Now()
        for {
            ticker := time.NewTicker(time.Second)
            select {
            case <-ticker.C:
                log.Infof("%v个弹幕客户端在过去%v秒内共获取了%v条弹幕", runningClients, time.Since(lastPollTime), count)
                lastPollTime = time.Now()
                count = 0
            case <-counterCh:
                count++
            case <-startCh:
                runningClients++
            }
        }
    }()
    httpClient := resty.New()
    httpClient.JSONUnmarshal = unmarshal
    var vups List
    httpClient.R().SetResult(&vups).Get("https://vup-json.xn--7dvy22i.com/vup-array.json")
    for idx, vup := range vups {
        if idx%(len(vups)/180) == 0 {
            time.Sleep(time.Second)
        }
        uid := vup.(Dict)["uid"].(json.Number).String()
        room := vup.(Dict)["room"].(json.Number).String()
        if room == "0" {
            continue
        }
        c := client.NewClient(room, uid)
        c.OnDanmaku(func(danmaku *message.Danmaku) {
            counterCh <- 1
        })
        go func() {
            err := c.Start()
            if err != nil {
                log.Warn(err)
            } else {
                startCh <- 1
            }
        }()
    }

    select {}
}

func unmarshal(data []byte, v interface{}) error {
    decoder := json.NewDecoder(bytes.NewReader(data))
    decoder.UseNumber()
    return decoder.Decode(&v)
}

Python:

import asyncio
from bilibili_api.live import LiveDanmaku
import requests

async def main():
    count = 0
    lock = asyncio.Lock()
    async def counter(msg):
        nonlocal count
        async with lock:
            count += 1
    resp = requests.get('https://vup-json.xn--7dvy22i.com/vup-array.json')
    resp = resp.json()
    for idx, r in enumerate(resp):
        if idx % (len(resp) // 180) == 0:
            await asyncio.sleep(1)
        if r["room"] == 0:
            continue
        room = LiveDanmaku(r["room"], max_retry = 10)
        room.add_event_listener('DANMU_MSG', counter)
        asyncio.create_task(room.connect())
    async def foo():
        nonlocal count
        while True:
            async with lock:
                print(count)
                count = 0
            await asyncio.sleep(1)
    await foo()

if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(main())

这两个库应该都是没有在连接ws的时候加UA的，但是我自己手写的加了UA情况也差不多。

[cqrect]

我用同一段代码尝试连接不同的直播间，发现部分直播间除了 STOP_LIVE_ROOM_LIST 拿不到其他东西。请教下是只是我的问题还是其他人也有这样的现象？