import (
"fmt"
+ "flag"
"bytes"
"strconv"
"os"
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 {
//获取房间相关信息
//传输变量至Msg,以便响应弹幕"弹幕机在么"
Msg_roomid = api.Roomid
Msg_cookie = f
- Danmuji_auto(5)
+ Danmuji_auto(1)
}
}()
}
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)