Skip to content

This package helps establish a websocket connection to the bilibili streaming server.

Notifications You must be signed in to change notification settings

q629988171/biliStreamClient

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

9 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

biliStreamClient

This package helps establish a websocket connection to the bilibili streaming server.
bilibili直播弹幕的WebSocket协议分析请参考:https://blog.csdn.net/xfgryujk/article/details/80306776


基于这个package,我写了一个朗读弹幕的网页应用
讲解: https://www.bilibili.com/video/BV18X4y1G7Ks/
试用: https://www.danmujun.online/

BiliClient is a struct with the following public methods

type BiliClient struct {
	serverConn      *websocket.Conn
	uid             int
	connected       bool
	roomID          int
	mutex           *sync.Mutex
	protocolVersion uint16
	Ch              chan PacketBody
}

func (bili *BiliClient) Connect(rid int) error
func (bili *BiliClient) Disconnect() error

After using BiliClient.Connect, a websocket connection between your machine and the Bilibili live-stream server is established. The BiliClient will listen to messages sent back from the live-stream server, parse it into a packBody, and put it into BiliClient.Ch.

We just need to fetch the packBody from BiliClient.Ch.

Currently packBody supports ParseDanmu(), ParseGift() and ParseGiftCombo(). You can also write custom parser to parse the data from the PackBody into your own data structure.

使用的时候我们只需要新建一个BiliClient,然后Connect(),然后从BiliClient.Ch里面不断取出PackBody即可。对于PackBody,目前支持parse 弹幕,礼物和礼物Combo, 分别对应DANMU_MSG,SEND_GIFT和COMBO_SEND。

Example Usage:

package main

import (
	"github.com/JimmyZhangJW/biliStreamClient"
	"log"
)

func main() {
	biliClient := biliStreamClient.New()
	biliClient.Connect(22763457)

	for {
		packBody := <-biliClient.Ch
		switch packBody.Cmd {
		case "DANMU_MSG":
			danmu, error := packBody.ParseDanmu()
			if error != nil {
				log.Fatalln(error)
			}
			log.Println(danmu)
		case "SEND_GIFT":
			gift, error := packBody.ParseGift()
			if error != nil {
				log.Fatalln(error)
			}
			log.Println(gift)
		case "COMBO_SEND":
			combo, error := packBody.ParseGiftCombo()
			if error != nil {
				log.Fatalln(error)
			}
			log.Println(combo)
		default:
			//log.Println(packBody.Cmd)
		}
	}
}

About

This package helps establish a websocket connection to the bilibili streaming server.

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Go 100.0%