package main
import (
"context"
"log"
"time"
"github.com/shynome/err0/try"
bilibili "github.com/shynome/openapi-bilibili"
"github.com/shynome/openapi-bilibili/live"
)
func main() {
bclient := bilibili.NewClient("access_key_id", "access_key_secret")
ctx := context.Background()
app := try.To1(bclient.Open(ctx, 0000000000000, "主播身份码"))
defer app.Close()
go app.KeepAlive(ctx)
info := app.Info().WebsocketInfo
room := live.RoomWith(info)
ctx, closeMsgCh := context.WithCancel(ctx)
go func() {
time.Sleep(10 * time.Minute)
closeMsgCh()
}()
msgCh := try.To1(room.Connect(ctx))
for msg := range msgCh {
log.Println("msg", msg.Cmd, msg.Data)
}
}
-
Notifications
You must be signed in to change notification settings - Fork 1
License
shynome/openapi-bilibili
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|