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

相关文章

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque

使用C++将处理后的信号保存为PNG和TIFF格式

《使用C++将处理后的信号保存为PNG和TIFF格式》在信号处理领域,我们常常需要将处理结果以图像的形式保存下来,方便后续分析和展示,C++提供了多种库来处理图像数据,本文将介绍如何使用stb_ima... 目录1. PNG格式保存使用stb_imagephp_write库1.1 安装和包含库1.2 代码解

C#使用DeepSeek API实现自然语言处理,文本分类和情感分析

《C#使用DeepSeekAPI实现自然语言处理,文本分类和情感分析》在C#中使用DeepSeekAPI可以实现多种功能,例如自然语言处理、文本分类、情感分析等,本文主要为大家介绍了具体实现步骤,... 目录准备工作文本生成文本分类问答系统代码生成翻译功能文本摘要文本校对图像描述生成总结在C#中使用Deep

Spring Boot 整合 ShedLock 处理定时任务重复执行的问题小结

《SpringBoot整合ShedLock处理定时任务重复执行的问题小结》ShedLock是解决分布式系统中定时任务重复执行问题的Java库,通过在数据库中加锁,确保只有一个节点在指定时间执行... 目录前言什么是 ShedLock?ShedLock 的工作原理:定时任务重复执行China编程的问题使用 Shed

解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

《解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)》该文章介绍了使用Redis的阻塞队列和Stream流的消息队列来优化秒杀系统的方案,通过将秒杀流程拆分为两条流水线,使用Redi... 目录Redis秒杀优化方案(阻塞队列+Stream流的消息队列)什么是消息队列?消费者组的工作方式每

使用C/C++调用libcurl调试消息的方式

《使用C/C++调用libcurl调试消息的方式》在使用C/C++调用libcurl进行HTTP请求时,有时我们需要查看请求的/应答消息的内容(包括请求头和请求体)以方便调试,libcurl提供了多种... 目录1. libcurl 调试工具简介2. 输出请求消息使用 CURLOPT_VERBOSE使用 C

Redis如何使用zset处理排行榜和计数问题

《Redis如何使用zset处理排行榜和计数问题》Redis的ZSET数据结构非常适合处理排行榜和计数问题,它可以在高并发的点赞业务中高效地管理点赞的排名,并且由于ZSET的排序特性,可以轻松实现根据... 目录Redis使用zset处理排行榜和计数业务逻辑ZSET 数据结构优化高并发的点赞操作ZSET 结

微服务架构之使用RabbitMQ进行异步处理方式

《微服务架构之使用RabbitMQ进行异步处理方式》本文介绍了RabbitMQ的基本概念、异步调用处理逻辑、RabbitMQ的基本使用方法以及在SpringBoot项目中使用RabbitMQ解决高并发... 目录一.什么是RabbitMQ?二.异步调用处理逻辑:三.RabbitMQ的基本使用1.安装2.架构

一文详解Python中数据清洗与处理的常用方法

《一文详解Python中数据清洗与处理的常用方法》在数据处理与分析过程中,缺失值、重复值、异常值等问题是常见的挑战,本文总结了多种数据清洗与处理方法,文中的示例代码简洁易懂,有需要的小伙伴可以参考下... 目录缺失值处理重复值处理异常值处理数据类型转换文本清洗数据分组统计数据分箱数据标准化在数据处理与分析过

mysql外键创建不成功/失效如何处理

《mysql外键创建不成功/失效如何处理》文章介绍了在MySQL5.5.40版本中,创建带有外键约束的`stu`和`grade`表时遇到的问题,发现`grade`表的`id`字段没有随着`studen... 当前mysql版本:SELECT VERSION();结果为:5.5.40。在复习mysql外键约