mirror of
https://github.com/ZLMediaKit/ZLMediaKit.git
synced 2026-01-12 00:04:03 +08:00
93 lines
2.8 KiB
C++
Executable File
93 lines
2.8 KiB
C++
Executable File
/*
|
||
* Copyright (c) 2016-present The ZLMediaKit project authors. All Rights Reserved.
|
||
*
|
||
* This file is part of ZLMediaKit(https://github.com/ZLMediaKit/ZLMediaKit).
|
||
*
|
||
* Use of this source code is governed by MIT-like 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_WEBRTC_CLIENT_H
|
||
#define ZLMEDIAKIT_WEBRTC_CLIENT_H
|
||
|
||
#include "Http/HttpRequester.h"
|
||
#include "Sdp.h"
|
||
#include "WebRtcTransport.h"
|
||
#include "WebRtcSignalingPeer.h"
|
||
#include <memory>
|
||
#include <string>
|
||
|
||
namespace mediakit {
|
||
|
||
// 解析webrtc 信令url的工具类
|
||
class WebRTCUrl {
|
||
public:
|
||
bool _is_ssl;
|
||
std::string _full_url;
|
||
std::string _negotiate_url; // for whep or whip
|
||
std::string _delete_url; // for whep or whip
|
||
std::string _target_secret;
|
||
std::string _params;
|
||
std::string _host;
|
||
uint16_t _port;
|
||
std::string _vhost;
|
||
std::string _app;
|
||
std::string _stream;
|
||
WebRtcTransport::SignalingProtocols _signaling_protocols = WebRtcTransport::SignalingProtocols::WHEP_WHIP;
|
||
std::string _peer_room_id; // peer room_id
|
||
|
||
public:
|
||
void parse(const std::string &url, bool isPlayer);
|
||
|
||
private:
|
||
};
|
||
|
||
// 实现了webrtc代理功能
|
||
class WebRtcClient : public std::enable_shared_from_this<WebRtcClient> {
|
||
public:
|
||
using Ptr = std::shared_ptr<WebRtcClient>;
|
||
|
||
WebRtcClient(toolkit::EventPoller::Ptr poller);
|
||
virtual ~WebRtcClient();
|
||
|
||
const toolkit::EventPoller::Ptr &getPoller() const { return _poller; }
|
||
void setPoller(toolkit::EventPoller::Ptr poller) { _poller = std::move(poller); }
|
||
|
||
// 获取WebRTC transport，用于API查询
|
||
const WebRtcTransport::Ptr &getWebRtcTransport() const { return _transport; }
|
||
|
||
protected:
|
||
virtual bool isPlayer() = 0;
|
||
virtual void startConnect();
|
||
virtual void onResult(const toolkit::SockException &ex) = 0;
|
||
virtual void onNegotiateFinish();
|
||
virtual float getTimeOutSec();
|
||
|
||
void doNegotiate();
|
||
void doNegotiateWebsocket();
|
||
void doNegotiateWhepOrWhip();
|
||
void checkIn();
|
||
void doBye();
|
||
void doByeWhepOrWhip();
|
||
void checkOut();
|
||
|
||
void gatheringCandidate(IceServerInfo::Ptr ice_server);
|
||
void connectivityCheck();
|
||
void candidate(const std::string &candidate, const std::string &ufrag, const std::string &pwd);
|
||
|
||
protected:
|
||
toolkit::EventPoller::Ptr _poller;
|
||
|
||
// for _negotiate_sdp
|
||
WebRTCUrl _url;
|
||
HttpRequester::Ptr _negotiate = nullptr;
|
||
WebRtcSignalingPeer::Ptr _peer = nullptr;
|
||
WebRtcTransport::Ptr _transport = nullptr;
|
||
bool _is_negotiate_finished = false;
|
||
|
||
};
|
||
|
||
} /*namespace mediakit */
|
||
#endif /* ZLMEDIAKIT_WEBRTC_CLIENT_H */
|