gobilibili

B 站直播弹幕 Go 版。在原项目基础上作了以下修改:

自动获取直播间真实ID,兼容短ID
增加赠送礼物/进入房间在线人数变动消息处理
增加方便的消息事件订阅机制，用于将自己的处理器注册到消息处理链
原处理逻辑现在被包装为一个处理器，名为DefaultHandler
增加了一些函数，用于事件触发时快速获取消息结构(徽章，等级，礼物信息，类型，数量，标志等等)
为大部分函数添加了错误处理

安装

go get github.com/lyyyuna/gobilibili

示例

实时打印弹幕

package main

import "github.com/lyyyuna/gobilibili"

func main() {
    bili := gobilibili.NewBiliBiliClient()
    bili.RegHandleFunc(gobilibili.CmdAll, gobilibili.DefaultHandler)
    bili.ConnectServer(102)
}

事件订阅

如果你希望订阅不同的事件，请尝试gobilibili.Cmd*开头的一系列常量。以下是一些示例,你也可以随时在example目录下查看.

订阅弹幕事件，并输出弹幕信息

bili := gobilibili.NewBiliBiliClient()
bili.RegHandleFunc(gobilibili.CmdDanmuMsg, func(c *gobilibili.Context) bool {
    dinfo := c.GetDanmuInfo()
    log.Printf("[%d]%d 说: %s\r\n", c.RoomID, dinfo.UID, dinfo.Text)
    return false
})

进入房间

bili.RegHandleFunc(gobilibili.CmdWelcome, func(c *gobilibili.Context) bool {
    winfo := c.GetWelcomeInfo()
    if winfo.Uname != "" {
        log.Printf("[%d]%s 进入了房间\r\n", c.RoomID, winfo.Uname)
    } else {
        log.Printf("[%d]%d 进入了房间\r\n", c.RoomID, winfo.UID)
    }
    return false
})

投喂礼物

bili.RegHandleFunc(gobilibili.CmdSendGift, func(c *gobilibili.Context) bool {
    gInfo := c.GetGiftInfo()
    log.Printf("[%d]%s %s 了 %s x %d (价值%.3f)\r\n", c.RoomID, gInfo.Uname, gInfo.Action, gInfo.GiftName, gInfo.Num, float32(gInfo.Price*gInfo.Num)/1000)
    return false
})

在线人数变动

bili.RegHandleFunc(gobilibili.CmdOnlineChange, func(c *gobilibili.Context) bool {
    online := c.GetOnlineNumber()
    log.Printf("[%d]房间里当前在线：%d\r\n", c.RoomID, online)
    return false
})

状态切换为直播开始

bili.RegHandleFunc(gobilibili.CmdLive, func(c *gobilibili.Context) bool {
    online := c.GetOnlineNumber()
    log.Println("主播诈尸啦!")
    return false
})

状态切换为准备中

bili.RegHandleFunc(gobilibili.CmdPreparing, func(c *gobilibili.Context) bool {
    online := c.GetOnlineNumber()
    log.Println("主播正在躺尸")
    return false
})

返回值 Handler和HandleFunc的返回值用于控制调用链是否继续向下执行。如果你希望其它调用链能够继续响应这个事件，请返回false。

消息调试

通过注册gobilibili.DebugHandler,可以在收到直播消息时查看原始消息。

package main

import "github.com/lyyyuna/gobilibili"

func main() {
    bili := gobilibili.NewBiliBiliClient()
    bili.RegHandleFunc(gobilibili.CmdAll, gobilibili.DebugHandler)
    bili.ConnectServer(102)
}

运行后,当直播间发生事件时,将会输出类似格式的JSON输出:

{
  "cmd": "DANMU_MSG",
  "info": [
    [
      0,
      1,
      25,
      16777215,
      1517402685,
      -136720455,
      0,
      "c42d0814",
      0
    ],
    "干嘛不播啦",
    [
      30731115,
      "Ed在",
      0,
      0,
      0,
      10000,
      1,
      ""
    ],
    [],
    [
      1,
      0,
      9868950,
      "\u003e50000"
    ],
    [],
    0,
    0,
    {
      "uname_color": ""
    }
  ]
}

以上示例的是一个弹幕消息. 其中"cmd": "DANMU_MSG"中的"DANMU_MSG",就是调用bili.RegHandleFunc时需要传入的cmd参数。你可以通过gobilibili.CmdType("嘿,我是CmdType"),将string转换为CmdType. 在这之后，你可以使用 bili.RegHandleFunc 或 bili.RegHandler 注册这个CmdType.

扩展

通过读取gobilibili.Context传入的Msg,可以处理尚未进行支持的事件. 请搭配上一节的消息调试进行食用。以下是DefaultHandler的实现。

func DefaultHandler(c *Context) bool {
    cmd, err := c.Msg.Get("cmd").String()
    if err != nil {
        return true
    }
    if cmd == "LIVE" {
        fmt.Println("直播开始。。。")
        return false
    }
    if cmd == "PREPARING" {
        fmt.Println("房主准备中。。。")
        return false
    }
    if cmd == "DANMU_MSG" {
        commentText, err := c.Msg.Get("info").GetIndex(1).String()
        if err != nil {
            fmt.Println("Json decode error failed: ", err)
            return false
        }

        commentUser, err := c.Msg.Get("info").GetIndex(2).GetIndex(1).String()
        if err != nil {
            fmt.Println("Json decode error failed: ", err)
            return false
        }
        fmt.Println(commentUser, " say: ", commentText)
        return false
    }
    return false
}

lyyyuna / gobilibili

readme

gobilibili

安装

示例

实时打印弹幕

事件订阅

消息调试

扩展