reply

README

---

目录释义

目录	说明
./	接收的数据处理区
json/	json的golang struct表述
ws_msg/	弹幕服务器传回的Msg类型json的golang struct表述
0Init.go	最初始载入配置
F.go	附加功能
flvDecode.go	直播流转局域网直播流
Heartbeat.go	人气数据分派
Msg.go	消息数据分派
Reply.go	分派数据处理
gtk.go	gtk弹幕窗模块
tts.go	TTS语音模块

---

Documentation

Index

• Variables
• func Ass_f(ctx context.Context, save_path string, filePath string, st time.Time)
• func Assf(s string)
• func AutoSend_silver_gift()
• func Autoskipf(s string) uint
• func Danmuji_auto()
• func Danmujif(s string)
• func Entry_danmu()
• func Gui_show(m ...string)
• func Heart(b []byte)
• func IsOn(s string) bool
• func Itos(i []interface{}) string
• func Jiezouf(s []string) bool
• func Keep_medal_light()
• func Lessdanmuf(s string) (show bool)
• func Msg(b []byte)
• func Msg_senddanmu(msg string)
• func Msg_showdanmu(item Danmu_item)
• func PlayRecDanmu(filePath string) (*websocket.Server, func())
• func Reply(b []byte)
• func Search_stream_tag(buf []byte, keyframe *slice.Buf[byte]) (front_buf []byte, last_available_offset int, err error)
• func SendStreamWs(item Danmu_item)
• func Shortdanmuf(s string) string
• func StartRecDanmu(ctx context.Context, filePath string)
• func StreamOCommon(roomid int) (array []*c.Common)
• func StreamOCut(roomid int) (setTitle func(string))
• func StreamOStart(roomid int)
• func StreamOStatus(roomid int) (Islive bool)
• func StreamOStop(roomid int)
• func TTS(msg string)
• type Ass
• type Autoskip
• type Autoskip_item
• type Communicate
  • func (t *Communicate) Count() int
  • func (t *Communicate) Reset()
  • func (t *Communicate) Store(k interface{})
• type Danmu_item
• type Danmu_mq_t
• type Danmuji
• type Fmp4Decoder
  • func NewFmp4Decoder() *Fmp4Decoder
  • func (t *Fmp4Decoder) Init_fmp4(buf []byte) (b []byte, err error)
  • func (t *Fmp4Decoder) Search_stream_fmp4(buf []byte, keyframe *slice.Buf[byte]) (cu int, err error)
• type Jiezou
• type Lessdanmu
• type M4SStream
  • func (t *M4SStream) Common() *c.Common
  • func (t *M4SStream) Cut()
  • func (t *M4SStream) GetSavePath() string
  • func (t *M4SStream) GetStreamType() string
  • func (t *M4SStream) LoadConfig(common *c.Common) (e error)
  • func (t *M4SStream) MarshalJSON() ([]byte, error)
  • func (t *M4SStream) PusherToFile(contextC context.Context, filepath string, startFunc func(*M4SStream) error, ...) error
  • func (t *M4SStream) PusherToHttp(conn net.Conn, w http.ResponseWriter, r *http.Request, ...) error
  • func (t *M4SStream) Start() bool
  • func (t *M4SStream) Stop()
• type M4SStream_Config
• type SaveDanmuToDB
• type Shortdanmu

Variables

var (
	Ass_height = 720  //字幕高度
	Ass_width  = 1280 //字幕宽度
	Ass_font   = 50   //字幕字体大小
	Ass_T      = 7    //单条字幕显示时间
	Ass_loc    = 7    //字幕位置 小键盘对应的位置
)

var (
	ErrBufTooLarge = errors.New("ErrBufTooLarge")
	ErrMisTraks    = errors.New("ErrMisTraks")
)

var (
	ErrMisBox     = perrors.New("decode", "ErrMisBox")
	ErrCantResync = perrors.New("decode")
)

var Danmu_mq = mq.New()

var (
	ErrUnkownBox = perrors.New("ErrUnkownBox")
)

var Heart_map = map[string]func(replyF, int){
	"heartbeat": replyF.heartbeat,
}

var Msg_map = map[string]func(replyF, string){}/* 115 elements not displayed */

Msg类型数据处理方法map

var SaveToJson saveToJson

var StreamWs = websocket.New_server()

直播Web服务口

var (
	TTS_setting_string = map[string]string{
		"0buyguide":  "感谢{D}",
		"0gift":      "感谢{D}",
		"0superchat": "感谢{D}",
	}
)

Functions

func Ass_f

func Ass_f(ctx context.Context, save_path string, filePath string, st time.Time)

设定字幕文件名，为""时停止输出

func Assf

func Assf(s string)

传入要显示的单条字幕

func AutoSend_silver_gift

func AutoSend_silver_gift()

自动发送即将过期的银瓜子礼物

func Autoskipf

func Autoskipf(s string) uint

func Danmuji_auto

func Danmuji_auto()

func Danmujif

func Danmujif(s string)

func Entry_danmu

func Entry_danmu()

进入房间发送弹幕

func Gui_show

func Gui_show(m ...string)

消息显示

func Heart

func Heart(b []byte)

HeartBeat类型，将人气4位byte转为字符串，并送到上述map指定的方法

func IsOn

func IsOn(s string) bool

功能开关选取函数

func Itos

func Itos(i []interface{}) string

func Jiezouf

func Jiezouf(s []string) bool

func Keep_medal_light

func Keep_medal_light()

保持所有牌子点亮

