更新虎牙直播

173.py

@@ -0,0 +1,22 @@
+# 艺气山直播：http://www.173.com/room/category?categoryId=11
+import requests
+
+
+def _173(rid):
+    params = 'roomId={}&format=m3u8'.format(rid)
+    with requests.Session() as s:
+        res = s.post('http://www.173.com/room/getVieoUrl', params=params).json()
+    data = res['data']
+    if data:
+        status = data['status']
+        if status == 2:
+            return data['url']
+        else:
+            raise Exception('未开播')
+    else:
+        raise Exception('直播间不存在')
+
+
+if __name__ == '__main__':
+    r = input('输入艺气山直播房间号：\n')
+    print(_173(r))

README.md

@@ -4,9 +4,11 @@
 
 这个仓库存放的是：获取一些直播平台真实流媒体地址（直播源）和弹幕的 Python 代码实现。获取的地址经测试，均可在 PotPlayer、VLC、DPlayer(flv.js + hls.js)等播放器中播放。
 
+>  🤘👌🤙🙏🐉👉 ：如果该项目能帮助到您，欢迎 star 和 pr；或在您的项目中标注 Real-Url 为参考来源。
+
 目前已实现：
 
- **46** 个直播平台的直播源获取：斗鱼直播、虎牙直播、哔哩哔哩直播、战旗直播、网易 CC 直播、火猫直播、企鹅电竞、YY 直播、一直播、快手直播、花椒直播、映客直播、西瓜直播、触手直播、NOW 直播、抖音直播，爱奇艺直播、酷狗直播、龙珠直播、PPS 奇秀直播、六间房、17 直播、来疯直播、优酷轮播台、网易 LOOK 直播、千帆直播、陌陌直播、小米直播、迅雷直播、京东直播、企鹅体育、人人直播、棉花糖直播、九秀直播、羚萌直播、95秀、新浪疯播、红人直播、艾米直播、KK直播、酷我聚星、乐嗨直播、秀色直播、星光直播、我秀直播、热猫直播
+ **48** 个直播平台的直播源获取：斗鱼直播、虎牙直播、哔哩哔哩直播、战旗直播、网易 CC 直播、火猫直播、企鹅电竞、YY 直播、一直播、快手直播、花椒直播、映客直播、西瓜直播、触手直播、NOW 直播、抖音直播，爱奇艺直播、酷狗直播、龙珠直播、PPS 奇秀直播、六间房、17 直播、来疯直播、优酷轮播台、网易 LOOK 直播、千帆直播、陌陌直播、小米直播、迅雷直播、京东直播、企鹅体育、人人直播、棉花糖直播、九秀直播、羚萌直播、95秀、新浪疯播、红人直播、艾米直播、KK直播、酷我聚星、乐嗨直播、秀色直播、星光直播、我秀直播、热猫直播、艺气山直播、AcFun 直播。
 
  **16** 个直播平台的弹幕获取：斗鱼直播、虎牙直播、哔哩哔哩直播、快手直播、火猫直播、企鹅电竞、花椒直播、映客直播、网易 CC 直播、酷狗直播、龙珠直播、PPS 奇秀、搜狐千帆、战旗直播、来疯直播、网易 LOOK 直播。
 
@@ -23,7 +25,9 @@
 
 ## 更新
 
-### 2020.07.31：新增 19 个直播平台，详见上面说明；更新YY直播，现在可以获取最高画质；优化战旗直播、优酷直播代码；
+### 2020.08.08：新增：AcFun 直播、艺气山直播；更新：哔哩哔哩直播、虎牙直播；红人直播；优化：斗鱼直播。
+
+2020.07.31：新增 19 个直播平台，详见上面说明；更新YY直播，现在可以获取最高画质；优化战旗直播、优酷直播代码；
 
 2020.07.25：新增网易 LOOK 直播弹幕获取；修复斗鱼直播源；新增陌陌直播源。
 

acfun.py

