好友 阅读权限 10
听众 最后登录 1970-1-1
本帖最后由 helory 于 2024-2-4 21:47 编辑 0. 写在前面 马上要过年了，过年了肯定是需要有电视作为背景音乐的，但是否有稳定的直播源呢？ 毕竟它在不登录的情况下，也是可以观看几十个频道的直播（虽然大部分只有720P的清晰度）。 1. 尝试抓包 工具：Charles 、ApiPost7 、Android手机 、IPhone 使用Android手机抓包 在使用Android手机抓包的过程中，最开始遇到的是安装证书后，App提示无网络 如果你的Charles很长时间没用了(一年多)，一定要看一下证书的过期时间 ，如果证书已经过期了，那最好重置一下证书。不然就像我一样，折腾了半天发现证书是过期的…… :'(weeqw 这时候会发现安装了证书后，打开网页或使用其他App都可以正常抓包，但打开某视频App，依旧是没有网络 SSL Pinning 技术，就是开发者只信任自己的证书。LSPosed 以及JustTrustMe 模块并启用，但问题依旧，App还是提示无网络 使用IPhone抓包 Android手机行不通，那试试IPhone？ “VPN与设备管理” ，先安装描述文件 。通用 → 关于本机 → 证书信任设置 中，启用证书 。 但这时会发现，Charles拦截的请求中，几乎全部都是乱码。 https://liveinfo.ysp.cctv.cn 的请求是可以被正常被解码的，而这条请求也正包含了我们需要的直播源信息。
cKey
ApiPost ，反复测试大概猜出了defn 、cnlid 、livepid 等几个参数代表的意义，
platform 、sdtfrom 、appVer 、encryptVer 、cmd 、cnlid 、cKey 等几个值为必填，所幸的是必填项里，也只有cKey 是动态的，
cKey 值。
2. 获取cKey
jadx 反编译App，映入眼帘的都是a、b、c、d、e、f、g啥的。
jadx 有反混淆功能 。
反混淆之后，至少一切稍微可读性高了些{:1_907:}
找到cKey相关的方法
cKey cKey
com.tencent.qqlive.tvkplayer.vinfo.ckey
“liveinfo.ysp.cctv.cn”
com.tencent.qqlive.tvkplayer.tools.config ）以及这段的大概意思应该是建立了一个索引，
“zb_cgi_host” “zb_cgi_host” 。
这就有意思了，确实搜索到了有地方在使用“zb_cgi_host” 看大概得意思就是判断是使用主地址还是备用地址，
HashMap
cKey C13016e.m42151a()
com.tencent.qqlive.tvkplayer.vinfo.ckey.CKeyFacade
GenCKey
libckeygenerator.so 文件，用IDA 反编译后，确实也能找到一个GenCKey
libckeygenerator.so 文件里的GenCKey 方法呢？
AndroidNativeEmu 库来调用，均遇到了不同的问题……
使用Frida Hook getCKey方法
“服务端” 与“客户端” 。
【服务端】
在Frida 的 Github 页面上直接下载对应的frida-server 就行。
[Shell] 纯文本查看 复制代码
> adb shell uname -a
Linux localhost 4.14.180-perf-gb24d113 #2 SMP PREEMPT Thu Nov 25 13:06:04 CST 2021 aarch64
frida-server64
[Shell] 纯文本查看 复制代码
# 先把文件传到 /sdcard 目录下，所以后续还需要将它移动到其他文件夹内
> adb push frida-server64 /sdcard/Download
> adb shell
cepheus:/ $ su
cepheus:/ # mv /sdcard/Download/frida-server64 /data/local/tmp
cepheus:/ # cd /data/local/tmp
# 记得需要给可执行文件增加执行权限
cepheus:/data/local/tmp # chmod +x frida-server64
cepheus:/data/local/tmp # ./frida-server64 frida server 就已经启动了
【客户端】
frida 和 frida-tools
[Shell] 纯文本查看 复制代码
> pip install frida frida-tools
[Shell] 纯文本查看 复制代码
> frida-ps -U
cKey com.tencent.qqlive.tvkplayer.vinfo.ckey.CKeyFacade 类下面的 getCKey 方法生成的，
[Asm] 纯文本查看 复制代码
// 注入的函数需要包含在 Java.perform() 内
Java.perform(function () {
// 先让 Frida 找到 CKeyFacade 类
var CKeyFacade = Java.use("com.tencent.qqlive.tvkplayer.vinfo.ckey.CKeyFacade");
// getCKey 是 CKeyFacade 类下的方法， overload 内填写方法接受参数的类型
CKeyFacade.getCKey
.overload('java.lang.String', 'long', 'java.lang.String', 'java.lang.String', 'java.lang.String', 'java.lang.String', '[I', 'int', 'java.lang.String')
.implementation = function (val1, val2, val3, val4, val5, val6, val7, val8, val9) {
console.log(" getCKey() got called!");
// 将输入的几个参数打印出来
console.log(
`str: ${val1}; j: ${val2}; str2: ${val3}; str3: ${val4}; str4: ${val5}; str5: ${val6}; iArr: ${val7}; i: ${val8}; str6: ${val9}; `
)
var result = this.getCKey(val1, val2, val3, val4, val5, val6, val7, val8, val9);
// 将结果打印出来
console.log('ckey:'+result)
// 记得将结果返回给App，不然可能会导致App崩溃
return result
};
}); getCkey 中的 overload() 里的参数如果不知道怎么填，可以先不填。
[Shell] 纯文本查看 复制代码
> frida -U 某视频 -l test.js
“某视频” 为进程名，可以通过 frida-ps -U 来查看进程
cKey
[Plain Text] 纯文本查看 复制代码
val1：设备的guid
val2：10位时间戳
val3：cnlid，就是直播流的id
val4：appVersion，固定值
val5：platform，固定值
val6：sdtfrom，固定值
val7：[0,0,0]，固定值
val8：3，固定值
val9：空字符串，固定值 Frida Hook了getCKey
3. 使用Frida Hook请求和响应
jadx 可以直接生成frida 脚本，找到最开始找到的那个名为 m42096a() 复制为frida片段 。
[JavaScript] 纯文本查看 复制代码
//jadx生成的片段不包括 Java.perform(function(){}) ,需要自行添加
let C13028d = Java.use("com.tencent.qqlive.tvkplayer.vinfo.c.d");
C13028d["a"].overload().implementation = function () {
console.log(`C13028d.m42096a is called`);
let result = this["a"]();
console.log(`C13028d.m42096a result=${result}`);
return result;
}; m42096a()
a()
hashMap ，我们需要把代码片段再加工一下，使控制台可以输出hashMap 里的内容。
[JavaScript] 纯文本查看 复制代码
Java.perform(function () {
var Gson = Java.use('com.google.gson.Gson').$new();
let C13028d = Java.use("com.tencent.qqlive.tvkplayer.vinfo.c.d");
C13028d["a"].overload().implementation = function () {
console.log(`C13028d.m42096a is called`);
let result = this["a"]();
var json_str = Gson.toJsonTree(result).getAsJsonObject();
var json_obj = JSON.parse(json_str)
console.log(`C13028d.m42096a result=${json_obj}`);
return result;
};
});
com.tencent.qqlive.tvkplayer.vinfo.p543c.C13028d
C13029e json解析 的日志输出。
com.tencent.qqlive.tvkplayer.vinfo.p543c.C13029e.m42080a() 解析响应json字符串 的。
[JavaScript] 纯文本查看 复制代码
Java.perform(function () {
var Gson = Java.use('com.google.gson.Gson').$new();
var reqHashMapClass = Java.use("com.tencent.qqlive.tvkplayer.vinfo.c.d");
var repJsonClass = Java.use("com.tencent.qqlive.tvkplayer.vinfo.c.e");
reqHashMapClass.a.overload().implementation = function () {
var result = this.a();
console.log("==============================");
console.log("↓↓↓↓↓↓↓↓↓请求数据-START↓↓↓↓↓↓↓↓");
var json_str = Gson.toJsonTree(result).getAsJsonObject();
var json_obj = JSON.parse(json_str)
const date = new Date();
console.log(`json: ${json_str}`);
console.log(date.toLocaleString('zh-CN', { timeZone: 'Asia/Shanghai' }));
console.log(`cnlid: ${json_obj.cnlid}`);
console.log(`livepid: ${json_obj.livepid}`);
console.log(`defn: ${json_obj.defn}`);
console.log(`vip_status: ${json_obj.vip_status}`);
console.log("↑↑↑↑↑↑↑↑↑请求数据-END↑↑↑↑↑↑↑↑↑↑");
console.log("==============================");
return result
};
repJsonClass.a.overload('java.lang.String').implementation = function (str) {
var result = this.a(str);
console.log("==============================");
console.log("↓↓↓↓↓↓↓↓↓响应数据-START↓↓↓↓↓↓↓↓");
var json_obj = JSON.parse(str)
const date = new Date();
console.log(date.toLocaleString('zh-CN', { timeZone: 'Asia/Shanghai' }));
console.log(`errinfo: ${json_obj.errinfo}`);
console.log(`cnlid: ${json_obj.cnlid}`);
console.log(`defn: ${json_obj.defn}`);
console.log(`livepid: ${json_obj.livepid}`);
console.log(`playurl: ${json_obj.playurl}`);
// console.log(str)
console.log("↑↑↑↑↑↑↑↑↑响应数据-END↑↑↑↑↑↑↑↑↑↑");
console.log("==============================");
return result
};
});
只要Hook okhttp的模块，就和上面提到的Android抓包一样，提示无网络 :'(weeqw ，不知道是否有大佬能解答下 {:1_889:}
4. 通过 Frida 创建 getCKey API 上面的所有案例中，Frida都是通过被动调用的方式来执行的，那么它可以主动调用对应的方法吗？
https://github.com/frida/frida-python/blob/ebd797e4bc248b8d895d68ebf244a34744cb3ea9/examples/rpc.py
简单说，就是通过frida提供的 rpc.exports
getCkey.js [JavaScript] 纯文本查看 复制代码
// getCkey.js 只需要输入时间戳和cnlid即可
function ckey(timestamp, cnlid){
var result = '';
Java.perform(function(){
var CKeyFacade = Java.use("com.tencent.qqlive.tvkplayer.vinfo.ckey.CKeyFacade");
var guid = '9d3644141c7047acb072f6343cfaa433';
var appVer = 'V8.12.1034.4382';
var platform = '4330303';
var sdtfrom = 'v5028';
var _iArr = [0,0,0];
var _i = 3;
var _str6 = '';
result = CKeyFacade.getCKey(guid, timestamp, cnlid, appVer, platform, sdtfrom, _iArr, _i, _str6);
});
return result
}
rpc.exports = {
ckey: ckey
} Python脚本
[Python] 纯文本查看 复制代码
import frida, sys, time
# 读取js脚本，也可以直接以字符串的形式写在python脚本中
with open('getCkey.js', 'r+') as f:
js_code = f.read()
# 通过USB获取设备
device = frida.get_usb_device()
# attach进程
session = device.attach('某视频')
# 加载脚本
script = session.create_script(js_code)
script.load()
# 获取frida导出的函数
api = script.exports_sync
# 可以直接调用ckey函数，来获取CKey
result = api.ckey(int(time.time()), '2000210103')
print(result) 远程调用Frida 在实际应用的环境中，手机一直用USB连着电脑似乎也不太靠谱，而Frida也提供了远程调用的方式。
[Shell] 纯文本查看 复制代码
./frida-server64 -l 0.0.0.0 那么之前注入脚本的命令也变成了 [Shell] 纯文本查看 复制代码
frida -H 10.10.10.170 -n 某视频 -l test.js 在python中调用的方式，也变成了 [Python] 纯文本查看 复制代码
device = frida.get_device_manager().add_remote_device('10.10.10.170')
session = device.attach('某视频')
script = session.create_script(js_code)
script.load() 甚至也可以在虚拟机 或者树莓派等设备中安装安卓系统作为专门的api服务器
非实体Android系统 若在树莓派中的Android系统，主要有两种选择： EmteriaOS（注册账户后即可下载安装程序，通过安装程序可刷写系统到TF卡中，非商业版8小时重启一次） LineageOS（由konstakang大佬魔改而来，下载镜像刷写到TF卡中即可）
5. 整理脚本 最后可以将上述所有的整理成脚本即可根据自己的需求去获取各个直播流的地址了。
[Python] 纯文本查看 复制代码
import requests, time, logging
from functools import wraps
from requests.exceptions import ConnectTimeout, ConnectionError
class WaterRequest():
def __init__(
self,
headers={},
config={},
logger=logging.getLogger(__name__),
retry_times=5,
**kwargs
):
self.session = requests.Session()
self.headers = {
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.61 Safari/537.36',
**headers
}
self.config = {
'timeout': 300,
'verify': True,
**config
}
self.logger = logger
self.session.headers.update({**self.headers})
self.retry_times = retry_times
def __enter__(self):
return self
def __exit__(self, exc_type, exc_val, exc_tb):
self.close()
def retry_decorator(func):
@wraps(func)
def wrapped_function(*args, **kwargs):
_self = [*args][0]
result = None
for i in range(_self.retry_times):
if i > 0:
_self.logger.warning(f'正在进行第 {i} 次重试...')
try:
result = func(*args, **kwargs)
break
except (ConnectionError, ConnectTimeout) as e:
_url = {**kwargs}.get('url', None)
if _url is None:
if len([*args])>1:
_url = [*args][1]
if _url is not None and len(_url)>20:
_url = f'{_url[:10]}...{_url[-10:]}'
if type(e) == ConnectionError:
_self.logger.warning(f'[ConnectionError][URL:{_url}]')
elif type(e) == ConnectTimeout:
_self.logger.warning(f'[ConnectTimeout][URL:{_url}]')
else:
_self.logger.warning(f'[未知错误][URL:{_url}]')
if i == _self.retry_times-1:
_self.logger.error(f'已重试 {i+1} 次，达到最大重试次数，访问失败')
break
else:
_self.logger.info(f'3秒后进行第 {i+1} 次重试')
time.sleep(3)
continue
return result
return wrapped_function
def updateHeaders(self, new_header:dict):
self.headers.update({**new_header})
_s = self.session
_s.headers.update({**new_header})
@retry_decorator
def get(self, url, query:dict=None, data:dict=None):
_s = self.session
_r = _s.get(url, params=query, data=data, **self.config)
return _r.json()
@retry_decorator
def post(self, url, json:dict=None, query:dict=None, data:dict=None):
_post_data = {}
if data is not None:
_post_data = {
'data': data
}
if json is not None:
_post_data = {
'json': json
}
_s = self.session
_r = _s.post(url, params=query, **_post_data, **self.config)
return _r.json()
@retry_decorator
def delete(self, url, json:dict=None, query:dict=None, data:dict=None):
_s = self.session
_r = _s.delete(url, json=json, params=query, data=data, **self.config)
return _r.json()
def close(self):
return self.session.close() config.py [Python] 纯文本查看 复制代码
ANDROID_IP = '10.10.10.170'
LIVEINFO_URL = 'https://liveinfo.ysp.cctv.cn/'
REQUEST_HEADER = {
'Host': 'liveinfo.ysp.cctv.cn',
'Accept-Encoding': 'gzip',
'User-Agent': 'qqlive'
}
# 参数已脱敏处理
REQUEST_QUERY = {
'platform': '',
'sdtfrom': '',
'appVer': '',
'encryptVer': '',
'cmd': '',
'spacode': '',
'app_version': '',
'spwebrtc': '',
'spwm': '',
'hevclv': '',
'stream': '',
'sphttps': '',
'spdynamicrange': '',
'wxopenid': '',
'spdemuxer': '',
'spvcode': '',
'sphdrfps': '',
'qq': '',
'defnsrc': '',
'estid': '',
'newnettype': '',
'spflvaudio': '',
'adjust': '',
'guid': '',
'vip_status': '',
'spflv': '',
'uhd_flag': '',
'otype': '',
'caplv': ''
}
# 仅保留两条作为示例
CHANNELS = [{'type': 'CCTV',
'name': '超高清4K',
'livepid': '600002264',
'cnlid': '2000266303',
'icon': 'https://jietufengmian.yangshipin.cn/20230915/1859032628044/a9b31c00c575f5e3a5ca0e27fa8ff208.webp',
'tvg-name': 'noepg',
'tvg-id': '9999'},
{'type': 'CCTV',
'name': '1 综合',
'livepid': '600001859',
'cnlid': '2000210103',
'icon': 'https://jietufengmian.yangshipin.cn/20230915/1857389472656/1e5dbbb13283991e8f443cfb5f229f06.webp',
'tvg-name': 'CCTV1',
'tvg-id': '1'}] getCkey.js [JavaScript] 纯文本查看 复制代码
function ckey(timestamp, cnlid){
var result = '';
Java.perform(function(){
var CKeyFacade = Java.use("com.tencent.qqlive.tvkplayer.vinfo.ckey.CKeyFacade");
var guid = '9d3644141c7047acb072f6343cfaa433';
var appVer = 'V8.12.1034.4382';
var platform = '4330303';
var sdtfrom = 'v5028';
var _iArr = [0,0,0];
var _i = 3;
var _str6 = '';
result = CKeyFacade.getCKey(guid, timestamp, cnlid, appVer, platform, sdtfrom, _iArr, _i, _str6);
});
return result
}
rpc.exports = {
ckey: ckey
} m3u8.j2 [HTML] 纯文本查看 复制代码
#EXTM3U
{%- for ch in channel_list %}
#EXTINF:-1 tvg-id="{{ ch.get('tvg-id', '9999') }}" tvg-name="{{ ch.get('tvg-name', 'noepg') }}" tvg-logo="{{ ch.get('icon', '') }}" group-title="{{ ch.get('type', '其他') }}",{% if ch.get('type') == 'CCTV' %}{{ ch.get('type') }}-{% endif %}{{ ch.get('name') }}[{{ ch.get('defn') }}]
{{ ch.get('playurl') }}
{%- endfor -%} main.py [Python] 纯文本查看 复制代码
import time, frida, sys, logging, \
subprocess, re, os, random, uuid, datetime
from config import CHANNELS, ANDROID_IP, \
REQUEST_QUERY, LIVEINFO_URL, REQUEST_HEADER
from WaterRequests import WaterRequest
from jinja2 import Environment, FileSystemLoader, select_autoescape
logger = logging.getLogger(__name__)
logger.setLevel(level=logging.DEBUG)
formatter = logging.Formatter(
'%(asctime)s - %(levelname)s: %(message)s'
)
console = logging.StreamHandler()
console.setLevel(logging.INFO)
console.setFormatter(formatter)
logger.addHandler(console)
handler = logging.FileHandler('getYSPLive.log', encoding='utf8')
handler.setLevel(logging.DEBUG)
handler.setFormatter(formatter)
logger.addHandler(handler)
class CkeyGenerator():
def __init__(self, android_ip: str) -> None:
self.android_ip = android_ip
self.pid = 0
self.process_name = ''
self.js_code = ''
self.device = None
self.session = None
self.script = None
self.api = None
self.pattern = re.compile(
r'(\d+)\s*(com\.cctv\.yangshipin\.app\.androidp|央视频)\s+',
re.MULTILINE
)
if self._checkFrida():
self._loadJsCode()
self._attachProcess()
def _checkFrida(self) -> bool:
logger.info('开始检查与Android的连接...')
run = subprocess.run(
f'frida-ps -H {self.android_ip}', shell=True, stdout=subprocess.PIPE,
stderr=subprocess.PIPE, text=True, encoding='utf8'
)
matches = self.pattern.findall(run.stdout)
if len(matches) <= 0:
logger.warning('frida server未启动或未打开应用，退出脚本。')
sys.exit()
else:
self.pid = int(matches[0][0])
self.process_name = matches[0][1]
logger.info(f'发现进程 [{self.pid}]{self.process_name}')
return True
def _loadJsCode(self) -> str:
if os.path.exists('getCkey.js'):
with open('getCkey.js', 'r+') as f:
self.js_code = f.read()
logger.info('已加载JavaScript脚本 getCkey.js')
return self.js_code
else:
logger.warning('未找到 getCkey.js 文件！退出脚本。')
sys.exit()
def _attachProcess(self):
try:
self.device = frida.get_device_manager().add_remote_device(self.android_ip)
self.session = self.device.attach(self.pid)
self.script = self.session.create_script(self.js_code)
self.script.load()
self.api = self.script.exports_sync
logger.info(f'attach进程 [{self.pid}]{self.process_name} 成功')
except Exception as e:
logger.warning(f'attach进程失败，退出脚本。Error:{e}')
sys.exit()
def createCKey(self, timestamp: int, cnlid: str) -> str:
ckey = self.api.ckey(timestamp, cnlid)
logger.debug(f'成功获取CKey:[{timestamp}][{cnlid}][{ckey}]')
return ckey
class LiveInfo():
def __init__(
self,
channel_info: dict,
url: str,
query: dict,
request_class: WaterRequest,
ckey_class: CkeyGenerator
) -> None:
self.url = url
self.query = query
self.channel_info = channel_info
self.get_ckey = ckey_class
self.request = request_class
self.defn = self._getDefn()
self.flowid = self._getFlowID()
self.fntick = self._getTimeStamp()
self.pageId = self._getPageID()
self.refer_pageId = self._getReferPageID()
self.randnum = self._getRandNum()
self.livepid = self._getLivePid()
self.cnlid = self._getCnlid()
self.cKey = self._getCkey(self.fntick, self.cnlid)
@property
def channel_type(self):
return self.channel_info.get('type')
@property
def channel_name(self):
if self.channel_info.get('type') == 'CCTV':
return f"{self.channel_info.get('type')}-{self.channel_info.get('name')}"
return self.channel_info.get('name')
def _getDefn(self) -> str:
if self.channel_info.get('livepid') == '600156816':
return 'fhd'
return 'fhd'
def _getFlowID(self) -> str:
unique_id = str(uuid.uuid4())
nano_timestamp = str(int(time.time() * 1e3))
return unique_id + nano_timestamp + '_4330303'
def _getRandNum(self) -> int:
return round(random.uniform(0, 1), 16)
def _getTimeStamp(self) -> int:
self.timestamp = int(time.time())
return self.timestamp
def _getCkey(self, timestamp: int, cnlid:str) -> str:
return self.get_ckey.createCKey(timestamp, cnlid)
def _getReferPageID(self) -> str:
if self.channel_info.get('type', 'CCTV') == 'CCTV':
return 'page_channel_510104'
else:
return 'page_tv_500102'
def _getPageID(self) -> str:
if self.channel_info.get('type', 'CCTV') == 'CCTV':
return 'page_tv_500102'
else:
return 'page_tv_500105'
def _getLivePid(self) -> str:
return self.channel_info.get('livepid')
def _getCnlid(self) -> str:
return self.channel_info.get('cnlid')
def getLiveInfo(self) -> dict:
self.query['defn'] = self.defn
self.query['flowid'] = self.flowid
self.query['fntick'] = self.fntick
self.query['pageId'] = self.pageId
self.query['refer_pageId'] = self.refer_pageId
self.query['randnum'] = self.randnum
self.query['livepid'] = self.livepid
self.query['cnlid'] = self.cnlid
self.query['cKey'] = self.cKey
rep = self.request.get(self.url, self.query)
if rep is None:
return None
errinfo = rep.get('errinfo', 'no errinfo')
if errinfo == 'success!':
rep_defn = rep.get('defn').upper()
rep_playurl = rep.get('playurl')
logger.info(f'{self.channel_type} - {self.channel_name}[{rep_defn}]: {rep_playurl}')
return {
'type': self.channel_type,
'name': self.channel_name,
'defn': rep_defn,
'playurl': rep_playurl,
'icon': self.channel_info.get('icon'),
'tvg-id': self.channel_info.get('tvg-id', '9999'),
'tvg-name': self.channel_info.get('tvg-name', 'noepg')
}
else:
logger.warning(self.query)
logger.warning(f'[{self.channel_type} - {self.channel_name}] 获取播放地址失败，原因：{errinfo}')
return None
def createM3U8(channel_list:list):
env = Environment(
loader=FileSystemLoader(os.getcwd()),
autoescape=select_autoescape()
)
template = env.get_template('m3u8.j2')
m3u8 = template.render(channel_list=channel_list)
if not os.path.exists('m3u8'):
os.mkdir('m3u8')
filename = f"{datetime.datetime.now().strftime('%Y_%m_%d_%H%M%S')}.m3u8"
filepath = os.path.join(os.getcwd(), 'm3u8', filename )
try:
with open(filepath, 'w+') as f:
f.write(m3u8)
logger.info(f'成功生成m3u8文件，文件路径：{filepath}')
except Exception as e:
logger.warning(f'写入m3u8文件失败！ERROR: {e}')
sys.exit()
def main():
logger.info('脚本开始执行...')
request = WaterRequest(REQUEST_HEADER,logger=logger)
ckeyGen = CkeyGenerator(ANDROID_IP)
channel_list = []
for channel in CHANNELS:
liveinfo = LiveInfo(
channel, LIVEINFO_URL, REQUEST_QUERY,
request, ckeyGen
)
_info = liveinfo.getLiveInfo()
if not _info is None:
channel_list.append(_info)
logger.info(f'直播地址获取完毕，共获取 {len(channel_list)} 条信息')
if len(channel_list) > 0:
createM3U8(channel_list)
logger.info('脚本执行结束...')
if __name__ == '__main__':
main() 6. 总结 最早在测试的时候，发现每个直播流的地址有效期大概是4小时左右，
但后面开始批量获取直播流地址的时候每个直播流地址的有效期时间变得很短，大概十几分钟就失效了，
猜测有可能和请求参数里的guid短时间内发送大量请求有关，
但这些现在已经不重要了，更重要的是通过这次实践了解到的App爬虫思路。
需要分析大量的网络请求，甚至要破解 各种加密算法。
但通过这次实践，了解到了Frida神器，便完全可以换一种思路来爬取App中的内容，
让App自己来成为核心算法的API服务器，借助这些api再去爬取App的内容，这样便可以省去很大一部分精力。
之所以Charles抓包的时候请求和响应都是乱码，也是因为其使用是jce协议，也就是使用的腾讯tars框架。
在 com.tencent.videolite.android.datamodel.cctvjce
所有的请求数据都会经过这些结构体进行序列化成二进制流与服务器沟通，响应数据也同样经过结构体的反序列化后呈现在App中。
查看全部评分
[复制链接]
发表于 2024-2-11 00:16
|
发表于 2024-2-9 12:11
|楼主
收藏
淘帖
有用
分享到朋友圈