func Lessdanmuf

func Lessdanmuf(s string) (show bool)

func Msg

func Msg(b []byte)

Msg类型数据处理方法挑选 识别cmd字段类型，查找上述map中设置的方法，并将json转为字符串型传入

func Msg_senddanmu

func Msg_senddanmu(msg string)

弹幕发送 传入字符串即可发送 需要cookie

func Msg_showdanmu

func Msg_showdanmu(item Danmu_item)

弹幕显示 由于额外功能有些需要显示，为了统一管理，使用此方法进行处理

func PlayRecDanmu

func PlayRecDanmu(filePath string) (*websocket.Server, func())

func Reply

func Reply(b []byte)

返回数据分派 传入接受到的ws数据 判断进行解压，并对每个json对象进行分派

func Search_stream_tag

func Search_stream_tag(buf []byte, keyframe *slice.Buf[byte]) (front_buf []byte, last_available_offset int, err error)

this fuction read []byte and return flv header and all complete keyframe if possible. complete keyframe means the video and audio tags between two video key frames tag

func SendStreamWs

func SendStreamWs(item Danmu_item)

func Shortdanmuf

func Shortdanmuf(s string) string

func StartRecDanmu

func StartRecDanmu(ctx context.Context, filePath string)

弹幕回放

func StreamOCommon

func StreamOCommon(roomid int) (array []*c.Common)

获取实例的Common

func StreamOCut

func StreamOCut(roomid int) (setTitle func(string))

实例切断

func StreamOStart

func StreamOStart(roomid int)

开始实例

func StreamOStatus

func StreamOStatus(roomid int) (Islive bool)

获取实例的录制状态

func StreamOStop

func StreamOStop(roomid int)

停止实例

-2 其他房间 -1 所有房间 针对某房间

func TTS

func TTS(msg string)

Types

type Ass

type Ass struct {
	// contains filtered or unexported fields
}

Ass 弹幕转字幕

type Autoskip

type Autoskip struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Autoskip_item

type Autoskip_item struct {
	Exprie uint
	Num    uint
}

type Communicate

type Communicate struct {
	Buf *psync.Map
}

func (*Communicate) Count

func (t *Communicate) Count() int

func (*Communicate) Reset

func (t *Communicate) Reset()

func (*Communicate) Store

func (t *Communicate) Store(k interface{})

type Danmu_item

type Danmu_item struct {
	// contains filtered or unexported fields
}

Msg-弹幕处理

type Danmu_mq_t

type Danmu_mq_t struct {
	// contains filtered or unexported fields
}

type Danmuji

type Danmuji struct {
	Buf        map[string]string
	Inuse_auto bool
	// contains filtered or unexported fields
}

type Fmp4Decoder

type Fmp4Decoder struct {
	AVTDiff float64 // 音视频时间戳容差
	// contains filtered or unexported fields
}

func NewFmp4Decoder

func NewFmp4Decoder() *Fmp4Decoder

func (*Fmp4Decoder) Init_fmp4

func (t *Fmp4Decoder) Init_fmp4(buf []byte) (b []byte, err error)

func (*Fmp4Decoder) Search_stream_fmp4

func (t *Fmp4Decoder) Search_stream_fmp4(buf []byte, keyframe *slice.Buf[byte]) (cu int, err error)

type Jiezou

type Jiezou struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Lessdanmu

type Lessdanmu struct {
	// contains filtered or unexported fields
}

type M4SStream

type M4SStream struct {
	Status context.Context //IsLive()是否运行中

	Stream_msg *msgq.MsgType[[]byte] //流数据消息 tag:data

	Current_save_path string //明确的直播流保存目录

	Callback_start    func(*M4SStream) error //实例开始的回调
	Callback_startRec func(*M4SStream) error //录制开始的回调
	Callback_stopRec  func(*M4SStream)       //录制结束的回调
	Callback_stop     func(*M4SStream)       //实例结束的回调
	// contains filtered or unexported fields
}

func (*M4SStream) Common

func (t *M4SStream) Common() *c.Common

func (*M4SStream) Cut

func (t *M4SStream) Cut()

func (*M4SStream) GetSavePath

func (t *M4SStream) GetSavePath() string

func (*M4SStream) GetStreamType

func (t *M4SStream) GetStreamType() string

func (*M4SStream) LoadConfig

func (t *M4SStream) LoadConfig(common *c.Common) (e error)

func (*M4SStream) MarshalJSON

func (t *M4SStream) MarshalJSON() ([]byte, error)

func (*M4SStream) PusherToFile

func (t *M4SStream) PusherToFile(contextC context.Context, filepath string, startFunc func(*M4SStream) error, stopFunc func(*M4SStream) error) error

保存到文件

func (*M4SStream) PusherToHttp

func (t *M4SStream) PusherToHttp(conn net.Conn, w http.ResponseWriter, r *http.Request, startFunc func(*M4SStream) error, stopFunc func(*M4SStream) error) error

流服务推送方法

在客户端存在某种代理时，将有可能无法监测到客户端关闭，这有可能导致goroutine泄漏

func (*M4SStream) Start

func (t *M4SStream) Start() bool

func (*M4SStream) Stop

func (t *M4SStream) Stop()

type M4SStream_Config

type M4SStream_Config struct {
	// contains filtered or unexported fields
}

type SaveDanmuToDB

type SaveDanmuToDB struct {
	sync.Once
	// contains filtered or unexported fields
}

type Shortdanmu

type Shortdanmu struct {
	// contains filtered or unexported fields
}