抖音虎牙斗鱼快手等多平台直播流地址获取服务

Author： XGSClear7
发布时间：July 29, 2021
1549 views
6 comments
10700 words
Categories：技术

## 为什么要做这个

看自己的github上的star的时候发现了[wbt5/real-url](https://github.com/wbt5/real-url)，感觉一个个的脚本找起来挺麻烦的，就想着能不能整合成一个服务去调用，抽空摸了几个小时鱼就有了现在这个项目。

## 如何实现

首先先看看完整的项目结构：

```bash
root.
│  config.py	# 配置文件
│  flask_server.py	# flask app
│  README.md	# 说明文档
│  requirements.txt	# 依赖包
├─apps	# 注册的app
│    live_url_api.py	# 获取直播链接的api文件
│   __init__.py
│
├─Logs	# 日志模块
│      Error.log	# 错误日志
│      Runtime.log	# 运行日志
│
├─routings	# 直播平台区分路由
│    live_api_routing.py	# 直播平台区分路由
│    __init__.py
│
├─scripts
│  │  base.py	# 基础类
│  │  __init__.py	# 读取所有继承基础类的类对象
│  │
│  └─lives	# 各直播平台脚本
│    │  173.py
│    │  17live.py
│    │  2cq.py
│    │  51lm.py
│    │  95xiu.py
│    │  9xiu.py
│    │  acfun.py
│    │  bilibili.py
│    │  cc.py
│    │  changyou.py
│    │  douyin.py
│    │  douyu.py
│    │  egame.py
│    │  fengbolive.py
│    │  hongle.py
│    │  huajiao.py
│    │  huomao.py
│    │  huya.py
│    │  imifun.py
│    │  immomo.py
│    │  inke.py
│    │  iqiyi.js
│    │  iqiyi.py
│    │  ixigua.py
│    │  jd.py
│    │  kbs.py
│    │  kk.py
│    │  kuaishou.py
│    │  kugou.py
│    │  kuwo.py
│    │  laifeng.py
│    │  lehai.py
│    │  longzhu.py
│    │  look.py
│    │  maoer.py
│    │  now.py
│    │  pps.py
│    │  ppsport.py
│    │  qf.py
│    │  qie.py
│    │  renren.py
│    │  showself.py
│    │  sports_iqiyi.py
│    │  tiktok.py
│    │  tuho.py
│    │  twitch.py
│    │  v6cn.py
│    │  wali.py
│    │  woxiu.py
│    │  xunlei.py
│    │  yangshipin.py
│    │  yizhibo.py
│    │  youku.py
│    │  yuanbobo.py
│    │  yy.py
│    │  zhanqi.py
│    │  zhibotv.py
│    └─ __init__.py
└─templates	# 模板文件夹
      LiveUrlDocs.html	# 接口文档HTML
      LiveUrlDocs.md	# 接口文档
```

我目前比较顺手的web框架就是**flask**了，简单易上手。

首先使用**flask**搭建一个web服务：

```python
# flask_server.py
# -*- coding: utf-8 -*-
from flask import Flask
from flask_restful import Api

from loguru import logger
from apps.live_url_api import live_api
from config import *

# 注册flask
app = Flask(__name__)
# restful
api = Api(app)
# encode
app.config.update(RESTFUL_JSON=dict(ensure_ascii=False))
app.config['JSON_AS_ASCII'] = False
# registered
app.register_blueprint(live_api, url_prefix='/live-api')

if __name__ == '__main__':
    logger.info(f"server run on {API_HOST}:{API_PORT}. threaded is {'on' if API_THREADED else 'off'}.")
    app.run(host=API_HOST, port=API_PORT, threaded=API_THREADED)
```

端口 HOST 等再创建一个**config**配置方便管理，因为本项目没有用的数据库，如果要添加数据库，请使用**环境变量**配置，如何配置请看这篇文章：[flask配置文件之python-dotenv的使用 - PY·DUCK (pyduck.com)](https://www.pyduck.com/archives/22/)

```python
# config.py
# -*- coding: utf-8 -*-
# 日志模块
from loguru import logger

logger.add('./Logs/Runtime.log', level='DEBUG', retention='7 days', encoding='utf-8')
logger.add('./Logs/Error.log', level='ERROR', retention='7 days', encoding='utf-8')

# api配置
API_HOST = '0.0.0.0'
API_PORT = 7000
API_THREADED = True	# 是否开启多线程
```

如果用其他服务部署的话API配置可以不必计较，如何部署我们后边会讲。

接下来我们在**live_url_api.py**里面配置接口：

```python
# live_url_api.py
# -*- coding: utf-8 -*-
from flask import Blueprint, render_template
from flask_restful import Resource
from flask_restful import reqparse
from loguru import logger
from routings.live_api_routing import RunScripts

live_api = Blueprint('live_api', __name__)

# 响应模板
return_model = {'state': 0, 'data': None}

class LiveUrl(Resource):
    """
    直播流接口
    """

def __init__(self):
        self.return_data = return_model
        self.reqparse = reqparse.RequestParser()
        self.reqparse.add_argument('live_platform', type=str, required=True, help='直播平台')
        self.reqparse.add_argument('parameter', type=str, required=True, help='需要解析的内容')
        super(LiveUrl, self).__init__()

def get(self):
        # 定义消息体
        return_data = self.return_data.copy()
        # 接收front参数
        args = self.reqparse.parse_args()
        live_platform = args.get('live_platform')
        parameter = args.get('parameter')
        logger.info(f"req: live_platform-{live_platform} parameter-{parameter}")
        live_url = RunScripts(live_platform, parameter).choice()
        logger.info(f"res: live_platform-{live_platform} parameter-{parameter} res-{live_url}")
        if not live_url:
            return return_data
        return_data['state'] = 1
        return_data['data'] = live_url
        return return_data

class LiveUrlDocs(Resource):
    """
    接口文档
    """
    def get(self):
        """
        获取接口文档
        :return:
        """
        return render_template('LiveUrlDocs.html')

live_api.add_url_rule(rule='/api-docs', view_func=LiveUrlDocs.as_view('api-docs'))
live_api.add_url_rule(rule='/get-url', view_func=LiveUrl.as_view('get-live-url'))
```

因为要对接很多直播平台的脚本文件，我们不可能一个一个去判断再去调用相应的脚本，这里我之前看过崔庆才的代理池项目：[[Python3 网络爬虫开发实战] 9.2 - 代理池的维护 | 静觅 (cuiqingcai.com)](https://cuiqingcai.com/7048.html)，里面用到了如何灵活调用类方法。

基类文件：

```python
# base.py
class Base(object):
    _name = 'Base'

def __init__(self):
        self.rid = ''

def get_real_url(self):
        return
```

读取所有继承类：

```python
# __init__.py
# -*- coding: utf-8 -*-
import pkgutil
from .base import Base
import inspect

# load classes subclass of BaseCrawler
classes = []
for loader, name, is_pkg in pkgutil.walk_packages(__path__):
    module = loader.find_module(name).load_module(name)
    for name, value in inspect.getmembers(module):
        globals()[name] = value
        if inspect.isclass(value) and issubclass(value, Base) and value is not Base \
                and not getattr(value, 'ignore', False):
            classes.append(value)
__all__ = __ALL__ = classes
```

然后将脚本文件统一继承基类，统一调用函数：

```python
# 2cq.py
# 棉花糖直播：https://www.2cq.com/rank

import requests

from scripts.base import Base

class MHT(Base):	# 继承基类

_name = '棉花糖'	# 定义名称，方便判断

def __init__(self, rid):
        super(Base, self).__init__()
        self.rid = rid

def get_real_url(self):
        with requests.Session() as s:
            res = s.get('https://www.2cq.com/proxy/room/room/info?roomId={}&appId=1004'.format(self.rid))
        res = res.json()
        if res['status'] == 1:
            result = res['result']
            if result['liveState'] == 1:
                real_url = result['pullUrl']
                return real_url
            else:
                return '未开播'
        else:
            return '直播间可能不存在'

if __name__ == '__main__':
    r = input('输入棉花糖直播房间号：\n')
    print(MHT(r).get_real_url())
```

最后把判断调用的脚本写好就OK了：

```python
# live_api_routing.py
# -*- coding: utf-8 -*-
from loguru import logger

from scripts import __all__ as scripts_cls

class RunScripts:

def __init__(self, live_platform, parameter):
        self.scripts_cls = scripts_cls
        self.live_platform = live_platform
        self.parameter = parameter
        self.scripts = [scripts(self.parameter) for scripts in self.scripts_cls]

def choice(self):
        """
        选择脚本
        :return:
        """
        for live_platform in self.scripts:
            if self.live_platform.upper() == live_platform._name:
                logger.info(f'live_platform {live_platform} to get live url.')
                data = live_platform.get_real_url()
                return data
        else:
            return

if __name__ == '__main__':
    print(RunScripts('羚萌', '24003').choice())
```

## 如何部署

### 运行环境：

**python3.6及以上**

### 安装依赖

在项目路径下运行此命令

```shell
pip install -r rquirements.txt
```

### 服务部署

1. mac
   暂未测试
2. windows
   直接运行
   ```shell
   python flask_server.py
   ```
3. linux
   可以用gunicorn部署
   ```
   运行命令
   gunicorn -w 4 -b 127.0.0.1:8080 flask_server:app
   配置说明
   -c CONFIG, --config=CONFIG 设定配置文件。
   -b BIND, --bind=BIND 设定服务需要绑定的端口。建议使用HOST:PORT。 
   -w WORKERS, --workers=WORKERS 设置工作进程数。建议服务器每一个核心可以设置2-4个。 
   -k MODULE 选定异步工作方式使用的模块。
   ```

## 接口说明

### 接口地址

[http://api.pyduck.com/live-api/get-url](http://api.pyduck.com/live-api/get-url)

接口免费，服务器性能有限，勿压请爱惜。

### 接口文档请访问

[获取直播流接口文档](http://api.pyduck.com/live-api/api-docs)

## 项目说明

本项目开源，由于本身有工作，再加上下班就躺，所以有问题请在github上发issue，我会用上班摸鱼的时间去看。->  [XGSClear7 (26℃) (github.com)](https://github.com/XGSClear7)

### 支持的直播平台

| 平台名称   | 请求说明                    |
| ------------ | ----------------------------- |
| 棉花糖     | 直播房间号                  |
| 九秀       | 直播房间号                  |
| 17         | 直播房间号                  |
| 羚萌       | 直播房间号                  |
| 95秀       | 直播房间号                  |
| 艺气山     | 直播房间号                  |
| AcFun      | 直播房间号                  |
| 哔哩哔哩   | 直播房间号                  |
| 网易CC     | 直播房间号                  |
| 畅秀阁     | 直播房间号                  |
| 抖音       | 抖音直播间room_id或分享链接 |
| 斗鱼       | 直播间号                    |
| 企鹅电竞   | 房间号                      |
| 新浪疯播   | 直播房间号                  |
| 红人       | 直播房间号                  |
| 花椒       | 直播房间号                  |
| 火猫       | 直播房间号                  |
| 虎牙       | 直播房间号                  |
| 艾米       | 直播房间号                  |
| 陌陌       | 直播房间号                  |
| 映客       | 直播房间号                  |
| 爱奇艺     | 直播房间号                  |
| 西瓜       | 直播房间号                  |
| 京东       | 直播房间号                  |
| 腾讯体育   | 直播间地址                  |
| KK         | 直播房间号                  |
| 快手       | 直播房间ID                  |
| 酷狗       | 直播房间号                  |
| 酷我聚星   | 直播房间号                  |
| 来疯       | 直播房间号                  |
| 乐嗨       | 直播房间号                  |
| 龙珠       | 直播房间号                  |
| Look       | 直播房间号                  |
| 猫耳       | 直播房间号                  |
| NOW        | 直播间号                    |
| PPS奇秀    | 直播房间号                  |
| PP体育     | 直播间地址                  |
| 千帆       | 直播房间号                  |
| 企鹅体育   | 直播房间号                  |
| 人人       | 直播房间号                  |
| 秀色       | 直播房间号                  |
| 爱奇艺体育 | 直播间完整地址              |
| TikTok     | 分享链接                    |
| 星光       | 直播房间号                  |
| twitch     | 房间名                      |
| 六间房     | 直播房间号                  |
| 小米       | 直播房间号                  |
| 我秀       | 直播房间号                  |
| 迅雷       | 直播房间号                  |
| 央视频     | 央视频地址                  |
| 一直播     | 房间地址                    |
| 优酷轮播台 | 房间号                      |
| 热猫       | 直播房间号                  |
| YY         | 直播房间号                  |
| 战旗       | 直播房间号                  |
| 中国       | 体育房间号                  |

Last modification：August 2, 2021

如果觉得我的文章对你有用，请作者喝杯咖啡把~

6 comments

ColdStone
July 26th, 2022 at 05:58 pm

博主这个 API 接口会一直运行吗？

Reply
lkainan
March 24th, 2022 at 10:41 am

博主，随着real-url的更新，您库里的有些文件可能没法用了。
我尝试在容器内直接替换对应的文件，解析依旧不行。
例如 bilibili的22015508,单独使用新的bilibili.py，能正常解析,{'线路1': 'https://d1--cn-gotcha208.bilivideo.com/live-bvc/872142/live_473837611_14189661/index.m3u8?expires=1648093249&len=0&oi=1950320294&pt=h5&qn=10000&trid=1007799513a2c0f241ac8b50bc217b99c5a6&sigparams=cdn,expires,len,oi,pt,qn,trid&cdn=cn-gotcha208&sign=8cc813159ca5dca4a0d776d770d73e72&sk=c9c6154426932efa80d25af02e87a3bd&p2p_type=0&src=57353&sl=3&free_type=0&flowtype=1&machinezone=jd&pp=rtmp&slot=9&source=onetier&order=1&site=746de84d532c38ca7d26e9415bfcc0e1', '线路2': 'https://d1--cn-gotcha203.bilivideo.com/live-bvc/872142/live_473837611_14189661/index.m3u8?expires=1648093249&len=0&oi=1950320294&pt=h5&qn=10000&trid=1007799513a2c0f241ac8b50bc217b99c5a6&sigparams=cdn,expires,len,oi,pt,qn,trid&cdn=cn-gotcha203&sign=4689c80bdfaf1bbcf9b4c29bfb872b99&sk=c9c6154426932efa80d25af02e87a3bd&p2p_type=0&src=57353&sl=3&free_type=0&flowtype=1&machinezone=jd&pp=rtmp&slot=9&source=onetier&order=2&site=746de84d532c38ca7d26e9415bfcc0e1'}
使用咱们的api的话，得到的提示是这样的“{"data":null,"state":0}”。请问一下，这类问题，一般需要怎么才能修复。
谢谢

Reply
1. 小木木
  March 24th, 2022 at 12:42 pm
  
  @lkainan
  
  请问一下，你这个是如何调用出来的，比如你的B站的22015508这个，http://api.pyduck.com/live-api/get-url?bilibili&roomid=22015508，调用不出来啊，能否给一个完整的调用网址示例
  
  Reply
小木木
March 12th, 2022 at 01:21 am

博主你到是给个请求示例啊，搞了半天都不知道怎么调用的。只有接口地址，但是后面的参数怎么输入都不清楚啊，比如我要调用这个数据： https://www.yy.com/91399980，那么完整的请求网是是多少，你写详细一点呀

Reply
VIP券网vipquanwang
August 5th, 2021 at 05:41 pm

接口地址挂了。。。另外，能不能增加个新的接口版本，使得php输出的结果是直接跳转到那输出视频的链接

Reply
1. XGSClear7
  August 11th, 2021 at 08:48 am
  
  @VIP券网vipquanwang
  
  接口已经恢复，如何对接PHP这个还真不太了解
  
  Reply

抖音虎牙斗鱼快手等多平台直播流地址获取服务

XGSClear7 • 2021 年 07 月 29 日

## 为什么要做这个

## 如何实现

首先先看看完整的项目结构：

我目前比较顺手的web框架就是**flask**了，简单易上手。

首先使用**flask**搭建一个web服务：

```python
# flask_server.py
# -*- coding: utf-8 -*-
from flask import Flask
from flask_restful import Api

from loguru import logger
from apps.live_url_api import live_api
from config import *

if __name__ == '__main__':
    logger.info(f"server run on {API_HOST}:{API_PORT}. threaded is {'on' if API_THREADED else 'off'}.")
    app.run(host=API_HOST, port=API_PORT, threaded=API_THREADED)
```

```python
# config.py
# -*- coding: utf-8 -*-
# 日志模块
from loguru import logger

logger.add('./Logs/Runtime.log', level='DEBUG', retention='7 days', encoding='utf-8')
logger.add('./Logs/Error.log', level='ERROR', retention='7 days', encoding='utf-8')

# api配置
API_HOST = '0.0.0.0'
API_PORT = 7000
API_THREADED = True	# 是否开启多线程
```

如果用其他服务部署的话API配置可以不必计较，如何部署我们后边会讲。

接下来我们在**live_url_api.py**里面配置接口：

live_api = Blueprint('live_api', __name__)

# 响应模板
return_model = {'state': 0, 'data': None}

class LiveUrl(Resource):
    """
    直播流接口
    """

class LiveUrlDocs(Resource):
    """
    接口文档
    """
    def get(self):
        """
        获取接口文档
        :return:
        """
        return render_template('LiveUrlDocs.html')

live_api.add_url_rule(rule='/api-docs', view_func=LiveUrlDocs.as_view('api-docs'))
live_api.add_url_rule(rule='/get-url', view_func=LiveUrl.as_view('get-live-url'))
```

基类文件：

```python
# base.py
class Base(object):
    _name = 'Base'

def __init__(self):
        self.rid = ''

def get_real_url(self):
        return
```

读取所有继承类：

```python
# __init__.py
# -*- coding: utf-8 -*-
import pkgutil
from .base import Base
import inspect

然后将脚本文件统一继承基类，统一调用函数：

```python
# 2cq.py
# 棉花糖直播：https://www.2cq.com/rank

import requests

from scripts.base import Base

class MHT(Base):	# 继承基类

_name = '棉花糖'	# 定义名称，方便判断

def __init__(self, rid):
        super(Base, self).__init__()
        self.rid = rid

if __name__ == '__main__':
    r = input('输入棉花糖直播房间号：\n')
    print(MHT(r).get_real_url())
```

最后把判断调用的脚本写好就OK了：

```python
# live_api_routing.py
# -*- coding: utf-8 -*-
from loguru import logger

from scripts import __all__ as scripts_cls

class RunScripts:

if __name__ == '__main__':
    print(RunScripts('羚萌', '24003').choice())
```

## 如何部署

### 运行环境：

**python3.6及以上**

### 安装依赖

在项目路径下运行此命令

```shell
pip install -r rquirements.txt
```

### 服务部署

## 接口说明

### 接口地址

[http://api.pyduck.com/live-api/get-url](http://api.pyduck.com/live-api/get-url)

接口免费，服务器性能有限，勿压请爱惜。

### 接口文档请访问

[获取直播流接口文档](http://api.pyduck.com/live-api/api-docs)

## 项目说明

### 支持的直播平台

抖音虎牙斗鱼快手等多平台直播流地址获取服务

6 comments

Leave a Comment Cancel reply

抖音虎牙斗鱼快手等多平台直播流地址获取服务

pyinstaller——multiprocessing.freeze_support() 填坑

flask使用restful接口风格之-flask-restx的使用

MongoDB用户权限

HTTP响应状态码含义

MongoDB用户权限

智配store APP数据爬虫

supervisor教程

HTTP响应状态码含义

监控亚马逊商铺商品信息--scrapy框架

抖音虎牙斗鱼快手等多平台直播流地址获取服务