cnschwarzer / douyudm

基于websocket实时获取斗鱼弹幕

douyudanmu

实时获取斗鱼弹幕

>= 1.1.1 支持所有消息输出到文件

安装(命令行)

npm i -g douyudm
or
yarn global add douyudm

使用(命令行)

通过命令行监听，默认显示，--debug开启输出到文件，默认保存当前运行目录

douyudm -i 房间号

更多命令查看 douyudm --help

安装(WEB)

建议在html顶部位置引入js文件

<script src="https://flxxyz.github.io/douyudm/dist/douyudanmaku.min.js"></script>

使用(WEB)

挂载在window下，可通过 douyudanmaku, danmaku调用

<script>
window.onload = function() {
    var room = new danmaku(roomId, {
        debug: false, //存储到indexedDB
    })
    //系统事件
    room.on('connect', function() {
        console.log('[connect] roomId=%s', this.roomId)
    })
    room.on('disconnect', function() {
        console.log('[disconnect] roomId=%s', this.roomId)
    })
    room.on('error', function(err) {
        console.log('[error] roomId=%s', this.roomId)
    })
    //消息事件
    room.on('chatmsg', function(res) {
        console.log('[chatmsg]', `<lv ${res.level}> [${res.nn}] ${res.txt}`)
    })
    room.on('loginres', function(res) {
        console.log('[loginres]', '登录成功')
    })
    room.on('uenter', function(res) {
        console.log('[uenter]', `${res.nn}进入房间`)
    })
    //开始监听
    room.run()

    //导出日志(不传入房间号默认为所有)
    room.logger.export(房间号)

    //清除日志(不传入房间号默认为所有)
    room.logger.clear(房间号)
}
</script>

安装(API)

npm i douyudm
or
yarn add douyudm

使用(API)

通过库调用自行封装

//引入类库
const douyu = require('douyudm')

//设置房间号，初始化
const roomId = 102965
const opts = {
    debug: false,
    logfile: `/自定义路径/${roomId}.log`,  //默认保存到当前运行目录，格式: 房间号.log
}
const room = new douyu(roomId, opts)

//系统事件
room.on('connect', function () {
    console.log('[connect] roomId=%s', this.roomId)
})
room.on('disconnect', function () {
    console.log('[disconnect] roomId=%s', this.roomId)
})
room.on('error', function(err) {
    console.log('[error] roomId=%s', this.roomId)
})

//消息事件
room.on('chatmsg', function(res) {
    console.log('[chatmsg]', `<lv ${res.level}> [${res.nn}] ${res.txt}`)
})
room.on('loginres', function(res) {
    console.log('[loginres]', '登录成功')
})
room.on('uenter', function(res) {
    console.log('[uenter]', `${res.nn}进入房间`)
})

//开始监听
room.run()

事件列表

系统事件	描述
connect	连接
disconnect	断开
error	错误监听

---

消息事件	描述
loginres	登入
chatmsg	弹幕消息
uenter	进入房间
upgrade	用户等级提升
rss	房间开播提醒
bc_buy_deserve	赠送酬勤通知
ssd	超级弹幕
spbc	房间内礼物广播
dgb	赠送礼物
onlinegift	领取在线鱼丸
ggbb	房间用户抢红包
rankup	房间内top10变化消息
ranklist	广播排行榜消息
mrkl	心跳
erquizisn	鱼丸预言
blab	粉丝等级升级
rri	未知的消息事件
synexp	未知的消息事件
noble_num_info	未知的消息事件
gbroadcast	未知的消息事件
qausrespond	未知的消息事件
wiru	未知的消息事件
wirt	未知的消息事件
mcspeacsite	未知的消息事件
rank_change	未知的消息事件
srres	未知的消息事件
anbc	未知的消息事件
frank	未知的消息事件

斗鱼STT序列化反序列化库

STT序列化规定如下:

1. 键key和值value直接采用`@=`分割
2. 数组采用`/`分割
3. 如果key或者value中含有字符`/`， 则使用`@S`转义
4. 如果key或者value中含有字符`@`， 则使用`@A`转义

//引入类库
const stt = require('douyudm').stt

//序列化测试数据
const obj = {
    type: 'chatmsg',
    nn: '河马（￣。。￣）',
    ic: 'avatar_v3/201912/b99d77251eb643b5a88bb81863afea4e',
    cst: '1592152272402',
    brid: '0',
    lk: '',
    list: [{
        lev: '1',
        num: '2'
    }, {
        lev: '7',
        num: '3'
    }]
}

//反序列化测试数据
const str = 'type@=chatmsg/nn@=河马（￣。。￣）/ic@=avatar_v3@S201912@Sb99d77251eb643b5a88bb81863afea4e/cst@=1592152272402/brid@=0/lk@=/list@=lev@AA=1@ASnum@AA=2@AS@Slev@AA=7@ASnum@AA=3@AS@S/'

// 1.序列化
console.log(stt.serialize(obj))
// 输出: type@=chatmsg/nn@=河马（￣。。￣）/ic@=avatar_v3@S201912@Sb99d77251eb643b5a88bb81863afea4e/cst@=1592152272402/brid@=0/lk@=/list@=lev@AA=1@ASnum@AA=2@AS@Slev@AA=7@ASnum@AA=3@AS@S/

// 2.反序列化
console.log(stt.deserialize(str))
// 输出: 
// {
//   type: 'chatmsg',
//   nn: '河马（￣。。￣）',
//   ic: 'avatar_v3/201912/b99d77251eb643b5a88bb81863afea4e',
//   cst: '1592152272402',
//   brid: '0',
//   lk: '',
//   list: [ { lev: '1', num: '2' }, { lev: '7', num: '3' } ]
// }

后话

坑太多了，github上的库大部分都是不能使用的，如果近期更新的可以判断使用的新接口，review了几乎所有相关的库，都是依据斗鱼自己官方平台的方法发起tcp连接？但根本连不上，一直拒绝...

看了下能使用的库，都是通过websocket建立的连接，立马修改，不出片刻撸完，发现发送数据的格式有点难搞，虽说示意图挺清楚的，但是用Buffer传输死活没有相应的消息，调试太磨人心性了，玛德，直接去把斗鱼网页上的方法扒下来。

通过webpack打包混淆代码乍一眼看去很混乱，其实仔细观察还是有规律寻找的。

文档中编码的几个固定参数均为数字，在webpack中数字的混淆我还没见过，按这个思路精准的找到这段代码。经过我十几分钟的理解，提取出 bufferCoder.js

斗鱼自有的序列化，反序列化方法可以查看 stt.js