mirror of
https://github.com/ZLMediaKit/ZLMediaKit.git
synced 2024-11-23 19:20:53 +08:00
271 lines
7.8 KiB
C++
271 lines
7.8 KiB
C++
/*
|
||
* Copyright (c) 2016 The ZLMediaKit project authors. All Rights Reserved.
|
||
*
|
||
* This file is part of ZLMediaKit(https://github.com/xiongziliang/ZLMediaKit).
|
||
*
|
||
* Use of this source code is governed by MIT license that can be found in the
|
||
* LICENSE file in the root of the source tree. All contributing project authors
|
||
* may be found in the AUTHORS file in the root of the source tree.
|
||
*/
|
||
|
||
#ifndef ZLMEDIAKIT_MEDIASOURCE_H
|
||
#define ZLMEDIAKIT_MEDIASOURCE_H
|
||
|
||
#include <mutex>
|
||
#include <string>
|
||
#include <memory>
|
||
#include <functional>
|
||
#include <unordered_map>
|
||
#include "Common/config.h"
|
||
#include "Common/Parser.h"
|
||
#include "Util/logger.h"
|
||
#include "Util/TimeTicker.h"
|
||
#include "Util/NoticeCenter.h"
|
||
#include "Util/List.h"
|
||
#include "Rtsp/Rtsp.h"
|
||
#include "Rtmp/Rtmp.h"
|
||
#include "Extension/Track.h"
|
||
#include "Record/Recorder.h"
|
||
|
||
using namespace std;
|
||
using namespace toolkit;
|
||
|
||
namespace toolkit{
|
||
class TcpSession;
|
||
}// namespace toolkit
|
||
|
||
namespace mediakit {
|
||
|
||
class MediaSource;
|
||
class MediaSourceEvent{
|
||
public:
|
||
friend class MediaSource;
|
||
MediaSourceEvent(){};
|
||
virtual ~MediaSourceEvent(){};
|
||
|
||
// 通知拖动进度条
|
||
virtual bool seekTo(MediaSource &sender,uint32_t ui32Stamp){ return false; }
|
||
// 通知其停止推流
|
||
virtual bool close(MediaSource &sender,bool force) { return false;}
|
||
// 观看总人数
|
||
virtual int totalReaderCount(MediaSource &sender) = 0;
|
||
// 开启或关闭录制
|
||
virtual bool setupRecord(MediaSource &sender, Recorder::type type, bool start, const string &custom_path) { return false; };
|
||
// 获取录制状态
|
||
virtual bool isRecording(MediaSource &sender, Recorder::type type) { return false; };
|
||
private:
|
||
// 通知无人观看
|
||
void onNoneReader(MediaSource &sender);
|
||
private:
|
||
Timer::Ptr _async_close_timer;
|
||
};
|
||
|
||
/**
|
||
* 解析url获取媒体相关信息
|
||
*/
|
||
class MediaInfo{
|
||
public:
|
||
MediaInfo(){}
|
||
~MediaInfo(){}
|
||
MediaInfo(const string &url){ parse(url); }
|
||
void parse(const string &url);
|
||
public:
|
||
string _schema;
|
||
string _host;
|
||
string _port;
|
||
string _vhost;
|
||
string _app;
|
||
string _streamid;
|
||
string _param_strs;
|
||
};
|
||
|
||
/**
|
||
* 媒体源，任何rtsp/rtmp的直播流都源自该对象
|
||
*/
|
||
class MediaSource: public TrackSource, public enable_shared_from_this<MediaSource> {
|
||
public:
|
||
typedef std::shared_ptr<MediaSource> Ptr;
|
||
typedef unordered_map<string, weak_ptr<MediaSource> > StreamMap;
|
||
typedef unordered_map<string, StreamMap > AppStreamMap;
|
||
typedef unordered_map<string, AppStreamMap > VhostAppStreamMap;
|
||
typedef unordered_map<string, VhostAppStreamMap > SchemaVhostAppStreamMap;
|
||
|
||
MediaSource(const string &strSchema, const string &strVhost, const string &strApp, const string &strId) ;
|
||
virtual ~MediaSource() ;
|
||
|
||
// 获取协议类型
|
||
const string& getSchema() const;
|
||
// 虚拟主机
|
||
const string& getVhost() const;
|
||
// 应用名
|
||
const string& getApp() const;
|
||
// 流id
|
||
const string& getId() const;
|
||
|
||
// 设置TrackSource
|
||
void setTrackSource(const std::weak_ptr<TrackSource> &track_src);
|
||
// 获取所有Track
|
||
vector<Track::Ptr> getTracks(bool trackReady = true) const override;
|
||
|
||
// 设置监听者
|
||
virtual void setListener(const std::weak_ptr<MediaSourceEvent> &listener);
|
||
// 获取监听者
|
||
const std::weak_ptr<MediaSourceEvent>& getListener() const;
|
||
|
||
// 本协议获取观看者个数，可能返回本协议的观看人数，也可能返回总人数
|
||
virtual int readerCount() = 0;
|
||
// 观看者个数，包括(hls/rtsp/rtmp)
|
||
virtual int totalReaderCount();
|
||
|
||
// 获取流当前时间戳
|
||
virtual uint32_t getTimeStamp(TrackType trackType) { return 0; };
|
||
// 设置时间戳
|
||
virtual void setTimeStamp(uint32_t uiStamp) {};
|
||
|
||
// 拖动进度条
|
||
bool seekTo(uint32_t ui32Stamp);
|
||
// 关闭该流
|
||
bool close(bool force);
|
||
// 该流无人观看
|
||
void onNoneReader();
|
||
// 开启或关闭录制
|
||
virtual bool setupRecord(Recorder::type type, bool start, const string &custom_path);
|
||
// 获取录制状态
|
||
virtual bool isRecording(Recorder::type type);
|
||
|
||
// 同步查找流
|
||
static Ptr find(const string &schema, const string &vhost, const string &app, const string &id);
|
||
// 异步查找流
|
||
static void findAsync(const MediaInfo &info, const std::shared_ptr<TcpSession> &session, const function<void(const Ptr &src)> &cb);
|
||
// 遍历所有流
|
||
static void for_each_media(const function<void(const Ptr &src)> &cb);
|
||
|
||
// 从mp4文件生成MediaSource
|
||
static MediaSource::Ptr createFromMP4(const string &schema, const string &vhost, const string &app, const string &stream, const string &filePath = "", bool checkApp = true);
|
||
|
||
protected:
|
||
void regist() ;
|
||
bool unregist();
|
||
|
||
private:
|
||
static Ptr find_l(const string &schema, const string &vhost, const string &app, const string &id, bool bMake);
|
||
static void findAsync_l(const MediaInfo &info, const std::shared_ptr<TcpSession> &session, bool retry, const function<void(const MediaSource::Ptr &src)> &cb);
|
||
private:
|
||
string _strSchema;
|
||
string _strVhost;
|
||
string _strApp;
|
||
string _strId;
|
||
std::weak_ptr<MediaSourceEvent> _listener;
|
||
weak_ptr<TrackSource> _track_source;
|
||
static SchemaVhostAppStreamMap g_mapMediaSrc;
|
||
static recursive_mutex g_mtxMediaSrc;
|
||
};
|
||
|
||
///缓存刷新策略类
|
||
class FlushPolicy {
|
||
public:
|
||
FlushPolicy(bool is_audio) {
|
||
_is_audio = is_audio;
|
||
};
|
||
|
||
~FlushPolicy() = default;
|
||
|
||
uint32_t getStamp(const RtpPacket::Ptr &packet) {
|
||
return packet->timeStamp;
|
||
}
|
||
|
||
uint32_t getStamp(const RtmpPacket::Ptr &packet) {
|
||
return packet->timeStamp;
|
||
}
|
||
|
||
bool isFlushAble(uint32_t new_stamp, int cache_size);
|
||
private:
|
||
bool _is_audio;
|
||
uint32_t _last_stamp= 0;
|
||
};
|
||
|
||
/// 视频合并写缓存模板
|
||
/// \tparam packet 包类型
|
||
/// \tparam policy 刷新缓存策略
|
||
/// \tparam packet_list 包缓存类型
|
||
template<typename packet, typename policy = FlushPolicy, typename packet_list = List<std::shared_ptr<packet> > >
|
||
class VideoPacketCache {
|
||
public:
|
||
VideoPacketCache() : _policy(false) {
|
||
_cache = std::make_shared<packet_list>();
|
||
}
|
||
|
||
virtual ~VideoPacketCache() = default;
|
||
|
||
void inputVideo(const std::shared_ptr<packet> &rtp, bool key_pos) {
|
||
if (_policy.isFlushAble(_policy.getStamp(rtp), _cache->size())) {
|
||
flushAll();
|
||
}
|
||
|
||
//追加数据到最后
|
||
_cache->emplace_back(rtp);
|
||
if (key_pos) {
|
||
_key_pos = key_pos;
|
||
}
|
||
}
|
||
|
||
virtual void onFlushVideo(std::shared_ptr<packet_list> &, bool key_pos) = 0;
|
||
|
||
private:
|
||
void flushAll() {
|
||
if (_cache->empty()) {
|
||
return;
|
||
}
|
||
onFlushVideo(_cache, _key_pos);
|
||
_cache = std::make_shared<packet_list>();
|
||
_key_pos = false;
|
||
}
|
||
|
||
private:
|
||
policy _policy;
|
||
std::shared_ptr<packet_list> _cache;
|
||
bool _key_pos = false;
|
||
};
|
||
|
||
/// 音频频合并写缓存模板
|
||
/// \tparam packet 包类型
|
||
/// \tparam policy 刷新缓存策略
|
||
/// \tparam packet_list 包缓存类型
|
||
template<typename packet, typename policy = FlushPolicy, typename packet_list = List<std::shared_ptr<packet> > >
|
||
class AudioPacketCache {
|
||
public:
|
||
AudioPacketCache() : _policy(true) {
|
||
_cache = std::make_shared<packet_list>();
|
||
}
|
||
|
||
virtual ~AudioPacketCache() = default;
|
||
|
||
void inputAudio(const std::shared_ptr<packet> &rtp) {
|
||
if (_policy.isFlushAble(_policy.getStamp(rtp), _cache->size())) {
|
||
flushAll();
|
||
}
|
||
//追加数据到最后
|
||
_cache->emplace_back(rtp);
|
||
}
|
||
|
||
virtual void onFlushAudio(std::shared_ptr<packet_list> &) = 0;
|
||
|
||
private:
|
||
void flushAll() {
|
||
if (_cache->empty()) {
|
||
return;
|
||
}
|
||
onFlushAudio(_cache);
|
||
_cache = std::make_shared<packet_list>();
|
||
}
|
||
|
||
private:
|
||
policy _policy;
|
||
std::shared_ptr<packet_list> _cache;
|
||
};
|
||
|
||
} /* namespace mediakit */
|
||
|
||
|
||
#endif //ZLMEDIAKIT_MEDIASOURCE_H
|