@@ -0,0 +1,45 @@
+# AcFun直播：https://live.acfun.cn/
+# 默认最高画质
+import requests
+import json
+
+
+def acfun(rid):
+    headers = {
+        'content-type': 'application/x-www-form-urlencoded',
+        'cookie': '_did=H5_',
+        'referer': 'https://m.acfun.cn/'
+    }
+    url = 'https://id.app.acfun.cn/rest/app/visitor/login'
+    data = 'sid=acfun.api.visitor'
+    with requests.Session() as s:
+        res = s.post(url, data=data, headers=headers).json()
+    userid = res['userId']
+    visitor_st = res['acfun.api.visitor_st']
+
+    url = 'https://api.kuaishouzt.com/rest/zt/live/web/startPlay'
+    params = {
+        'subBiz': 'mainApp',
+        'kpn': 'ACFUN_APP',
+        'kpf': 'PC_WEB',
+        'userId': userid,
+        'did': 'H5_',
+        'acfun.api.visitor_st': visitor_st
+    }
+    data = 'authorId={}&pullStreamType=FLV'.format(rid)
+    res = s.post(url, params=params, data=data, headers=headers).json()
+    if res['result'] == 1:
+        data = res['data']
+        videoplayres = json.loads(data['videoPlayRes'])
+        liveadaptivemanifest, = videoplayres['liveAdaptiveManifest']
+        adaptationset = liveadaptivemanifest['adaptationSet']
+        representation = adaptationset['representation'][-1]
+        real_url = representation['url']
+        return real_url
+    else:
+        raise Exception('直播已关闭')
+
+
+if __name__ == '__main__':
+    r = input('输入AcFun直播间号：\n')
+    print(acfun(r))

bilibili.py

@@ -1,61 +1,50 @@
-# 获取哔哩哔哩直播的真实流媒体地址。
-# PC网页和手机APP端的qn=1是最高画质;qn取值0~4。
-# 手机网页端的只找到一个值qn=0。
-
+# 获取哔哩哔哩直播的真实流媒体地址，默认获取直播间提供的最高画质
+# qn=150高清
+# qn=250超清
+# qn=400蓝光
+# qn=10000原画
 import requests
-import re
 
 
-def get_real_rid(rid):
-    room_url = 'https://api.live.bilibili.com/room/v1/Room/room_init?id=' + str(rid)
-    response = requests.get(url=room_url).json()
-    data = response.get('data', 0)
-    if data:
-        live_status = data.get('live_status', 0)
-        room_id = data.get('room_id', 0)
+def bilibili(rid):
+    # 先获取直播状态和真实房间号
+    r_url = 'https://api.live.bilibili.com/room/v1/Room/room_init?id={}'.format(rid)
+    with requests.Session() as s:
+        res = s.get(r_url).json()
+    code = res['code']
+    if code == 0:
+        live_status = res['data']['live_status']
+        if live_status == 1:
+            room_id = res['data']['room_id']
+
+            def u(pf):
+                f_url = 'https://api.live.bilibili.com/xlive/web-room/v1/playUrl/playUrl'
+                params = {
+                    'cid': room_id,
+                    'qn': 10000,
+                    'platform': pf,
+                    'https_url_req': 1,
+                    'ptype': 16
+                }
+                resp = s.get(f_url, params=params).json()
+                try:
+                    durl = resp['data']['durl']
+                    real_url = durl[-1]['url']
+                    return real_url
+                except KeyError or IndexError:
+                    raise Exception('获取失败')
+
+            return {
+                'flv_url': u('web'),
+                'hls_url': u('h5')
+            }
+
+        else:
+            raise Exception('未开播')
     else:
