系统提供了音视频发声设备统一投播组件AVCastPicker,作为播控中心系统级设备切换、投播能力选择入口。应用通过接入统一投播组件,可以实现在应用内及系统播控中心,将音视频资源通过Cast+协议/DLNA协议投播到远端设备。
通过本开发指导,完成一次音视频跨设备投播。
当前设备发现和设备选择均为系统能力,由投播组件AVCastPicker集成,应用通过接入投播组件实现音视频投播能力。
需同时满足以下条件,才能使用该功能:
设备限制
本端设备:HarmonyOS 5.0.0及以上版本的手机或平板设备、HarmonyOS 6.0.0及以上版本的PC/2in1设备
远端设备:HarmonyOS 5.0.0及以上版本的PC/2in1设备、HarmonyOS 3.1及以上版本的TV设备、支持标准DLNA协议的设备
使用限制
在进行投播前,双端设备均需要在设置中打开蓝牙和WIFI,并确保设备可访问网络。
PC/2in1设备不支持发现PC/2in1设备。
在开发具体功能前,请先查阅参考文档,获取详细的接口说明。
AVCastPicker:投播组件,提供设备发现认证连接的统一入口。
AVCastController:投播控制器,用于投播场景下,完成播放控制、远端播放状态监听等操作。
AVCastController由系统获取并返回,在设备连接成功后获取,在设备断开后不能继续使用,否则会抛出异常。
支持在线DRM视频资源投播能力,需注册DRM许可证请求回调函数,获取许可证后,调用处理许可证响应函数。
| 接口类 | 接口 | 说明 |
|---|---|---|
| AVSession | setAVMetadata(data: AVMetadata, callback: AsyncCallback<void>): void | 配置媒体信息,包括ID、标题、作者以及DRM类型等。 |
| AVSession | on(type: 'outputDeviceChange', callback: (state: ConnectionState, device: OutputDeviceInfo) => void): void | 注册设备变化的回调,同时包含了设备的连接状态。 |
| AVSession | getAVCastController(callback: AsyncCallback<AVCastController>): void | 获取远端投播时的控制接口。 |
| AVCastController | sendControlCommand(command: AVCastControlCommand, callback: AsyncCallback<void>): void | 投播会话的控制接口,用于进行投播中的各种播控指令。 |
| AVCastController | prepare(item: AVQueueItem, callback: AsyncCallback<void>): void | 准备播放,进行资源加载和缓冲,不会触发真正的播放。 |
| AVCastController | start(item: AVQueueItem, callback: AsyncCallback<void>): void | 开始播放媒体资源。 |
| AVCastController | processMediaKeyResponse(assetId: string, response: Uint8Array): Promise<void> | 提供DRM资源所需的秘钥。 |
| AVCastController | on(type: 'keyRequest', callback: KeyRequestCallback): void | 注册DRM秘钥请求的回调。 |
| AVCastController | on(type: 'playbackStateChange', filter: Array<string> | 'all', callback: (state: AVPlaybackState) => void): void | 注册播放状态变化的回调。 |
| AVCastController | on(type: 'mediaItemChange', callback: Callback<AVQueueItem>): void | 注册当前播放内容更新的回调,返回当前播放的内容的信息。 |
创建播放器,并创建AVSession。
通过AVSessionManager创建并激活媒体会话。
示例中的context的获取方式请参见获取UIAbility的上下文信息。
import { avSession } from '@kit.AVSessionKit'; // 导入AVSession模块。
// 声明全局的session对象,此写法是加在class类外的声明,如果需要在class类内申明全局变量,需要去掉 export let。
export let session: avSession.AVSession;
// ...
@Entry
@Component
struct Index {
// ...
// 创建session
async createSession(context: common.UIAbilityContext) {
// 创建的AVSession在基础播控与投播场景可以共用。
session = await avSession.createAVSession(context, 'video_test', 'video'); // 'audio'代表音频应用,'video'代表视频应用
// ...
await session.activate();
// 请按照如下参数设置,告知系统应用当前支持投播,才能成功投播。
session.setExtras({
requireAbilityList: ['url-cast'],
});
console.info(`Session created. sessionId: ${session.sessionId}`);
}
// ...
} 设置媒体资源信息,注册基础播控回调,接入系统播控中心的基础播控。
接入投播组件前需要先适配媒体播控中心的基础播控业务,具体需要接入的内容请按照应用类型参考应用接入自检表。
应用可以通过filter字段设置需要发现和过滤的协议类型,来匹配应用期望的投播设备。
注意,投播后,应用播放器切换上下集时,若下一集不支持投播,可以通过filter参数控制系统播控中心是否显示可投播设备列表,filter参数设置为0,播控会识别当前媒体内容为不支持投播,隐藏可投播设备显示。避免用户从播控中心投播,应用资源不可用。
需要在AVCastPicker中仅显示支持DRM资源投播的设备时,应在AVMetadata设置明确的drmSchemes。
// 与session声明不在同一文件时,需要import。
import { avSession } from '@kit.AVSessionKit'; // 导入AVSession模块。
// 声明全局的session对象,此写法是加在class类外的声明,如果需要在class类内申明全局变量,需要去掉 export let。
export let session: avSession.AVSession;
// ...
@Entry
@Component
struct Index {
// ...
public setAVMetadata(playInfo: avSession.AVMediaDescription): Promise<void> {
const metadata: avSession.AVMetadata = {
assetId: playInfo.assetId, // 需要配置实际id。
title: playInfo.title, // 播放媒体资源的标题。
subtitle: playInfo.subtitle, // 播放媒体资源的副标题。
// 发现Cast+ Stream 和 DLNA协议设备,TYPE_CAST_PLUS_STREAM为默认必选。
filter: avSession.ProtocolType.TYPE_CAST_PLUS_STREAM | avSession.ProtocolType.TYPE_DLNA,
mediaImage: playInfo.mediaImage,
artist: playInfo.artist,
// 如果是DRM资源,配置支持的DRM uuid 用于设备过滤。非DRM资源不配置。
drmSchemes: ['3d5e6d35-9b9a-41e8-b843-dd3c6e72c42c']
};
return session.setAVMetadata(metadata);
}
public setSessionListener() {
// 请按照自检接入表按需注册并实现基础播控的控制指令,以下为举例。
session?.on('play', () => {
});
session?.on('pause', () => {
});
}
// ...
} 在需要投播的播放界面创建投播组件AVCastPicker。
若创建AVCastPicker后应用界面未显示,或点开Picker显示空白,请排查是否按步骤1、2接入了系统播控中心的基础播控,且正确设置了AVMetadata与Extras参数。
系统AVCastPicker提供CustomerPicker参数,应用可以通过该参数自定义Picker按钮的显示,具体开发请参考自定义样式。
使用投播组件AVCastPicker期间需要保证avsession对象不被后台销毁,否则可能会导致切换设备失败。
import { AVCastPickerState, AVCastPicker } from '@kit.AVSessionKit';
@Entry
@Component
export struct AVCastPickerComponent {
// 应用可以通过onStateChange接口监听组件显示/消失状态,
// 当组件显示时建议不要销毁AVCastPicker的显示;当组件消失时,再根据业务隐藏AVCastPicker。
private onStateChange(state: AVCastPickerState) {
if (state == AVCastPickerState.STATE_APPEARING) {
console.info('The picker starts showing.');
} else if (state == AVCastPickerState.STATE_DISAPPEARING) {
console.info('The picker finishes presenting.');
}
}
// 创建组件,并设置大小。
build() {
Row() {
Column() {
AVCastPicker({
normalColor: Color.Red,
onStateChange: this.onStateChange
})
.width('40vp')
.height('40vp')
.border({ width: 1, color: Color.Red })
}.height('50%')
}.width('50%')
}
} 注册AVSession投播控制回调。用于感知投播设备连接。
下面代码展示设备连接成功后的相应的处理
import { avSession } from '@kit.AVSessionKit';
import { BusinessError } from '@kit.BasicServicesKit';
// ...
/**
* Register the AVSession playback control callback.
* Used to detect the connection of playback devices.
* @param session: The AVSession to configure for casting.
*/
getAVCastController(session: avSession.AVSession) {
// 如支持投播,可使用下面接口监听设备连接状态的变化。
session.on('outputDeviceChange', async (connectState: avSession.ConnectionState,
device: avSession.OutputDeviceInfo) => {
// 可以通过当前设备及设备连接状态来更新应用内播放界面的显示。
let currentDevice: avSession.DeviceInfo = device?.devices?.[0];
if (currentDevice.castCategory === avSession.AVCastCategory.CATEGORY_REMOTE &&
connectState === avSession.ConnectionState.STATE_CONNECTED) { // 设备连接成功。
console.info(`Device connected: ${device}`);
this.castController = await session.getAVCastController();
console.info('Succeeded in getting a cast controller');
// 查询当前播放的状态。
let avPlaybackState = await this.castController?.getAVPlaybackState();
console.info(`Succeeded in AVPlaybackState resource obtained: ${avPlaybackState}`);
// 监听播放状态的变化。
this.castController?.on('playbackStateChange', 'all', (state: avSession.AVPlaybackState) => {
console.info(`Succeeded in Playback state changed: ${state}`);
});
// 根据currentDevice.supportedProtocols可以判断设备支持的协议类型,设备支持单个或多个协议类型
if (currentDevice.supportedProtocols === avSession.ProtocolType.TYPE_CAST_PLUS_STREAM) {
// 此设备支持cast+投播协议。
} else if (currentDevice.supportedProtocols === avSession.ProtocolType.TYPE_DLNA) {
// 此设备支持DLNA投播协议。
}
// 此设备支持chinaDRM,监听许可证请求事件,也可在发起DRM资源投播前监听。
if (currentDevice.supportedDrmCapabilities?.includes('3d5e6d35-9b9a-41e8-b843-dd3c6e72c42c')) {
this.castController?.on('keyRequest', this.keyRequestCallback);
}
}
})
}
// 处理DRM许可证请求事件。
private keyRequestCallback: avSession.KeyRequestCallback = async (assetId: string, requestData: Uint8Array) => {
// 根据assetId获取对应的DRM url。
let drmUrl: string = 'https://www.examples.com';
// 从服务器获取许可证,具体实现可参考附录。
let licenseResponseData = await this.getLicense.getLicense(drmUrl, requestData);
try {
// 处理DRM许可证响应。
await this.castController?.processMediaKeyResponse(assetId, licenseResponseData);
} catch (error) {
console.error(`Failed to process the response corresponding to the media key. Error: ${error}`);
}
} 使用AVCastController进行资源播放。
playItem() {
// 设置播放参数,开始播放。
let playItem : avSession.AVQueueItem = {
itemId: 0,
description: {
assetId: 'VIDEO-1',
title: 'ExampleTitle',
artist: 'ExampleArtist',
// 网络资源投播,设置mediaUri; 本地资源投播,将本地文件打开后,相关的文件描述符设置到fdSrc。
mediaUri: 'https://xxx.xxx.com/example.mp4',
// 该字段大写,音频'AUDIO',视频'VIDEO'。
mediaType: 'VIDEO',
mediaSize: 1000,
// startPosition为投播当前进度,设置该字段可将本机播放进度同步到远端。
startPosition: 0,
// 投播资源播放时长,设置该字段可将本机播放时长同步到远端显示。
duration: 100000,
albumCoverUri: 'https://www.examples.com',
albumTitle: '《ExampleAlbum》',
appName: 'ExampleApp',
// DRM资源,需要配置支持的DRM类型, 以chinaDRM为例。
drmScheme: '3d5e6d35-9b9a-41e8-b843-dd3c6e72c42c',
}
};
// 准备播放,这个不会触发真正的播放,会进行加载和缓冲。
this.avCastController?.prepare(playItem, () => {
console.info('Preparation done');
// 启动播放,真正触发对端播放。请在Prepare成功后再调用start。
this.avCastController?.start(playItem, () => {
console.info('Playback started');
});
});
} 使用AVCastController,监听控制命令和进行播放控制。
playControl() {
// 记录从avsession获取的远端控制器this.castController。
// 应用向对端设备下发播放命令。
let avCommand: avSession.AVCastControlCommand = {command:'play'};
this.avCastController?.sendControlCommand(avCommand);
// 应用向对端设备下发暂停命令。
avCommand = {command:'pause'};
this.avCastController?.sendControlCommand(avCommand);
// 应用调节对端设备音量。
avCommand = {
command: 'setVolume',
parameter: 1
};
this.avCastController?.sendControlCommand(avCommand);
// 应用调节对端设备进度。
avCommand = {
command: 'seek',
parameter: 1
};
this.avCastController?.sendControlCommand(avCommand);
// 更多控制指令请参考AVCastControlCommand。
}
controlListener() {
// 应用监听对端或播控中心上下一首/上下一集切换。
this.avCastController?.on('playPrevious', () => {
console.info('PlayPrevious done');
});
this.avCastController?.on('playNext', () => {
console.info('PlayNext done');
});
// 应用监听对端或播控中心播放状态、实时进度和音量变化事件。
this.avCastController?.on('playbackStateChange', 'all', (playbackState: avSession.AVPlaybackState)=>{
if (playbackState?.state) {
// 播放状态变化。
}
if (playbackState?.position) {
// 进度变化,可以根据position来获取对端播放的进度。
}
if (playbackState?.volume) {
// 音量变化。
}
});
// 应用监听对端投播内容播放完毕事件。应用监听到此回调,可以按照业务在以下三种选其一实现,否则无内容播放,对端出现黑屏。
// 1. 有下一集时,自动切换下一集投播,此时需要调用Prepare和start重新设置新的url,参考步骤5。
// 2. 无下一集时,建议循环播放同一集,重新调用prepare和start来设置当前新的url,参考步骤5。
// 3. 业务不再支持投播,可以主动断开投播,参考步骤9。
this.avCastController?.on('endOfStream', () => {
// 按业务处理。
});
// 应用监听对端或播控中心的进度调节完成事件,包括快进、快退、进度条拖拽完毕。
this.avCastController?.on('seekDone', (position: number) => {
// seekDone表示用户在对端或是播控内进度调节完毕,可以在收到该回调后,根据'playbackStateChange'回调的position刷新绘制应用内进度条。
// 应用主动调用seek调节对端进度后,也请等待seekDone回调再根据'playbackStateChange'中的position来刷新,更精准。
});
} 申请投播长时任务,避免应用在投播时进入后台时被系统冻结,导致无法持续投播。
在申请长时任务时,需要在module.json5文件中:
import { backgroundTaskManager } from '@kit.BackgroundTasksKit';
import { WantAgent, wantAgent } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';
// ...
async function startContinuousTask(context: Context) {
let wantAgentInfo: wantAgent.WantAgentInfo = {
// 点击通知后,将要执行的动作列表。
wants: [
{
bundleName: "com.example.myapplication",
abilityName: "EntryAbility",
}
],
// 点击通知后,动作类型。
actionType: wantAgent.OperationType.START_ABILITY,
// 使用者自定义的一个私有值。
requestCode: 0,
// 点击通知后,动作执行属性。
wantAgentFlags: [wantAgent.WantAgentFlags.UPDATE_PRESENT_FLAG]
};
// 通过wantAgent模块的getWantAgent方法获取WantAgent对象。
try {
wantAgent.getWantAgent(wantAgentInfo).then((wantAgentObj) => {
try {
backgroundTaskManager.startBackgroundRunning(context,
backgroundTaskManager.BackgroundMode.AUDIO_PLAYBACK, wantAgentObj).then(() => {
console.info('Succeeded in requesting to start running in background');
}).catch((error: BusinessError) => {
console.error(`Failed to request to start running in background. Code: ${error.code}, message: ${error.message}`);
});
} catch (error) {
console.error(`Failed to request to start running in background. Error: ${error}`);
}
});
} catch (error) {
console.error(`Failed to get WantAgent. Error: ${error}`);
}
} 投播后资源切换。
import { avSession } from '@kit.AVSessionKit'; // 导入AVSession模块。
// ...
getOutputDevice() {
session?.getOutputDevice().then((outputDeviceInfo: avSession.OutputDeviceInfo) => {
// 当前设备的castCategory为Remote,则表示正在投播中。
let isCasting = outputDeviceInfo.devices[0].castCategory === avSession.AVCastCategory.CATEGORY_REMOTE;
}).catch((err: BusinessError) => {
console.error(`GetOutputDevice BusinessError: code: ${err.code}, message: ${err.message}`);
});
} 情况一:如新的视频资源可以投播,有以下两种方式可处理:
方式一:直接调用prepare和start更换投播资源,参考步骤5。对端播放新的视频资源,本地显示切换为“正在投播的界面”,不需要断开投播重新投播。
方式二:不主动切换投播资源,正常绘制应用投播业务的按钮但不要创建AVCastPicker,用户点击后直接调用prepare和start更换投播资源,本地显示切换为“正在投播的界面”,不需要断开投播重新投播。
情况二:如此时不可以投播,当前视频就在本地播放,隐藏投播业务的按钮显示即可。
处理音频焦点。请参考多音频并发处理。
在应用进入投播后,当前应用需要取消注册焦点处理事件,以免被其他应用的焦点申请而影响。
结束投播。
async stopCasting() {
try {
await session.stopCasting();
// ...
} 适用场景:用户通过“无线投屏”功能实现手机等设备和大屏等的镜像投屏,然后打开视频应用进入视频播放,此时会自动切换为资源投播。要达到上述目标体验,还需要做一些额外的适配工作。
应用进入播放页后,需要调用getOutputDevicesync接口来判断当前是否存在投屏的设备,避免和其他应用冲突。
通过开发步骤第四步进行投播设备判断,如果存在投播设备,表示此时可以进行资源投播;否则表示没有可以投播的设备,或者系统当前虽然在镜像投屏,此时有别的APP在投播,此时应用应在本地播放。
应用正常投播后,仍然监听设备状态断开等场景,流程同投播组件开发步骤中的内容描述。
从服务器获取许可证
开发者需要根据实际的资源和服务地址获取DRM许可证,以下示例代码仅作为参考。
import { http } from '@kit.NetworkKit';
export class GetLicense {
// 获取DRM许可证, 仅做参考,需要结合实际资源和服务地址进行获取。
async getLicense(drmUrl: string, requestData: Uint8Array): Promise<Uint8Array | undefined> {
let licenseRequestStr: string = this.byteToString(requestData);
let licenseResponseStr: string = 'defaultStr';
let httpRequest = http.createHttp();
try {
let response: http.HttpResponse = await httpRequest.request(drmUrl, {
method: http.RequestMethod.POST,
header: {
'Content-Type': 'application/json',
'Accept-Encoding': 'gzip, deflate',
},
extraData: licenseRequestStr,
expectDataType: http.HttpDataType.STRING,
});
if (response?.responseCode == http.ResponseCode.OK) {
if (typeof response.result == 'string') {
licenseResponseStr = response.result;
}
}
httpRequest.destroy();
} catch (error) {
console.error(`Failed to request Http. Error: ${error}`);
return undefined;
}
return this.stringToByte(licenseResponseStr);
}
/**
* Uint8Array to string.
* @param arr Uint8Array.
* @returns string.
*/
byteToString(arr: Uint8Array): string {
let str: string = ''
let _arr: Uint8Array = arr
for (let i = 0; i < _arr.length; i++) {
// 将数值转为二进制字符串。
let binaryStr: string = _arr[i].toString(2)
let matchArray = binaryStr.match(new RegExp('/^1+?(?=0)/'))
if (matchArray && binaryStr.length == 8) {
let bytesLength: number = matchArray[0].length
let store: string = _arr[i].toString(2).slice(7 - bytesLength)
for (let j = 1; j < bytesLength; j++) {
store += _arr[j + i].toString(2).slice(2)
}
str += String.fromCharCode(Number.parseInt(store, 2))
i += bytesLength - 1
} else {
str += String.fromCharCode(_arr[i])
}
}
return str
}
/**
* string 转 Uint8Array。
* @param str string.
* @returns Uint8Array.
*/
stringToByte(str: string): Uint8Array {
let bytes: number[] = new Array();
let unicode: number
for (let i = 0; i < str.length; i++) {
unicode = str.charCodeAt(i)
if (unicode >= 0x010000 && unicode <= 0x10FFFF) {
bytes.push(((unicode >> 18) & 0x07) | 0xf0)
bytes.push(((unicode >> 12) & 0x3F) | 0x80)
bytes.push(((unicode >> 6) & 0x3F) | 0x80)
bytes.push((unicode & 0x3F) | 0x80)
} else if (unicode >= 0x000800 && unicode <= 0x00FFF) {
bytes.push(((unicode >> 12) & 0x07) | 0xf0)
bytes.push(((unicode >> 6) & 0x3F) | 0x80)
bytes.push((unicode & 0x3F) | 0x80)
} else if (unicode >= 0x000800 && unicode <= 0x0007FF) {
bytes.push(((unicode >> 6) & 0x3F) | 0x80)
bytes.push((unicode & 0x3F) | 0x80)
} else {
bytes.push(unicode & 0xFF)
}
}
return new Uint8Array(bytes);
}
}