java快手直播弹幕获取websocket

SkinApe
2022-06-06 08:53:29
JAVA交流
JAVA交流 JAVA教程 java源码

由于本博主在搞云直播游戏，所以一直在研究java直播弹幕获取

弹幕协议用的是websocket

流程就是:1.连接websocket 2.发送直播间数据和token 3.就能获取到弹幕的推送

以下就是关键代码，懂得自然懂！只要稍微研究一下弹幕就能看懂我写的啥
源码

@Override
    public void onOpen(ServerHandshake arg0) {
        // TODO Auto-generated method stub
        LOGGER.info("------ MyWebSocket onOpen ------");
 
        //==开头
        //byte[] part1=hexToBytes("08c8011ac8010a9801");
        //=开头
        byte[] part1 = hexToBytes("08c8011adc010aac01");
        if (token.lastIndexOf("==") > 0) {
            part1 = hexToBytes("08c8011ac8010a9801");
        }
        //token
        byte[] part2 = token.getBytes();
        //固定
        byte[] part3 = hexToBytes("120b");
        //stream_id
        byte[] part4 = streamId.getBytes();
        //固定
        byte[] part5 = hexToBytes("3a1e");
        //page_id
        byte[] part6 = getPageId().getBytes();
        List<byte[]> datas = new LinkedList<>(Arrays.asList(part1, part2, part3, part4, part5, part6));
        byte[] resultBytes = new byte[0];
        //记录需要复制到目标数组的起始索引
        int index = 0;
        for (byte[] bytes : datas) {
            //复制数组到新数组，并且长度为当前数组长度+bytes的长度
            resultBytes = Arrays.copyOf(resultBytes, resultBytes.length + bytes.length);
            //将bytes中的内容拼接在结果数组之后
            System.arraycopy(bytes, 0, resultBytes, index, bytes.length);
            //索引值递增
            index += bytes.length;
        }
        send(resultBytes);
 
        TimerTask task = new TimerTask() {
            public void run() {
                //20秒心跳包
//                String data = byte2Hex(HttpClientUtils.executeByPOST("https://live.kuaishou.com/rest/wd/live/watchingFeed","{\"liveStreamId\":\""+streamId+"\"}").getBytes());
//                System.out.println(data);
                byte[] heartBeat = hexToBytes("08011a070889aac0da8130");
                LOGGER.info("******心跳******");
                send(heartBeat);
            }
        };
        Timer timer = new Timer();
        long delay = 0;
        long intevalPeriod = 20 * 1000;
        timer.scheduleAtFixedRate(task, delay, intevalPeriod);
    }