-        live_status = room_id = 0
-    return live_status, room_id
+        raise Exception('房间不存在')
 
 
-def get_real_url_flv(rid):
-    room = get_real_rid(rid)
-    live_status = room[0]
-    room_id = room[1]
-    qn = 1 # PC网页和手机APP端的qn=1是最高画质;qn取值0~4。
-    if live_status:
-        try:
-            room_url = 'https://api.live.bilibili.com/xlive/web-room/v1/index/getRoomPlayInfo?room_id={}&play_url=1&mask=1&qn={}&platform=web'.format(room_id, qn)
-            response = requests.get(url=room_url).json()
-            durl = response.get('data').get('play_url').get('durl', 0)
-            real_url = durl[-1].get('url')
-        except:
-            real_url = '疑似部分国外IP无法GET到正确数据，待验证'
-    else:
-        real_url = '未开播或直播间不存在'
-    return real_url
-
-
-def get_real_url_hls(rid):
-    room = get_real_rid(rid)
-    live_status = room[0]
-    room_id = room[1]
-    qn = 0 # 手机网页端的只找到一个值qn=0。
-    if live_status:
-        try:
-            room_url = 'https://api.live.bilibili.com/xlive/web-room/v1/playUrl/playUrl?cid={}&platform=h5&otype=json&quality={}'.format(room_id, qn)
-            response = requests.get(url=room_url).json()
-            durl = response.get('data').get('durl', 0)
-            real_url = durl[-1].get('url')
-        except:
-            real_url = '疑似部分国外IP无法GET到正确数据，待验证'
-    else:
-        real_url = '未开播或直播间不存在'
-    return real_url
-
-rid = input('请输入bilibili房间号：\n')
-real_url_flv = get_real_url_flv(rid)
-# real_url_hls = get_real_url_hls(rid)
-print('该直播间源地址为：')
-print(real_url_flv)
-# print(real_url_hls)
+if __name__ == '__main__':
+    r = input('输入bilibili直播间号：\n')
+    print(bilibili(r))

douyu.py

@@ -1,8 +1,4 @@
-# 获取斗鱼直播间的真实流媒体地址，可在PotPlayer、flv.js等播放器中播放。
-# 2019年11月2日：修复斗鱼预览地址获取的方法；新增未开播房间的判断。
-# 2019年12月4日：斗鱼更新后更简单了，可直接在播放页源码的JS中找到播放地址。
-
-
+# 获取斗鱼直播间的真实流媒体地址，默认最高画质。
 import requests
 import re
 import execjs
@@ -10,137 +6,86 @@ import time
 import hashlib
 
 
-def get_tt():
-    tt1 = str(int(time.time()))
-    tt2 = str(int((time.time() * 1000)))
-    today = time.strftime('%Y%m%d', time.localtime())
-    return tt1, tt2, today
+class DouYu:
 
+    def __init__(self, rid):
+        # 房间号通常为1~7位纯数字，浏览器地址栏中看到的房间号不一定是真实rid.
+        self.did = '10000000000000000000000000001501'
+        self.t10 = str(int(time.time()))
+        self.t13 = str(int((time.time() * 1000)))
 
-def get_homejs(rid):
-    room_url = 'https://m.douyu.com/' + rid
-    response = requests.get(url=room_url)
-    pattern_real_rid = r'"rid":(\d{1,7})'
-    real_rid = re.findall(pattern_real_rid, response.text, re.I)[0]
-    if real_rid != rid:
-        room_url = 'https://m.douyu.com/' + real_rid
-        response = requests.get(url=room_url)
-    homejs = ''
-    pattern = r'(function ub9.*)[\s\S](var.*)'
-    result = re.findall(pattern, response.text, re.I)
-    str1 = re.sub(r'eval.*;}', 'strc;}', result[0][0])
-    homejs = str1 + result[0][1]
-    return homejs, real_rid
+        self.s = requests.Session()
+        self.res = self.s.get('https://m.douyu.com/' + str(rid)).text
+        result = re.search(r'rid":(\d{1,7}),"vipId', self.res)
 
