M3U8下载，直播源下载，FLASH下载（三）-直播源下载_最新m3u8高清直播源文件

2018年8月31日 更新，经过了一段时间的使用，我决定把这个下载类再升级一下。升级为一个工具类。我贴在了另一篇帖子中。
M3U8下载，直播源下载，FLASH下载（四）-直播源下载-工具类

前言

　　在工作或者生活中，我们往往会在网页中碰见一些不错的视频，想下载下来存到本地，但是无奈视频是flash播放的，不能在开发者工具中找到视频的绝对地址进行下载，反而是找到了个直播源，譬如：http://video.newsapp.cnr.cn/data/video/2018/7358/index.m3u8
这样的链接是直播源地址，很多电视台的流媒体或者网络直播就是采用这样的方式，优点我就不说了，请自己baidu。

准备

JDK安装
ffmpeg安装:https://blog.csdn.net/u_ascend/article/details/80418402

代码

package cn.edu.zua.common.util.audio;

import cn.edu.zua.common.util.UtilTools;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

/**
 * AudioM3U8Downloader
 *
 * @author ascend
 * @date 2018/06/08 11:07.
 */
public class AudioM3U8Downloader {
    private static final Logger LOG = LoggerFactory.getLogger(AudioM3U8Downloader.class);

    private static final String basePath = "/tmp/";
    private static final int downloaderMaxSecond = 120;

    private AudioM3U8Downloader() {
    }

    /**
     * 测试方法
     */
    public static void main(String[] args) throws Exception {
        byte[] bytes = downloadBytes("http://recordcdn.quklive.com/upload/vod/user1462960877450854/1527512379701708/3/video.m3u8");
        System.out.println(bytes.length);
        LOG.debug("等待2s");
        TimeUnit.SECONDS.sleep(2);
        // File file = downloadFile("http://recordcdn.quklive.com/upload/vod/user1462960877450854/1524531065801767/3/video.m3u8");
        // System.out.println("file.getAbsolutePath() = " + file.getAbsolutePath());
    }

    /**
     * 把m3u8短视频下载后提取File
     * @param m3u8Url 直播源地址
     * @return 直播源文件，File
     * @throws InterruptedException 中断异常
     * @throws IOException IO异常
     */
    public static File downloadFile(String m3u8Url) throws InterruptedException, IOException {
        String fileName = UtilTools.getUUIDyyyyMMddHHmmss();
        File f = new File("/tmp/");
        if (!f.exists()) {
            f.mkdirs();
        }
        String fullFileName = "/tmp/" + fileName + ".mp4";
        String command = "ffmpeg -i " + m3u8Url + " -vcodec copy " + fullFileName + " -y";
        LOG.debug("执行命令:{}", command);
        Process process = Runtime.getRuntime().exec(command);
        ExecutorService executorService = Executors.newFixedThreadPool(3);
        getStream(executorService, process.getErrorStream(), true);
        getStream(executorService, process.getInputStream(), false);
        TimeUnit.SECONDS.sleep(10);
        File file = new File(fullFileName);
        // 最长再等待24秒
        for (int i = 0; i < 8; i++) {
            if (!file.exists()) {
                LOG.debug("文件不存在，重新创建...");
                TimeUnit.SECONDS.sleep(3);
                file = new File(fullFileName);
            }
        }
        long size = 0;
        final boolean[] checkFlag = {true};
        executorService.execute(() -> {
            try {
                TimeUnit.SECONDS.sleep(150);
                checkFlag[0] = false;
            } catch (InterruptedException e) {
                LOG.error("最长等待线程被中断，正常错误", e);
            }
        });
        int maxCount = 10;
        while (checkFlag[0]) {
            TimeUnit.SECONDS.sleep(5);
            long fileLength = file.length();
            LOG.debug("上一次监测的大小:{}, 本次监测的大小:{}", size, fileLength);
            if (file.length() != size) {
                size = file.length();
                TimeUnit.SECONDS.sleep(5);
            } else {
                if (fileLength == 0 && maxCount-- > 0) {
                    continue;
                } else {
                    LOG.debug("退出循环...");
                    checkFlag[0] = false;
                }
            }
        }
        process.destroy();
        executorService.shutdownNow();
        LOG.info("文件下载成功：{}", file.getAbsolutePath());
        return file;
    }

    /**
     * 把m3u8短视频下载后提取byte数组，并且删除临时文件
     * @param m3u8Url 直播源地址
     * @return byte[],从文件中提取的字节数组
     * @throws InterruptedException 中断异常
     * @throws IOException IO异常
     */
    public static byte[] downloadBytes(String m3u8Url) throws InterruptedException, IOException {
        File file = downloadFile(m3u8Url);
        LOG.debug("字节数组方法下载调用成功：{}, 文件大小：{}", file.getAbsolutePath(), file.length());
        LOG.debug("睡眠2秒钟，把文件转换为字节数组");
        TimeUnit.SECONDS.sleep(2);
        FileInputStream input = FileUtils.openInputStream(file);
        byte[] bytes = IOUtils.toByteArray(input);
        input.close();
        LOG.info("返回文件数组！！文件长度：{}", bytes.length);
        // 删除下载后的文件
        if (file.exists()) {
            LOG.debug("文件存在,删除文件！");
            if (Files.deleteIfExists(Paths.get(file.toURI()))) {
                LOG.debug("删除成功");
            }else {
                LOG.debug("删除失败");
            }
        }
        return bytes;
    }


    private static void getStream(ExecutorService executorService, final InputStream inputStream, final boolean printFlag) {
        executorService.execute(() -> {
            BufferedInputStream in = new BufferedInputStream(inputStream);
            byte[] bytes = new byte[1024];
            try {
                while (in.read(bytes) != -1) {
                    String s = new String(bytes, 0, bytes.length);
                    if (printFlag) {
//                            LOG.error("ffmpeg:error when downloading!\ninfo:"+s);
                    }
//                        LOG.debug("read from inputstream:{}", s);
                }
            } catch (IOException e) {
                LOG.error("读取下载流失败", e);
            } finally {
                try {
                    in.close();
                } catch (IOException e) {
                    LOG.error("关闭读取流失败：", e);
                }
            }
        });
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159

看这里，看这里
文章总目录：博客导航