关于显示直播间数量

[bommbo]

求问，这个项目是只能显示各个分类中排名靠前的直播吗，其余的怎么显示？

[caiguanhao]

目前请求各分类前 15 个直播是不需要签名，而且不会触发滑动验证；因为抖音的签名方法很复杂，所以我想只能通过 chromedp 访问特定页面，移动页面或者执行 JavaScript，通过截取 JSON 返回的方法获取页面余下内容。但 chromedp 也不是万能，之前我试过 Tiktok 能识别 chromedp 但不能识别 puppeteer。迟点会考虑加入用 chromedp 的命令。下面是 demo：

package main

import (
	"context"
	"errors"
	"fmt"
	"log"
	"net/url"
	"strings"
	"time"

	"github.com/chromedp/cdproto/cdp"
	"github.com/chromedp/cdproto/network"
	"github.com/chromedp/chromedp"
	"github.com/chromedp/chromedp/device"
)

func main() {
	data, _ := getResponse()
	fmt.Println(string(data))
}

func newContext() (context.Context, context.CancelFunc) {
	ctx := context.Background()
	// options := append(
	// 	chromedp.DefaultExecAllocatorOptions[:],
	// 	chromedp.Flag("headless", false),
	// )
	// ctx, _ = chromedp.NewExecAllocator(ctx, options...)
	return chromedp.NewContext(ctx)
}

func getResponse() ([]byte, error) {
	verbosive := true

	ctx, cancel := newContext()
	defer cancel()

	pageUrl := (&url.URL{
		Scheme: "https",
		Host:   "live.douyin.com",
		Path:   "/",
	}).String()
	if verbosive {
		log.Println("visiting", pageUrl)
	}

	chanResponse := make(chan []byte)
	chanError := make(chan error)

	chromedp.ListenTarget(ctx, func(v interface{}) {
		ev, ok := v.(*network.EventResponseReceived)
		if !ok {
			return
		}
		if ev.Type != network.ResourceTypeFetch ||
			!strings.Contains(ev.Response.URL, "/webcast/web/roadmap/") {
			return
		}
		if verbosive {
			log.Println("getting", ev.Response.URL)
		}
		go func() {
			c := chromedp.FromContext(ctx)
			cc := cdp.WithExecutor(ctx, c.Target)
			rbp := network.GetResponseBody(ev.RequestID)
			body, err := rbp.Do(cc)
			if err != nil {
				chanError <- err
				return
			}
			chanResponse <- body
		}()
	})
	go func() {
		err := chromedp.Run(
			ctx,
			network.Enable(),
			chromedp.Emulate(device.IPhoneX),
			chromedp.Navigate(pageUrl),
		)
		if err != nil {
			chanError <- err
		}
	}()

	timeout := time.After(30 * time.Second)

	select {
	case response := <-chanResponse:
		chromedp.Cancel(ctx)
		return response, nil
	case err := <-chanError:
		return nil, err
	case <-timeout:
		return nil, errors.New("timed out")
	}
}