-
-def get_sign(rid, post_v, tt, ub9):
-    docjs = execjs.compile(ub9)
-    res2 = docjs.call('ub98484234')
-    str3 = re.sub(r'\(function[\s\S]*toString\(\)', '\'', res2)
-    md5rb = hashlib.md5((rid + '10000000000000000000000000001501' + tt + '2501' +
-                         post_v).encode('utf-8')).hexdigest()
-    str4 = 'function get_sign(){var rb=\'' + md5rb + str3
-    str5 = re.sub(r'return rt;}[\s\S]*','return re;};', str4) 
-    str6 = re.sub(r'"v=.*&sign="\+', '', str5)
-    docjs1 = execjs.compile(str6)
-    sign = docjs1.call(
-        'get_sign', rid, '10000000000000000000000000001501', tt)
-    return sign
-
-
-def mix_room(rid):
-    result1 = 'PKing'
-    return result1
-
-
-def get_pre_url(rid, tt):
-    request_url = 'https://playweb.douyucdn.cn/lapi/live/hlsH5Preview/' + rid
-    post_data = {
-        'rid': rid,
-        'did': '10000000000000000000000000001501'
-    }
-    auth = hashlib.md5((rid + str(tt)).encode('utf-8')).hexdigest()
-    header = {
-        'content-type': 'application/x-www-form-urlencoded',
-        'rid': rid,
-        'time': tt,
-        'auth': auth
-    }
-    response = requests.post(url=request_url, headers=header, data=post_data)
-    response = response.json()
-    pre_url = ''
-    if response.get('error') == 0:
-        real_url = (response.get('data')).get('rtmp_live')
-        if 'mix=1' in real_url:
-            pre_url = mix_room(rid)
+        if result:
+            self.rid = result.group(1)
         else:
-            pattern1 = r'^[0-9a-zA-Z]*'
-            pre_url = re.search(pattern1, real_url, re.I).group()
-    return pre_url
+            raise Exception('房间号错误')
 
+    @staticmethod
+    def md5(data):
+        return hashlib.md5(data.encode('utf-8')).hexdigest()
 
-def get_sign_url(post_v, rid, tt, ub9):
-    sign = get_sign(rid, post_v, tt, ub9)
-    request_url = 'https://m.douyu.com/api/room/ratestream'
-    post_data = {
-        'v': '2501' + post_v,
-        'did': '10000000000000000000000000001501',
-        'tt': tt,
-        'sign': sign,
-        'ver': '219032101',
-        'rid': rid,
-        'rate': '-1'
-    }
-    header = {
-        'Content-Type': 'application/x-www-form-urlencoded',
-        'User-Agent': 'Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/75.0.3770.100 Mobile Safari/537.36'
-    }
-    response = requests.post(url=request_url, headers=header, data=post_data).json()
-    if response.get('code') == 0:
-        real_url = (response.get('data')).get('url')
-        if 'mix=1' in real_url:
-            result1 = mix_room(rid)
+    def get_pre(self):
+        url = 'https://playweb.douyucdn.cn/lapi/live/hlsH5Preview/' + self.rid
+        data = {
+            'rid': self.rid,
+            'did': self.did
+        }
+        auth = DouYu.md5(self.rid + self.t13)
+        headers = {
+            'rid': self.rid,
+            'time': self.t13,
+            'auth': auth
+        }
+        res = self.s.post(url, headers=headers, data=data).json()
+        error = res['error']
+        data = res['data']
+        key = ''
+        if data:
+            rtmp_live = data['rtmp_live']
+            key = re.search(r'(\d{1,7}[0-9a-zA-Z]+)_?\d{0,4}(/playlist|.m3u8)', rtmp_live).group(1)
+        return error, key
+
+    def get_js(self):
+        result = re.search(r'(function ub98484234.*)\s(var.*)', self.res).group()
+        func_ub9 = re.sub(r'eval.*;}', 'strc;}', result)
+        js = execjs.compile(func_ub9)
+        res = js.call('ub98484234')
+
+        v = re.search(r'v=(\d+)', res).group(1)
+        rb = DouYu.md5(self.rid + self.did + self.t10 + v)
+
+        func_sign = re.sub(r'return rt;}\);?', 'return rt;}', res)
+        func_sign = func_sign.replace('(function (', 'function sign(')
+        func_sign = func_sign.replace('CryptoJS.MD5(cb).toString()', '"' + rb + '"')
+
+        js = execjs.compile(func_sign)
+        params = js.call('sign', self.rid, self.did, self.t10)
+        params += '&ver=219032101&rid={}&rate=-1'.format(self.rid)
+
+        url = 'https://m.douyu.com/api/room/ratestream'
+        res = self.s.post(url, params=params).text
+        key = re.search(r'(\d{1,7}[0-9a-zA-Z]+)_?\d{0,4}(.m3u8|/playlist)', res).group(1)
+
+        return key
+
+    def get_real_url(self):
+        error, key = self.get_pre()
+        if error == 0:
+            pass
+        elif error == 102:
+            raise Exception('房间不存在')
+        elif error == 104:
+            raise Exception('房间未开播')
         else:
