MyHandler对'desc'消息的处理

2024-06-04 03:08
文章标签 处理 消息 desc myhandler

本文主要是介绍MyHandler对'desc'消息的处理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

            case 'desc':{//从消息msg里的"result"字段得到错误码的值int32_t result;CHECK(msg->findInt32("result", &result));ALOGI("DESCRIBE completed with result %d (%s)",result, strerror(-result));if (result == OK) {//如果result的值为OK,说明成功收到了服务端发送过来的应答消息//从消息msg的"response"字段获取服务端发送过来的应答消息对象responsesp<RefBase> obj;CHECK(msg->findObject("response", &obj));sp<ARTSPResponse> response =static_cast<ARTSPResponse *>(obj.get());if (response->mStatusCode == 301 || response->mStatusCode == 302) {//对从服务端发送过来的应答消息的状态码为301或者302的情况进行处理//本文不分析对301,301状态码的处理流程ssize_t i = response->mHeaders.indexOfKey("location");CHECK_GE(i, 0);mOriginalSessionURL = response->mHeaders.valueAt(i);mSessionURL = mOriginalSessionURL;// Strip any authentication info from the session url, we don't// want to transmit user/pass in cleartext.AString host, path, user, pass;unsigned port;if (ARTSPConnection::ParseURL(mSessionURL.c_str(), &host, &port, &path, &user, &pass)&& user.size() > 0) {mSessionURL.clear();mSessionURL.append("rtsp://");mSessionURL.append(host);mSessionURL.append(":");mSessionURL.append(AStringPrintf("%u", port));mSessionURL.append(path);ALOGI("rewritten session url: '%s'", mSessionURL.c_str());}sp<AMessage> reply = new AMessage('conn', this);mConn->connect(mOriginalSessionURL.c_str(), reply);break;}//代码执行到这里说明该从服务端发送过来的应答消息的//状态码不为301,302if (response->mStatusCode != 200) {//如果状态码不为200,将错误码UNKNOWN_ERROR赋值给resultresult = UNKNOWN_ERROR;} else if (response->mContent == NULL) {//代码执行到这里说明。状态码为200,//但是应答消息的内容为空,//则将错误码ERROR_MALFORMED赋值给resultresult = ERROR_MALFORMED;ALOGE("The response has no content.");} else {//代码执行到这里说明状态码为200//并且应答消息的内容也不为空//创建一个会话描述对象mSessionDesc = new ASessionDescription;//将应答消息的内容的缓冲区赋值给该会话描述对象mSessionDesc mSessionDesc->setTo(response->mContent->data(),response->mContent->size());if (!mSessionDesc->isValid()) {//如果mSessionDesc->isValid()的返回值是false//则说明该会话描述对象是无效的//将错误码ERROR_MALFORMED赋值给resultALOGE("Failed to parse session description.");result = ERROR_MALFORMED;} else {//代码执行到这里说明该会话描述对象是有效的//从应答消息对象response的mHeaders//成员变量获取key为"content-base"的值ssize_t i = response->mHeaders.indexOfKey("content-base");if (i >= 0) {//将获取到key为"content-base"的值赋值给mBaseURLmBaseURL = response->mHeaders.valueAt(i);} else {//代码执行到这里//说明i的值小于0,即不存在key为"content-base"的头部//则需要查询key为"content-location"的头部i = response->mHeaders.indexOfKey("content-location");if (i >= 0) {//将key为"content-location"头部的//内容赋值给mBaseURLmBaseURL = response->mHeaders.valueAt(i);} else {//代码执行到这里//说明在应答消息对象response里//即不存在key为"content-base"//也不存在key为"content-location"的头部//则将mSessionURL的值赋值给mBaseURLmBaseURL = mSessionURL;}}//判断该媒体是否能被seek//如果不为直播媒体流则可以被seekmSeekable = !isLiveStream(mSessionDesc);if (!mBaseURL.startsWith("rtsp://")) {//mBaseURL.startsWith("rtsp://")的值为fasle//说明服务端给出的是相对的url//需要将该相对url与绝对url合并在一起来定位媒体的位置// Some misbehaving servers specify a relative// URL in one of the locations above, combine// it with the absolute session URL to get// something usable...ALOGW("Server specified a non-absolute base URL"", combining it with the session URL to ""get something usable...");AString tmp;//合并相对url和绝对url//相对url是mBaseURL.c_str()//绝对url是mSessionURL.c_str()//具体是怎样的合并规则后续再研究介绍给大家CHECK(MakeURL(mSessionURL.c_str(),mBaseURL.c_str(),&tmp));mBaseURL = tmp;}//对于Control信息的处理//详细的处理过程后续介绍mControlURL = getControlURL();if (mSessionDesc->countTracks() < 2) {//如果会话描述的媒体的Tracks小于2//则将错误码ERROR_UNSUPPORTED赋值给result// There's no actual tracks in this session.// The first "track" is merely session meta// data.ALOGW("Session doesn't contain any playable ""tracks. Aborting.");result = ERROR_UNSUPPORTED;} else {//创建索引为1的tarcksetupTrack(1);}}}}if (result != OK) {//如果在上面过程中result的值不为OK//发送消息消息名为'disc'取消连接sp<AMessage> reply = new AMessage('disc', this);mConn->disconnect(reply);}break;}

  小结:MyHandler对’desc’消息的处理的主要工作就是创建一个会话对象。

这篇关于MyHandler对'desc'消息的处理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1028894

相关文章

Java中Springboot集成Kafka实现消息发送和接收功能

《Java中Springboot集成Kafka实现消息发送和接收功能》Kafka是一个高吞吐量的分布式发布-订阅消息系统,主要用于处理大规模数据流,它由生产者、消费者、主题、分区和代理等组件构成,Ka... 目录一、Kafka 简介二、Kafka 功能三、POM依赖四、配置文件五、生产者六、消费者一、Kaf

Go语言使用Buffer实现高性能处理字节和字符

《Go语言使用Buffer实现高性能处理字节和字符》在Go中,bytes.Buffer是一个非常高效的类型,用于处理字节数据的读写操作,本文将详细介绍一下如何使用Buffer实现高性能处理字节和... 目录1. bytes.Buffer 的基本用法1.1. 创建和初始化 Buffer1.2. 使用 Writ

Python视频处理库VidGear使用小结

《Python视频处理库VidGear使用小结》VidGear是一个高性能的Python视频处理库,本文主要介绍了Python视频处理库VidGear使用小结,文中通过示例代码介绍的非常详细,对大家的... 目录一、VidGear的安装二、VidGear的主要功能三、VidGear的使用示例四、VidGea

Python结合requests和Cheerio处理网页内容的操作步骤

《Python结合requests和Cheerio处理网页内容的操作步骤》Python因其简洁明了的语法和强大的库支持,成为了编写爬虫程序的首选语言之一,requests库是Python中用于发送HT... 目录一、前言二、环境搭建三、requests库的基本使用四、Cheerio库的基本使用五、结合req

使用Python处理CSV和Excel文件的操作方法

《使用Python处理CSV和Excel文件的操作方法》在数据分析、自动化和日常开发中,CSV和Excel文件是非常常见的数据存储格式,ython提供了强大的工具来读取、编辑和保存这两种文件,满足从基... 目录1. CSV 文件概述和处理方法1.1 CSV 文件格式的基本介绍1.2 使用 python 内

如何使用celery进行异步处理和定时任务(django)

《如何使用celery进行异步处理和定时任务(django)》文章介绍了Celery的基本概念、安装方法、如何使用Celery进行异步任务处理以及如何设置定时任务,通过Celery,可以在Web应用中... 目录一、celery的作用二、安装celery三、使用celery 异步执行任务四、使用celery

SpringBoot操作spark处理hdfs文件的操作方法

《SpringBoot操作spark处理hdfs文件的操作方法》本文介绍了如何使用SpringBoot操作Spark处理HDFS文件,包括导入依赖、配置Spark信息、编写Controller和Ser... 目录SpringBoot操作spark处理hdfs文件1、导入依赖2、配置spark信息3、cont

SpringBoot 自定义消息转换器使用详解

《SpringBoot自定义消息转换器使用详解》本文详细介绍了SpringBoot消息转换器的知识,并通过案例操作演示了如何进行自定义消息转换器的定制开发和使用,感兴趣的朋友一起看看吧... 目录一、前言二、SpringBoot 内容协商介绍2.1 什么是内容协商2.2 内容协商机制深入理解2.2.1 内容

MyBatis延迟加载的处理方案

《MyBatis延迟加载的处理方案》MyBatis支持延迟加载(LazyLoading),允许在需要数据时才从数据库加载,而不是在查询结果第一次返回时就立即加载所有数据,延迟加载的核心思想是,将关联对... 目录MyBATis如何处理延迟加载?延迟加载的原理1. 开启延迟加载2. 延迟加载的配置2.1 使用

Android WebView的加载超时处理方案

《AndroidWebView的加载超时处理方案》在Android开发中,WebView是一个常用的组件,用于在应用中嵌入网页,然而,当网络状况不佳或页面加载过慢时,用户可能会遇到加载超时的问题,本... 目录引言一、WebView加载超时的原因二、加载超时处理方案1. 使用Handler和Timer进行超