bilibili-lottery-listener - GitLite

KO | EN

gitlite — search

#mysql #monitoring #computer-vision #framework #macos #go #php #git #markdown #awesome-list

bilibili-lottery-listener

(★ 21)

Bilibili 直播抽奖监听服务器

bilibili-lottery-listener Latest Version Download

# Use via CDN

jsDelivr

jsDelivr serves any public GitHub repository as a CDN with zero setup. Pick a version and a file to get a ready-to-paste link and snippet.

Version

File path

Link

Example

Command Glossary

Commands referenced in this DOCs, explained below.

🔍

`java`

View Details ▼

Java application launcher.

java {{classname}}

Execute a Java `.class` file that contains a main method by using just the class name:

java -classpath {{path/to/classes1}}:{{path/to/classes2}}:. {{classname}}

Execute a Java program and use additional third-party or user-defined classes:

java -jar {{filename.jar}}

Execute a `.jar` program:

🔍

`apt install`

View Details ▼

Install packages for Debian-based distributions.

sudo apt install {{package}}

Install a package, or update it to the latest version:

sudo apt install {{[-V|--verbose-versions]}} {{package}}

Display verbose package version information during installation or update:

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

Bilibili 抽奖监听服务器. 当 B站(直播) 有抽奖发生时, 将把这个消息推送到订阅者.

# 运行
安装 jre

apt install openjdk-8-jre

在本仓库的 [releases](../../releases) 页面下载 jar 后, 执行以下命令行

java -jar server-{version}.jar

(version 是版本号)

# 构建
安装 jdk

apt install openjdk-8-jdk
    
clone 本仓库后

cd bilibili-lottery-listener
    ./gradlew bootJar

# 可配置项
配置文件需要放置在程序工作目录, 配置文件可以是 properties 也可以是 yaml.

配置文件需要命名为 application, 例如 application.properties 或 application.yaml.

配置写在配置文件中, 例如以下配置(也可以是 yaml, yaml 写法请脑补转换)

bilibili.listener.page-count=30

以下是默认值和注释(配置文件中使用短横线命名法, 例如 pageCount 转换为 page-count)

@ConfigurationProperties(prefix = "bilibili.listener")
    data class LotteryListenerConfigurationProperties(
            /**
             * 重新连接官方音悦台的重试次数限制
             */
            var reconnectTryLimit: Int = 5,
            /**
             * 连接前多少页的最热房间(一页有 30 个房间)
             */
            var pageCount: Int = 30,
            /**
             * 多少个房间使用一个线程
             */
            var roomsPerThread: Int = 50,
            /**
             * 每秒最大请求数, 用于防止 B站 禁封 IP
             */
            var requestRateLimit: Double = 20.0,
            /**
             * 断开连接并重新连接新的最热房间(复数)的间隔, 分
             */
            var refreshInterval: Long = 30L
    )

# 抽奖消息
## 全站通告的抽奖信息
全站通告的抽奖信息有 小电视(摩天大楼的数据包与小电视是一样的), 20 倍以上的节奏风暴, 活动礼物

## 非全站通告的抽奖信息
比如 20 倍以下的节奏风暴不会在全站通告, 而只在发生这个事件的直播间内会有消息(在弹幕推送 socket 中).

对于这种事件, 本程序的策略是连接最热门的前 N 个直播间并监听他们的消息, 从而尽可能多的获得这种抽奖消息并推送给订阅者.

## 购买舰长之后的抽奖活动
有人在某个房间购买舰长后, 将触发一次抽奖.

# 事件
以上几种事件的定义如下

enum class EventType {
        /**
         * DanMuMsg 用于测试时调试程序逻辑, 生产环境不存在此事件
         */
        DANMU_MSG_EVENT,
        /**
         * 小电视(摩天大楼也是这个)
         */
        SMALL_TV_EVENT,
        /**
         * 超过 20 倍的节奏风暴
         */
        GLOBAL_SPECIAL_GIFT_EVENT,
        /**
         * 活动礼物
         */
        ACTIVITY_GIFT_EVENT,
        /**
         * 节奏风暴开始(房间内通告的低于 20 倍的节奏风暴, 下同)
         */
        SPECIAL_GIFT_START_EVENT,
        /**
         * 节奏风暴结束
         */
        SPECIAL_GIFT_END_EVENT,
        /**
        * 购买舰长之后的抽奖活动
        */
        GUARD_LOTTERY_START
    }

# 订阅
客户端通过 WebSocket 连接到本程序, 并从 WebSocket 中得到推送.

应用层协议使用 STOMP, 以 JavaScript 为例(npm install stompjs):

const Stomp = require('stompjs');
    
    const client = Stomp.overWS('ws://localhost:8080/notifications');
    client.connect({}, frame => {
        console.log('Connected: ' + frame);
        client.subscribe('/DANMU_MSG_EVENT', message => {
            console.log('Received message: \n' + message.body)
        });
    });

WebSocket 的 Endpoint 为 "/notifications", Destination 为事件类型.

返回的 Message.body 为 JSON 字符串.

{
        "roomId": 3,
        "realRoomId": 23058,
        "eventType": "DANMU_MSG_EVENT",
        "payload": {"cmd":"DANMU_MSG","info":[[0,1,25,16777215,1525934492,"1525934492",0,"8a0f75dc",0],"悄悄地奉献。",[39042255,"夏沫丶琉璃浅梦",0,1,0,10000,1,""],[15,"夏沫","乄夏沫丶","1547306",16746162,""],[44,0,16746162,5811],["task-year","title-29-1"],0,0,{"uname_color":""}]}
    }

(注意 DanMuMsg 事件在生产环境中是不触发的)

(payload 为原始数据)

为了方便强类型语言接收该消息, 以下提供该模型的定义

data class PushModel<T : DataEntity>(
            val roomId: Long,
            val realRoomId: Long,
            val eventType: EventType,
            val payload: T
    )

(payload 可以当字符串来反序列化)

# 测试
测试代码(不同语言的 stomp 使用范例)在 /test 文件夹中.

# 开源协议
GPL V3