-            pattern = r'/(\d{1,8}[0-9a-zA-Z]+)_?[\d]{0,4}.m3u8'
-            result1 = re.search(pattern, real_url).group(1)
-    else:
-        result1 = 0
-    return result1
+            key = self.get_js()
+
+        return "http://tx2play1.douyucdn.cn/live/{}.flv?uuid=".format(key)
 
 
-def get_real_url(rid):
-    rid = str(rid)
-    tt = get_tt()
-    url = get_pre_url(rid, tt[1])
-    if url:
-        return "http://tx2play1.douyucdn.cn/live/" + url + ".flv?uuid="
-    else:
-        result = get_homejs(rid)
-        real_rid = result[1]
-        homejs = result[0]
-        real_url = get_sign_url(tt[2], real_rid, tt[0], homejs)
-        if real_url != 0:
-            real_url = "http://tx2play1.douyucdn.cn/live/" + real_url + ".flv?uuid="
-        else:
-            real_url = '未开播'
-        return real_url
-
-
-def get_url_from_js(rid):
-    # 从播放页源代码中直接匹配地址
-    header = {
-    'Content-Type': 'application/x-www-form-urlencoded'
-    }
-    try:
-        response = requests.get('https://www.douyu.com/{}'.format(rid), headers=header).text
-        real_url = re.findall(r'live/({}[\d\w]*?)_'.format(rid), response)[0]
-    except:
-        real_url = '直播间未开播或不存在'
-    return "http://tx2play1.douyucdn.cn/live/" + real_url + ".flv?uuid="
-
-
-rid = input('请输入斗鱼数字房间号：\n')
-real_url = get_real_url(rid)
-print('该直播间地址为：\n' + real_url)
-
-# print(get_url_from_js('85894'))
+if __name__ == '__main__':
+    r = input('输入斗鱼直播间号：\n')
+    s = DouYu(r)
+    print(s.get_real_url())

hongle.py

@@ -1,26 +1,57 @@
 # 红人直播：https://www.hongle.tv/
+# 该平台需登陆，下面代码中已集成一个账号的登陆方式；
+# 如登陆信息过期，可用自己的账号登陆后，查找浏览器Local Storage中的hrtk字段，替换代码中的accesstoken
 from urllib.parse import urlencode
+from urllib.parse import unquote
 import requests
 import time
 import hashlib
+import json
 
 
 def hongle(rid):
+    # 模拟登陆
+    with requests.Session() as s:
+        pass
+
+    tt = int(time.time() * 1000)
+    url = 'https://service.hongle.tv/v2/userw/login?_st1={}'.format(tt)
+    data = {
+        '_st1': tt,
+        'geetest_challenge': '7f4f6fd6257799c0bcac1f38c21c042dl0',
+        'geetest_seccode': 'd1163915f4cfd6c998014c4ca8899c9d|jordan',
+        'geetest_validate': 'd1163915f4cfd6c998014c4ca8899c9d',
+        'name': '16530801176',
+        'password': 'QTXz9/Sp40BbMHwVtcb7AQ==',
+    }
+
+    data1 = urlencode(data) + 'yuj1ah5o'
+    _ajaxdata1 = hashlib.md5(data1.encode('utf-8')).hexdigest()
+    data['_ajaxData1'] = _ajaxdata1
+    del data['_st1']
+    data = json.dumps(data, separators=(',', ':'))
+    headers = {'Content-Type': 'application/x-www-form-urlencoded'}
+    res = s.post(url, data=data, headers=headers).json()
+    if res['status']['statuscode'] == '0':
+        sessionid = res['data']['sessionid']
+    else:
+        raise Exception('登陆信息过期')
+
     url = 'https://service.hongle.tv/v2/roomw/media'
