title: 亚马逊AWS Kinesis Video Streams with WebRTC demo示例
categories:[Linux C]
tags:[亚马逊云平台]
date: 2021/12/22
以下分步说明介绍如何使用下载、构建和运行 Kinesis Video Streams with WebRTC 开发工具包及其相应示例。
运行以下命令:
git clone --recursive https://github.com/awslabs/amazon-kinesis-video-streams-webrtc-sdk-c.git
完成以下步骤:
安装 cmake:
brew install cmake pkg-config srtp
sudo apt-get install pkg-config cmake libcap2 libcap-dev
获取您要用于本演示的 AWS 账户的访问密钥和秘密密钥。
运行以下命令在您下载的 WebRTC C 开发工具包中创建一个 build
目录,并从中执行 cmake
:
mkdir -p amazon-kinesis-video-streams-webrtc-sdk-c/build
cd amazon-kinesis-video-streams-webrtc-sdk-c/build
cmake .. // 这里cmake的时候有可能会失败,被墙了,最好自备梯子
现在,您已经在build
目录中您刚刚使用上面的步骤创建,运行make
构建 WebRTC C 开发工具包及其提供的示例。
注意:
这些区域有:kvsWebrtcClientMasterGstSample
将不会构建,如果系统没有gstreamer
安装。要确保它已构建(在 macOS 上),您必须运行:brew install gstreamer gst-plugins-base gst-plugins-good
在完成第2步之后,会在build目录中生成以下demo应用程序:
kvsWebrtcClientMaster
- 此应用程序通过信令通道发送示例 H264/Opus 帧(路径:/samples/h264SampleFrames 和 /samples/opusSampleFrames)。它也接受传入的音频(如果在浏览器中启用)。在浏览器中勾选时,它会打印终端中收到的音频数据包的元数据。kvsWebrtcClientViewer
- 此应用程序接受示例 H264/Opus 帧并打印出来。kvsWebrtcClientMasterGstSample
- 此应用程序从 GStreamer 管道发送示例 H264/Opus 帧。要运行这些demo应用程序,要完成以下步骤:
使用 AWS 账户凭证设置您的环境:(AWS账户凭证需要自己从账户中获取)
export AWS_ACCESS_KEY_ID= <Your AWS account access Key>
export AWS_SECRET_ACCESS_KEY= <AWS account secret key>
export AWS_KVS_CACERT_PATH= <Full path of your cert.pem file. It is typically available in the certs directory inside
Kinesis-video-webrtc-native-build/certs/cert.pm>
通过将您要向信令通道提供的名称传递给示例应用程序来运行任一应用程序。应用程序使用您提供的名称创建信令通道。例如,要创建一个名为 myChannel
的信令通道并开始通过该通道发送示例 H264/Opus 帧,请运行以下命令:
./kvsWebrtcClientMaster myChannel
当命令行应用程序打印 Connection established
时,您可以继续下一步。
现在您的信令通道已创建,并且连接的主设备正在将媒体流式传输到它,您可以查看此流。例如,您可以在 Web 应用程序中查看此实时流。为此,请使用使用 Kinesis Video Streams with WebRTC 测试页面 中的步骤打开 WebRTC 开发工具包测试页面,并使用您为上述主设备指定的相同 AWS 凭证和相同信令通道设置以下值:
选择 Start viewer (启动查看器) 以启动示例 H264/Opus 帧的实时视频流式传输。
可以选择在网页上/集成了WebRTC的Android、iOS APP查看此流。
一个信令通道只能有一个主设备
一个信令通道最多可以有 10 个连接的查看器
建立连接后的数据交互:
VOID onDataChannelMessage(UINT64 customData, PRtcDataChannel pDataChannel, BOOL isBinary, PBYTE pMessage, UINT32 pMessageLen){ //连接
UNUSED_PARAM(customData);
UNUSED_PARAM(pDataChannel);
char *pTopicName = NULL,*pStrAnswer = NULL;
uint32_t nAnswerLen = 0;
if (isBinary) {
DLOGI("DataChannel Binary Message");
} else {
DLOGI("DataChannel String Message: %.*s\n", pMessageLen, pMessage);
}
printf("DataChannel String Message: %s \n MessageLen = %d\n", pMessage ,pMessageLen);
dataChannelSend(pDataChannel,isBinary,pStrAnswer,nAnswerLen); // 发送数据回去
}
VOID onDataChannel(UINT64 customData, PRtcDataChannel pRtcDataChannel){
DLOGI("New DataChannel has been opened %s \n", pRtcDataChannel->name);
printf("pRtcDataChannel->name : %s\n", pRtcDataChannel->name);
dataChannelOnMessage(pRtcDataChannel, customData, onDataChannelMessage); // 接收到数据的回调函数
}
如果你觉得文章还不错,可以给个"三连",文章同步到个人微信公众号[加班猿]
我是hackett,我们下期见