From: qydysky Date: Sun, 20 Sep 2020 09:31:39 +0000 (+0800) Subject: 16 X-Git-Tag: v0.0.0~27 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=d8d8886d2674cf5c42cf8a4a4efd3aff8086d126;p=bili_danmu%2F.git 16 --- diff --git a/bili_danmu.go b/bili_danmu.go index 7b5c357..56249f4 100644 --- a/bili_danmu.go +++ b/bili_danmu.go @@ -2,6 +2,7 @@ package bili_danmu import ( "fmt" + "flag" "bytes" "strconv" "os" @@ -22,15 +23,23 @@ func Demo() { interrupt := make(chan os.Signal, 1) signal.Notify(interrupt, os.Interrupt) + { - var room int + var groomid = flag.Int("r", 0, "roomid") + flag.Parse() + + var room = *groomid fmt.Printf("输入房间号: ") - _, err := fmt.Scanln(&room) - if err != nil { - danmulog.E("输入错误", err) - return + if room == 0 { + _, err := fmt.Scanln(&room) + if err != nil { + danmulog.E("输入错误", err) + return + } + } else { + fmt.Print(strconv.Itoa(room), "\n") } - + var break_sign bool for !break_sign { //获取房间相关信息 @@ -69,7 +78,7 @@ func Demo() { //传输变量至Msg,以便响应弹幕"弹幕机在么" Msg_roomid = api.Roomid Msg_cookie = f - Danmuji_auto(5) + Danmuji_auto(1) } }() } diff --git a/send.go b/send.go index 74372af..9637399 100644 --- a/send.go +++ b/send.go @@ -7,12 +7,12 @@ import ( p "github.com/qydysky/part" ) -//每秒一个令牌,最多等5秒 -var danmu_s_limit = p.Limit(1, 1500, 5000) +//每5s一个令牌,最多等10秒 +var danmu_s_limit = p.Limit(1, 5000, 10000) //弹幕发送 func Danmu_s(msg,Cookie string, roomid int) { - //等待令牌时阻塞,超时返回false + //等待令牌时阻塞,超时返回true if danmu_s_limit.TO() {return} l := p.Logf().New().Base(-1, "弹幕发送").Level(1)