-    accesstoken = 'YeOucg9SmlbeeicDSN9k0efa4JaecMNbQd7eTQDNQRRmqUHnA%2Bwq4g%3D%3D'
+    accesstoken = sessionid
     params = {
-        '_st1': int(time.time() * 1000),
+        '_st1': tt,
         'accessToken': accesstoken,
         'of': 1,
         'showid': rid,
-        'tku': 44623062,
+        'tku': 43112608,
     }
     data = urlencode(params) + 'yuj1ah5o'
     _ajaxData1 = hashlib.md5(data.encode('utf-8')).hexdigest()
     params['_ajaxData1'] = _ajaxData1
-    params['accessToken'] = 'YeOucg9SmlbeeicDSN9k0efa4JaecMNbQd7eTQDNQRRmqUHnA+wq4g=='
-    with requests.Session() as s:
-        res = s.get(url, params=params)
+    params['accessToken'] = unquote(accesstoken)
+
+    res = s.get(url, params=params)
     if res.status_code == 200:
         res = res.json()
         statuscode = res['status']['statuscode']

huya.py

@@ -1,7 +1,5 @@
 # 获取虎牙直播的真实流媒体地址。
-# 现在虎牙直播链接需要密钥和时间戳了
-
-
+# 虎牙"一起看"频道的直播间可能会卡顿
 import requests
 import re
 import base64
@@ -21,31 +19,35 @@ def live(e):
     u = base64.b64decode(fm).decode('utf-8')
     p = u.split('_')[0]
     f = str(int(time.time() * 1e7))
-    l = n['wsTime']
+    ll = n['wsTime']
     t = '0'
-    h = '_'.join([p, t, s, f, l])
+    h = '_'.join([p, t, s, f, ll])
     m = hashlib.md5(h.encode('utf-8')).hexdigest()
     y = c[-1]
-    url = "{}?wsSecret={}&wsTime={}&u={}&seqid={}&{}".format(i, m, l, t, f, y)
+    url = "{}?wsSecret={}&wsTime={}&u={}&seqid={}&{}".format(i, m, ll, t, f, y)
     return url
 
 
-def get_real_url(room_id):
+def huya(room_id):
     try:
         room_url = 'https://m.huya.com/' + str(room_id)
         header = {
             'Content-Type': 'application/x-www-form-urlencoded',
-            'User-Agent': 'Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 (KHTML, like Gecko) '
-                        'Chrome/75.0.3770.100 Mobile Safari/537.36 '
+            'User-Agent': 'Mozilla/5.0 (Linux; Android 5.0; SM-G900P Build/LRX21T) AppleWebKit/537.36 '
+                          '(KHTML, like Gecko) Chrome/75.0.3770.100 Mobile Safari/537.36 '
         }
         response = requests.get(url=room_url, headers=header).text
-        liveLineUrl = re.findall(r'liveLineUrl = "([\s\S]*?)";', response)[0]
-        if liveLineUrl:
-            if 'replay' in liveLineUrl:
-                return '直播录像：https:' + liveLineUrl
+        livelineurl = re.findall(r'liveLineUrl = "([\s\S]*?)";', response)[0]
+        if livelineurl:
+            if 'replay' in livelineurl:
+                return '直播录像：https:' + livelineurl
             else:
-                liveLineUrl = live(liveLineUrl)
-                real_url = ["https:" + liveLineUrl, "https:" + re.sub(r'_\d{4}.m3u8', '.m3u8', liveLineUrl)]
+                s_url = live(livelineurl)
+                b_url = live(livelineurl.replace('_2000', ''))
+                real_url = {
+                    '2000p': "https:" + s_url,
+                    'BD': "https:" + b_url
+                }
         else:
             real_url = '未开播或直播间不存在'
     except:
@@ -53,7 +55,6 @@ def get_real_url(room_id):
     return real_url
 
 
-rid = input('请输入虎牙房间号：\n')
-real_url = get_real_url(rid)
-print('该直播间源地址为：')
-print(real_url)
+if __name__ == '__main__':
+    rid = input('输入虎牙直播间号：\n')
+    print(huya(rid))