[JAVA版本] Websocket获取B站直播弹幕——基于直播开放平台

教程

B站直播间弹幕Websocket获取 — 哔哩哔哩直播开放平台
基于B站直播开放平台开放且未上架时，只能个人使用。

代码实现

1、相关依赖

fastjson2用于解析JSON字符串，可自行替换成别的框架。
hutool-core用于解压zip数据，可自行替换成别的框架。

<dependency><groupId>com.alibaba.fastjson2</groupId><artifactId>fastjson2</artifactId><version>2.0.40</version>
</dependency>
<!-- https://mvnrepository.com/artifact/cn.hutool/hutool-core -->
<dependency><groupId>cn.hutool</groupId><artifactId>hutool-core</artifactId><version>5.8.21</version>
</dependency>

1、新建ProjectRequest.java

用于发送项目start、end、heartbeat请求。
注意：
没有上架的项目，start返回结果没有场次ID，导致end、heartbeat请求不能正常执行。
但是没有关系，start能获得弹幕服务信息就行。

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import jakarta.annotation.Nonnull;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.security.InvalidKeyException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import java.util.stream.Collectors;public class ProjectRequest {/*** 项目ID*/private long appId;/*** 身份验证Key*/private String accessKey;/*** 身份验证密钥*/private String accessSecret;public ProjectRequest(long appId, String accessKey, String accessSecret) {this.appId = appId;this.accessKey = accessKey;this.accessSecret = accessSecret;}public final static String START_URL = "https://live-open.biliapi.com/v2/app/start";public final static String END_URL = "https://live-open.biliapi.com/v2/app/end";public final static String HEART_BEAT_URL = "https://live-open.biliapi.com/v2/app/heartbeat";public final static String BATCH_HEART_BEAT_URL = "https://live-open.biliapi.com/v2/app/batchHeartbeat";/*** 接口描述：开启项目第一步，平台会根据入参进行鉴权校验。鉴权通过后，返回长连信息、场次信息和主播信息。开发者拿到长连和心跳信息后，需要参照[长连说明]和[项目心跳]，与平台保持健康的* @param code 必填	string	[主播身份码]* param appId 必填	integer(13位长度的数值，注意不要用普通int，会溢出的)	项目ID*/public String start(String code) throws IOException, NoSuchAlgorithmException, InvalidKeyException {Map<String,Object> params = new HashMap<>();params.put("code", code);params.put("app_id", appId);return post(START_URL, params);}/*** 接口描述：项目关闭时需要主动调用此接口，使用对应项目Id及项目开启时返回的game_id作为唯一标识，调用后会同步下线互动道具等内容，项目关闭后才能进行下一场次互动。* param appId 必填	integer(13位长度的数值，注意不要用普通int，会溢出的)	项目ID* param gameId 必填	场次id*/public String end(String gameId) throws IOException, NoSuchAlgorithmException, InvalidKeyException {Map<String,Object> params = new HashMap<>();params.put("game_id", gameId);params.put("app_id", appId);return post(END_URL, params);}/*** 接口描述：项目开启后，需要持续间隔20秒调用一次该接口。平台超过60s未收到项目心跳，会自动关闭当前场次（game_id），同时将道具相关功能下线，以确保下一场次项目正常运行。* 接口地址：/v2/app/heartbeat* 方法：POST* param gameId 必填	场次id*/public String heartbeat(String gameId) throws IOException, NoSuchAlgorithmException, InvalidKeyException {Map<String,Object> params = new HashMap<>();params.put("game_id", gameId);return post(HEART_BEAT_URL, params);}/*** 项目批量心跳* 接口地址：/v2/app/batchHeartbeat* 方法：POST* @param gameIds    必填	[]string	场次id* */public String batchHeartbeat(@Nonnull List<String> gameIds) throws IOException, NoSuchAlgorithmException, InvalidKeyException {Map<String,Object> params = new HashMap<>();params.put("game_ids", JSONArray.toJSONString(gameIds));return post(HEART_BEAT_URL, params);}/*** 自定义post请求* @param url* @param dataMap* @throws IOException* @throws NoSuchAlgorithmException* @throws InvalidKeyException*/private String post(String url, Map<String,Object> dataMap) throws IOException, NoSuchAlgorithmException, InvalidKeyException {String bodyStr = JSONObject.toJSONString(dataMap);HttpURLConnection con = (HttpURLConnection) new URL(url).openConnection();con.setRequestMethod("POST");// 设置请求头setHeader(con, bodyStr);// 发送 POST 请求con.setDoOutput(true);try(DataOutputStream wr = new DataOutputStream(con.getOutputStream())) {wr.writeBytes(bodyStr);wr.flush();}// 获取响应结果try(BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(con.getInputStream(), StandardCharsets.UTF_8))){// 返回响应结果return  bufferedReader.lines().collect(Collectors.joining("\n"));}}public static String KEY_CONTENT_MD5 = "x-bili-content-md5";public static String KEY_TIMESTAMP = "x-bili-timestamp";public static String KEY_SIGNATURE_NONCE = "x-bili-signature-nonce";/*** 设置请求头* @param con* @param bodyStr 请求体* @throws NoSuchAlgorithmException* @throws InvalidKeyException*/private void setHeader(HttpURLConnection con,String bodyStr) throws NoSuchAlgorithmException, InvalidKeyException {con.setRequestProperty("User-Agent", "Mozilla/5.0");/**----------------------------------------------------------------------------**///必填：接受的返回结果的类型。目前只支持JSON类型，取值：application/json。con.setRequestProperty("Accept", "application/json");//必填：当前请求体（Request Body）的数据类型。目前只支持JSON类型，取值：application/json。con.setRequestProperty("Content-Type", "application/json");//必填：请求体的编码值，根据请求体计算所得。算法说明：将请求体内容当作字符串进行MD5编码。con.setRequestProperty(KEY_CONTENT_MD5, getContentMd5(bodyStr));//必填：unix时间戳，单位是秒。请求时间戳不能超过当前时间10分钟，否则请求会被丢弃。con.setRequestProperty(KEY_TIMESTAMP, String.valueOf(System.currentTimeMillis()/1000));//必填： 版本1.0con.setRequestProperty("x-bili-signature-version", "1.0");//必填：签名唯一随机数。用于防止网络重放攻击，建议您每一次请求都使用不同的随机数con.setRequestProperty(KEY_SIGNATURE_NONCE, UUID.randomUUID().toString());//必填：加密算法con.setRequestProperty("x-bili-signature-method", "HMAC-SHA256");//必填： accesskey idcon.setRequestProperty("x-bili-accesskeyid", accessKey);//必填：请求签名（注意生成的签名是小写的）。关于请求签名的计算方法，请参见签名机制con.setRequestProperty("Authorization", generateSignature(con));}/*** MD5计算*/private String getContentMd5(String content) throws NoSuchAlgorithmException {MessageDigest md5 = MessageDigest.getInstance("MD5");return byte2Hex( md5.digest(content.getBytes(StandardCharsets.UTF_8)) );}/*** 签名 HmacSHA256计算*/public String generateSignature(HttpURLConnection con) throws NoSuchAlgorithmException, InvalidKeyException {StringBuilder s = new StringBuilder();s.append("x-bili-accesskeyid:").append(accessKey).append("\n");s.append("x-bili-content-md5:").append(con.getRequestProperty(KEY_CONTENT_MD5)).append("\n");s.append("x-bili-signature-method:").append("HMAC-SHA256").append("\n");s.append("x-bili-signature-nonce:").append(con.getRequestProperty(KEY_SIGNATURE_NONCE)).append("\n");s.append("x-bili-signature-version:").append("1.0").append("\n");s.append("x-bili-timestamp:").append(con.getRequestProperty(KEY_TIMESTAMP));byte[] headerByte = s.toString().getBytes(StandardCharsets.UTF_8);byte[] secretByte = accessSecret.getBytes(StandardCharsets.UTF_8);Mac mac = Mac.getInstance("HmacSHA256");mac.init(new SecretKeySpec(secretByte, "HmacSHA256"));byte[] bytes = mac.doFinal(headerByte);return byte2Hex(bytes);}/*** 字节数组转16进制字符串* @param bytes* @return*/private static String byte2Hex(byte[] bytes){StringBuffer stringBuffer = new StringBuffer();String temp = null;for (int i=0;i<bytes.length;i++){temp = Integer.toHexString(bytes[i] & 0xFF);if (temp.length()==1){//1得到一位的进行补0操作stringBuffer.append("0");}stringBuffer.append(temp);}return stringBuffer.toString();}
}

3、新建 WebsocketListener.java

用于监听接收到的数据。

import jakarta.websocket.*;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import cn.hutool.core.util.ZipUtil;@ClientEndpoint
public class WebsocketListener {private Session session;private String authBody;public WebsocketListener(String authBody) {this.authBody = authBody;}@OnOpenpublic void onOpen(Session session) throws IOException {System.out.println("已连接服务...");this.session = session;RemoteEndpoint.Async remote = session.getAsyncRemote();//鉴权协议包ByteBuffer authPack = ByteBuffer.wrap(generateAuthPack(authBody));remote.sendBinary(authPack);//每30秒发送心跳包ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();executorService.scheduleAtFixedRate(() -> {try {ByteBuffer heartBeatPack = ByteBuffer.wrap(generateHeartBeatPack());remote.sendBinary(heartBeatPack);} catch (IOException e) {throw new RuntimeException(e);}}, 0, 30, TimeUnit.SECONDS);}@OnMessagepublic void onMessage(ByteBuffer byteBuffer) {//解包unpack(byteBuffer);}@OnClosepublic void onClose(Session session, CloseReason closeReason) {System.out.println("关闭Websocket服务: " + closeReason);}@OnErrorpublic void onError(Session session, Throwable t) {System.out.println("Websocket服务异常: " + t.getMessage());}public interface Opt{short HEARTBEAT = 2;//	客户端发送的心跳包(30秒发送一次)short HEARTBEAT_REPLY = 3;//	服务器收到心跳包的回复 人气值，数据不是JSON，是4字节整数short SEND_SMS_REPLY = 5;//	服务器推送的弹幕消息包short AUTH = 7;//客户端发送的鉴权包(客户端发送的第一个包)short AUTH_REPLY = 8;//服务器收到鉴权包后的回复}public interface Version{short NORMAL = 0;//Body实际发送的数据——普通JSON数据short ZIP = 2; //Body中是经过压缩后的数据，请使用zlib解压，然后按照Proto协议去解析。}/*** 封包* @param jsonStr 数据* @param code 协议包类型* @return* @throws IOException*/public static byte[] pack(String jsonStr, short code) throws IOException {byte[] contentBytes = new byte[0];if(Opt.AUTH == code){contentBytes = jsonStr.getBytes();}try(ByteArrayOutputStream data = new ByteArrayOutputStream();DataOutputStream stream = new DataOutputStream(data)){stream.writeInt(contentBytes.length + 16);//封包总大小stream.writeShort(16);//头部长度 header的长度，固定为16stream.writeShort(Version.NORMAL);stream.writeInt(code);//操作码（封包类型）stream.writeInt(1);//保留字段，可以忽略。if(Opt.AUTH == code){stream.writeBytes(jsonStr);}return data.toByteArray();}}/*** 生成认证包* @return*/public static byte[] generateAuthPack(String jsonStr) throws IOException {return pack(jsonStr, Opt.AUTH);}/*** 生成心跳包* @return*/public static byte[] generateHeartBeatPack() throws IOException {return pack(null, Opt.HEARTBEAT);}/*** 解包* @param byteBuffer* @return*/public static void unpack(ByteBuffer byteBuffer){int packageLen = byteBuffer.getInt();short headLength = byteBuffer.getShort();short protVer = byteBuffer.getShort();int optCode = byteBuffer.getInt();int sequence = byteBuffer.getInt();if(Opt.HEARTBEAT_REPLY == optCode){System.out.println("这是服务器心跳回复");}byte[] contentBytes = new byte[packageLen - headLength];byteBuffer.get(contentBytes);//如果是zip包就进行解包if(Version.ZIP == protVer){unpack(ByteBuffer.wrap(ZipUtil.unZlib(contentBytes)));return;}String content = new String(contentBytes, StandardCharsets.UTF_8);if(Opt.AUTH_REPLY == optCode){//返回{"code":0}表示成功System.out.println("这是鉴权回复："+content);}//真正的弹幕消息if(Opt.SEND_SMS_REPLY == optCode){System.out.println("真正的弹幕消息："+content);// todo 自定义处理}//只存在ZIP包解压时才有的情况//如果byteBuffer游标 小于 byteBuffer大小，那就证明还有数据if(byteBuffer.position() < byteBuffer.limit()){unpack(byteBuffer);}}
}

4、使用

public static void main(String[] args) throws IOException, NoSuchAlgorithmException, InvalidKeyException, URISyntaxException, DeploymentException {ProjectRequest p = new ProjectRequest(你的应用ID, 你的Access_key, 你的 Access_Secret);//获取弹幕服务信息String result = p.start(你的身份码);JSONObject data = JSONObject.parseObject(result).getJSONObject("data");//个人信息JSONObject anchorInfo = data.getJSONObject("anchor_info");//弹幕服务器信息JSONObject websocketInfo = data.getJSONObject("websocket_info");//弹幕服务器地址JSONArray wssLinks = websocketInfo.getJSONArray("wss_link");//websocket鉴权信息String authBody = websocketInfo.getString("auth_body");//选一个服务器节点String uri = wssLinks.getString(0);WebSocketContainer container = ContainerProvider.getWebSocketContainer();// 连接到WebSocket服务器container.connectToServer(new WebsocketListener(authBody), new URI(uri)); 
}
参数获取
Access_key 和 Access_Secret去B站直播开放平台注册申请个人开发者后就能获得
应用ID成为个人开发者后，在直播开放平台创建应用后，就能获得应用ID
身份码登录B站直播间找到幻星-互动玩法，在里面就能找到身份码

其他版本

【flutter / dart 版本】Websocket获取B站直播间弹幕教程——基于B站直播开发平台

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/101858.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

手写Spring系列【一】IOC的简单实现笔记

手写Spring系列【一】IOC的简单实现笔记

前言&#xff1a; &#x1f44f;作者简介&#xff1a;我是笑霸final&#xff0c;一名热爱技术的在校学生。 &#x1f4dd;个人主页&#xff1a;个人主页1 || 笑霸final的主页2 &#x1f4d5;系列专栏&#xff1a;项目专栏 &#x1f4e7;如果文章知识点有错误的地方&#xff0c;…
阅读更多...
大日志（大文件）查看工具

大日志（大文件）查看工具

一款很不错的日志查看工具&#xff0c; 优势是能查看很大的日志文档。 无需安装&#xff0c;解压后运行即可&#xff1b; 有注册版&#xff0c;不注册也可以使用。 官方地址&#xff1a; LogViewer - Home page 一个下载地址&#xff1a; 日志查看工具UVviewsoft LogViewer(超大…
阅读更多...
makefile编译举例

makefile编译举例

makefile编译举例 # 定义编译器和编译选项 CC gcc CFLAGS -Wall -Werror # 定义目标文件名 TARGET myprogram # 定义需要编译的源文件目录和文件名 SRC_DIR1 src1 SRC_DIR2 src2 OBJ_DIR1 obj1 OBJ_DIR2 obj2 SRC_FILES1 file1.c file2.c SRC_FILES2…
阅读更多...
电脑如何查看是否支持虚拟化及如何开启虚拟化

电脑如何查看是否支持虚拟化及如何开启虚拟化

什么是虚拟化? Intel Virtualization Technology就是以前众所周知的“Vanderpool”技术&#xff08;简称VT&#xff0c;中文译为虚拟化技术&#xff09;&#xff0c;这种技术可以让一个CPU工作起来就像多个CPU并行运行&#xff0c;从而使得在一部电脑内同时运行多个操作系统成…
阅读更多...
MyBatis的xml里#{}的参数为null报错、将null作为参数传递报错问题

MyBatis的xml里#{}的参数为null报错、将null作为参数传递报错问题

今天在调试的过程中发现一个bug&#xff0c;把传入的参数写到查询分析器中执行没有问题&#xff0c;但是在程序中执行就报错&#xff1a;org.springframework.jdbc.UncategorizedSQLException : Error setting null parameter. Most JDBC drivers require that the JdbcType m…
阅读更多...
开山之作 | YOLOv1算法超详细解析（包括诞生背景+论文解析+技术原理等）

开山之作 | YOLOv1算法超详细解析（包括诞生背景+论文解析+技术原理等）

前言&#xff1a;Hello大家好&#xff0c;我是小哥谈。目标检测是计算机视觉领域的一项重要研究方向&#xff0c;它在许多应用领域中都得到了广泛应用&#xff0c;如人脸识别、物体识别、自动驾驶、视频监控等。在过去&#xff0c;目标检测方法主要采用基于RCNN、Fast R-CNN等深…
阅读更多...
Python+Tkinter 图形化界面基础篇：集成数据库

Python+Tkinter 图形化界面基础篇：集成数据库

PythonTkinter 图形化界面基础篇&#xff1a;集成数据库 引言为什么选择 SQLite 数据库&#xff1f;集成 SQLite 数据库的步骤示例&#xff1a;创建一个任务管理应用程序步骤1&#xff1a;导入必要的模块步骤2&#xff1a;创建主窗口和数据库连接步骤3&#xff1a;创建数据库表…
阅读更多...
高级深入--day30

高级深入--day30

Scrapy Shell Scrapy终端是一个交互终端，我们可以在未启动spider的情况下尝试及调试代码，也可以用来测试XPath或CSS表达式，查看他们的工作方式，方便我们爬取的网页中提取的数据。 如果安装了 IPython ，Scrapy终端将使用 IPython (替代标准Python终端)。 IPython 终端与其…
阅读更多...
零基础学python之数据类型

零基础学python之数据类型

文章目录 1、数据类型1.1 编程规范注释标识符命名规则命名规则python命名规则关于代码规范编程习惯的重要性 输入输出与变量输出输入变量 1.2 数值类型int(整型)浮点型&#xff08;float&#xff09;类型转化 1.3 字符串字符串创建字符串格式化**format**%s**f** 案例&#xff…
阅读更多...
从零开始：深入理解Kubernetes架构及安装过程

从零开始：深入理解Kubernetes架构及安装过程

K8s环境搭建 文章目录 K8s环境搭建集群类型安装方式环境规划克隆三台虚拟机系统环境配置集群搭建初始化集群&#xff08;仅在master节点&#xff09;配置环境变量&#xff08;仅在master节点&#xff09;工作节点加入集群&#xff08;knode1节点及knode2节点&#xff09;安装ca…
阅读更多...
1806_emacs_org-mode归档的时候修改归档文件名称

1806_emacs_org-mode归档的时候修改归档文件名称

全部学习汇总&#xff1a;GreyZhang/g_org: my learning trip for org-mode (github.com) 前面已经基本了解了org-mode的归档的规则或者方法&#xff0c;但是还有一点跟我现在的工作流有点不相符。我自己的工作流中会每月做一次工作的整理总结&#xff0c;因此归档的文件是按照…
阅读更多...
KubeVela可持续测试应用部署之Mock基础设施

KubeVela可持续测试应用部署之Mock基础设施

Mock接口是我们常用的功能测试方案，有时候依赖的接口未开发完成或者依赖的第三方接口不提供测试环境等，只有Mock才能跑通流程。 我们基于KubeVela开发的云原生应用交付平台，提供如初始化基础设施导入、中间件部署共用基础设施等相关能力的测试，需要依赖基础设施。虽然terr…
阅读更多...
C++ PCL点云局部颜色变换

C++ PCL点云局部颜色变换

程序示例精选 C PCL点云局部颜色变换 如需安装运行环境或远程调试&#xff0c;见文章底部个人QQ名片&#xff0c;由专业技术人员远程协助&#xff01; 前言 这篇博客针对《C PCL点云局部颜色变换》编写代码&#xff0c;代码整洁&#xff0c;规则&#xff0c;易读。 学习与应用…
阅读更多...
基于SpringBoot的大学城水电管理系统

基于SpringBoot的大学城水电管理系统

目录 前言 一、技术栈 二、系统功能介绍 管理员模块的实现 领用设备管理 消耗设备管理 设备申请管理 状态汇报管理 用户模块的实现 设备申请 状态汇报 用户反馈 三、核心代码 1、登录模块 2、文件上传模块 3、代码封装 前言 随着信息技术在管理上越来越深入而广泛…
阅读更多...
Mysql 日常命令记录

Mysql 日常命令记录

索引操作 加联合组件&#xff1a; ALTER TABLE dws_stock_age_material_transactions_total_pri_rpt_update ADD INDEX index_sio (organization_id(16),item_code,subinventory_code); 查看索引&#xff1a; SHOW INDEX FROM dws_stock_age_material_transactions_detail_…
阅读更多...
ETX 高性能远程桌面访问方案在医疗保健保健行业的应用案例

ETX 高性能远程桌面访问方案在医疗保健保健行业的应用案例

飞利浦医疗存在的挑战 1、对集成解决方案的多个系统进行远程访问连接&#xff1b; 2、医疗保健专业人员需要高质量的图形应用程序显示&#xff1b; 3、安全的远程访问&#xff0c;能够保护敏感数据和关键患者数据。 取得的成果 1、连接多个系统&#xff0c;以增强肿瘤治疗的交…
阅读更多...
【SMOKE-CMAQ实践技术】10天，从小白-精通一站式技能提升

【SMOKE-CMAQ实践技术】10天，从小白-精通一站式技能提升

大气污染物排放是空气污染的源头&#xff0c;气象因素是影响污染程度的重要因素&#xff0c;因此空气质量模式要求气象资料和污染物排放清单作为输入&#xff0c;其中由于大气污染源复杂性、数据滞后性、动态变化、规律性不明显等特点&#xff0c;使得大气污染源排放清单输入准…
阅读更多...
深度学习简述

深度学习简述

⭐️⭐️⭐️⭐️⭐️欢迎来到我的博客⭐️⭐️⭐️⭐️⭐️ &#x1f434;作者&#xff1a;秋无之地 &#x1f434;简介&#xff1a;CSDN爬虫、后端、大数据领域创作者。目前从事python爬虫、后端和大数据等相关工作&#xff0c;主要擅长领域有&#xff1a;爬虫、后端、大数据…
阅读更多...
点击劫持：X-Frame-Options 未配置

点击劫持：X-Frame-Options 未配置

前言 X-Frame-Options作为HTTP头的一部分&#xff0c;是一种用于保护网站免受点击劫持攻击的安全措施。网站可以通过设置X-Frame-Options或csp报头来控制网站本身是否可以被嵌套到iframe中。 漏洞描述 Clickjacking&#xff08;点击劫持&#xff09;是一种安全漏洞&#xff…
阅读更多...
Android 项目增加 res配置

Android 项目增加 res配置

main.res.srcDirs "src/main/res_test" build->android->sourceSets
阅读更多...
最新文章

Copyright @ 2022~2023