主界面获取个人信息客户端方

news2024/11/17 8:59:32

主界面获取个人信息客户端方

前言

上一集我们完成了websocket身份验证的内容,那么这一集开始我们将要配合MockServer来完成主界面获取个人信息的内容。

需求分析

我们这边是完成客户端那方的内容,当客户端登录成功之后,我们就要从服务器获取到当前登录用户的基本信息。包括头像、昵称、id、电话、个性签名等。其中,我们的头像是要直接显示在我们的主界面上的。如下图:

对应proto文件

我们之前规定了这些前后端交互的接口的URL,所以我们就要去翻一下我们的proto文件。

我们先来看到我们的路径!!!

这就是我们的前后端交互接口的URL。

我们再来看到我们网络传输的请求和响应的proto文件。

这两个分别对应的是我们请求和响应的body。请求和响应我们都需要使用protobuf进行序列化

这里我们也是需要规定一下以下内容。

客户端和网关服务器进行通信的时候,需要填充sessionId属性,而不需要填充userId的属性,我们这里的这个规定是为了确认用户的身份信息,用于鉴权。

网关服务器和其他服务器进行通信的时候,我们就不需要填充sessionId属性,而一定要有userId属性。

getMyselfAsync

我们可以看到上面proto定义的内容,我们构造的请求里面需要有请求id,用户id以及会话id,这里我们需要传入DataCenter里保存的loginSessionId这个内容,请求id我们需要到NetClient中获取,这里的用户id我们是不需要传入的!

所以我们要在DataCenter当中添加以下方法

    //通过网络获取用户个人信息(异步)
    void getMyselfAsync();

看到这个函数的名称的末尾,我们就可以补充一个知识点:

同步与异步

async我们称之为异步,Sync称之为同步。

就举个例子解释一下。我们发送请求的时候,请求到返回一个响应的中间都是需要时间的。


我们的异步就是发送请求,就可以做其他的事情了,不会一直阻塞等待这个响应回来。

我们的同步就是与异步相反,我们发送请求后,我们需要阻塞去等这个响应回来接收到。


那么我们在代码中就不期望使用同步的方式来完成我们的功能,我们需要获取我们的个人信息的功能只要触发了,就能做其他事情去了,这个个人信息等他自己程序自己在另一个载体进行处理。


那么这个载体或者说接力棒,我们就可以很容易想到我们的信号槽。我们的程序的流程就是发送一个请求,把接力棒给到我们的信号槽,当响应回来了就触发我们的信号槽的信号,之后就针对响应的处理放到我们的槽函数。那样我们就不会在程序上卡住停滞不前了。


由于我们还需要进一步进行构造请求id,那么我们就要将loginSessionId这个参数带入到我们的NetClient,那么我们就继续创建一个方法在NetClient当中,接收我们的loginSessionId。那么我们先完成getMyselfAsync方法。

void DataCenter::getMyselfAsync()
{
    //这里注意!DataCenter只是处理数据,进行网络通信的是NetClient
    netClient.getMyself(loginSessionId);
}

其实就是给NetClient传入loginSessionId这个信息。

NetClient::getMyself

那么进一步我们就要去完成网络通信部分的getMyself的方法。

我们的这个方法一共三个步骤

构造http的body部分、构造http请求,信号槽处理响应。

构造http的body

这一个部分是不同的请求需要构造的成员都不一样,所以我们就不能封装成一个函数来构造http的body,那么就只能按照proto文件一步一步来构造。

//构造http的body部分
    bite_im::GetUserInfoReq req;
    req.setRequestId(makeRequestId()); 
    req.setSessionId(loginSessionId);
    QByteArray body = req.serialize(&serializer);
    LOG() << "[获取个人信息] 发送请求 requestId=" << req.requestId() << ", loginSessionId=" << loginSessionId;

这里我们需要body弄成二进制文件才能在网络上正常的传输。这个序列化器我们的NetClient里面也有,可以直接用上。

构造http请求

这一个部分就基本都是一个通用的操作了,我们就封装一个方法来实现吧。

我们先来看一下我们请求的一个格式

这个看上去还是十分的简单的。我们需要设置的就是我们是需要使用post方法,以及这个请求的路径,之后是content-type。当然我们最后要用一个QNetworkReply进行接收响应,并且返回这个响应的变量。

我们这里还是看到那个URL

由于我们的发送的不同的请求的内容只有URL和body是不同的,那么我们就要从getMyself那里传入我们需要发送的请求路径以及构造好的请求body即可。

QNetworkReply *NetClient::sendHttpRequest(const QString &apiPath, const QByteArray &body)
{
    QNetworkRequest httpReq;
    httpReq.setUrl(QUrl(HTTP_URL + apiPath));
    httpReq.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-protobuf");

    QNetworkReply* httpResp = httpClient.post(httpReq,body);
    return httpResp;
}

信号槽处理响应

那么到这里,我们就已经把请求发送出去了,那么我们是要把接力棒交给我们的信号槽,我们就能让这个程序异步处理我们的请求了。

处理响应之前,我们要等到响应回来我们才能正式处理响应,所以我们的信号就是这个响应是finished的状态就可以开始我们的处理。

那么我们处理响应的时候是需要先判断我们的响应的业务上是否出错,HTTP上是否有出错。

如果我们的响应没有错误,我们就可以根据不同的响应做出不同的处理了。我们这里的需要把获取到的个人信息给我们保存到DataCenter当中,毕竟我们一开始在DataCenter里面我们的这个内容是nullptr的!


那么处理我们的业务上的逻辑是否出错我们也可以封装成一个方法。

但是这个函数需要能够处理不同的返回结果的对象,所以我们就要引入我们的模板,我们要去使用泛型编程。

返回值方面,我们虽然可以使用直接使用T来返回,但是!拷贝的开销是很大的。那么我们可以引入智能指针,在函数的内部,通过new的方式创建出对象,并返回指针,为了让这个对象能够在合适的时机进行释放,我们选用智能指针就是最好的办法!

那么判断这个业务逻辑是否有问题,我们就传入这个http的响应以及传入两个指针,一个ok用于判定是否有问题,一个reason用于接收错误原因。

 connect(httpResp, &QNetworkReply::finished, this, [=](){
        //返回值能获取一个反序列好的对象,并且判定业务上正确的
        bool ok = true;
        QString reason;
        auto resp = handleHttpResponse<bite_im::GetUserInfoRsp>(httpResp, &ok, &reason);

        if(!ok){
            LOG() << "[获取个人信息] 出错!requestId=" << req.requestId() <<"reason=" << reason;
            return;
        }
}

那么我们就要进去完成我们的handleHttpResponse的内容。

handleHttpResponse

我们这个函数要先判断http是否出错,我们就要去看是否NoError

之后返回一个空的智能指针即可。要记得delete以下我们的响应对象。

之后就要获取我们响应的body,之后进行反序列化

    template <typename T>
    std::shared_ptr<T> handleHttpResponse(QNetworkReply* httpResp, bool* ok, QString* reason){
        //判定http是否出错
        if(httpResp->error() != QNetworkReply::NoError){
            *ok = false;
            *reason = httpResp->errorString();
            httpResp->deleteLater();
            return std::shared_ptr<T>();
        }

        //获取响应body
        QByteArray respBody = httpResp->readAll();

        //body反序列化
        std::shared_ptr<T> respObj = std::make_shared<T>();
        respObj->deserialize(&serializer, respBody);

        //判定业务上的逻辑
        if(!respObj->success()){
            *ok = false;
            *reason = respObj->errmsg();
            httpResp->deleteLater();
            return std::shared_ptr<T>();
        }

        //释放对象
        httpResp->deleteLater();

        return respObj;

    }

我们反序列化后能够得到以下的内容

我们就可以知道我们的业务逻辑是否是成功的,如果成功了我们就可以直接返回我们的respObj了,我们接收就可以在外面接收我们的respObj了。里面就包含了我们的userInfo!当然一定要记得我们的响应是已经使用完了,不需要他了,我们就要手动给他延迟delete!


C++模板

我们先不回到信号槽的代码!我们来谈一谈C++模板的问题

在C++中,模板的使用确实有一些特殊的考虑,特别是关于模板的声明和定义。你提到的“分离编译模型必须把声明和定义写在一起,不能分开写”的问题,实际上是由于C++模板的编译机制导致的。

模板的编译机制

C++模板是一种在编译时进行处理的泛型编程工具。编译器需要在编译时看到模板的完整定义,以便对模板进行实例化。这意味着,如果你只在头文件中声明模板而不提供定义,那么在其他.cpp文件中使用这个模板时,编译器将无法找到模板的定义,从而导致编译错误。

所以我们上面的那个函数就需要放到我们的头文件当中!


我们回到我们的信号槽部分,接下来我们就剩下把respObj里面的userInfo给放到我们的DataCenter当中。

也是十分的简单,请看下面的代码

我们一开始给myself就是一个nullptr,我们需要new一个新对象出来,再把userInfo给到我们的myself即可,这里也用到我们之前使用的load方法。

void DataCenter::resetMyself(std::shared_ptr<bite_im::GetUserInfoRsp> resp)
{
    if(myself == nullptr){
        myself = new UserInfo();
    }
    const bite_im::UserInfo& userInfo = resp->userInfo();
    myself->load(userInfo);
}

这里我们调用了这个函数就能把userInfo的内容放到我们的DataCenter里的myself了。


主窗口信号槽

我们只要进入主窗口就必须让这个头像和我们userInfo的内容就能够加载出来了,所以我们就要在整个触发连接信号槽的地方直接让他调用我们的getMyselfAsync的方法。只要一登录我们就能够从客户端发送请求到服务端获取我们的个人信息。

但是!展示在我们主页面的内容是也要显示正确才行啊,我们的头像还得渲染到我们的主页面的个人头像上,所以我们还得弄一个信号槽函数,用于接收一下信号,信号我们可以自定义一个,我们当把DataCenter的内容给弄上去之后就可以触发这个信号,信号被触发之后我们就会把头像的内容放到我们的主界面的userAvatar上。

    //获取个人信息
    connect(dataCenter, &DataCenter::getMyselfDone, this,[=](){
        //从DataCenter中拿到响应结果的myself,把里面的头像拿出来,放置在界面上
        auto myself = dataCenter->getMyself();
        userAvatar->setIcon(myself->avatar);
    });
    dataCenter->getMyselfAsync();
signals:
    //自定义信号
    void getMyselfDone();
//通过网络获取用户个人信息
void NetClient::getMyself(const QString &loginSessionId)
{
    //构造http的body部分
    bite_im::GetUserInfoReq req;
    req.setRequestId(makeRequestId()); 
    req.setSessionId(loginSessionId);
    QByteArray body = req.serialize(&serializer);
    LOG() << "[获取个人信息] 发送请求 requestId=" << req.requestId() << ", loginSessionId=" << loginSessionId;

    //构造http请求
    QNetworkReply* httpResp = sendHttpRequest("/service/user/get_user_info", body);

    //通过信号槽,获取到当前的响应
    connect(httpResp, &QNetworkReply::finished, this, [=](){
        //返回值能获取一个反序列好的对象,并且判定业务上正确的
        bool ok = true;
        QString reason;
        auto resp = handleHttpResponse<bite_im::GetUserInfoRsp>(httpResp, &ok, &reason);

        if(!ok){
            LOG() << "[获取个人信息] 出错!requestId=" << req.requestId() <<"reason=" << reason;
            return;
        }

        //响应数据保存到DataCenter中,一开始个人信息是nullptr的
        dataCenter->resetMyself(resp);

        //通知调用逻辑,响应处理完毕
        emit dataCenter->getMyselfDone();

        //打印日志
        LOG() << "[获取个人信息] 响应处理完毕!requestId=" << req.requestId();


    });

}

我们程序的链路就是:

  1. 主窗口调用DataCenter的getMyselfAsync
  2. 把DataCenter的loginSessionId传给NetClient,调用getMyself
  3. 进入getMyself,发送请求,返回并处理请求,保存myself,触发信号
  4. 触发信号,主窗口渲染头像即可。

这样我们客户端这边就暂时告一段落了,可以准备去完成测试服务器那边的内容。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2242070.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

redis实现消息队列的几种方式

一、了解 众所周知&#xff0c;redis是我们日常开发过程中使用最多的非关系型数据库&#xff0c;也是消息中间件。实际上除了常用的rabbitmq、rocketmq、kafka消息队列&#xff08;大家自己下去研究吧~模式都是通用的&#xff09;&#xff0c;我们也能使用redis实现消息队列。…

单片机智能家居火灾环境安全检测

目录 前言 一、本设计主要实现哪些很“开门”功能&#xff1f; 二、电路设计原理图 电路图采用Altium Designer进行设计&#xff1a; 三、实物设计图 四、程序源代码设计 五、获取资料内容 前言 在现代社会&#xff0c;火灾安全始终是人们关注的重点问题。随着科技的不…

【目标检测】用YOLOv8-Segment训练语义分割数据集(保姆级教学)

前言 这篇教程会手把手带你用 YOLOv8-Segment 搭建一个属于自己的分割任务项目。从环境配置到数据集准备&#xff0c;再到模型训练和测试&#xff0c;所有步骤都有详细说明&#xff0c;适合初学者使用。你将学会如何安装必要的软件&#xff0c;标注自己的数据&#xff0c;并使…

mac2019环境 Airflow+hive+spark+hadoop本地环境安装

1 环境介绍 本地安装可分为两个部分&#xff0c;mac软件环境&#xff0c; python开发环境 ps: 安装过程参考chatgpt、csdn文章 1.1 mac软件环境 目标安装的的软件是hive、apache-spark、hadoop&#xff0c;但是这三个软件又依赖java(spark依赖&#xff09;、ssh&#xff08…

1.7 JS性能优化

从输入url到页面加载完成都做了些什么 输入 URL - 资源定位符 http://www.zhaowa.com - http 协议 域名解析 https://www.zhaowa.com > ip 1. 切HOST&#xff1f; > 浏览器缓存映射、系统、路由、运营商、根服务器 2. 实际的静态文件存放&#xff1f; 大流量 > 多个…

【Ansible常用命令+模块+Playbook+Roles】

Ansible 一、命令1.1 常用命令 二、模块2.1 shell模块2.2 复制模块2.3 用户模块2.4 软件包管理2.5 服务模块2.6 文件模块2.7 收集模块2.8 fetch2.9 cron2.10 group2.11 script2.12 unarchive 三、YAML Roles3.1 目录结构3.2 文件内容tasks/main.yamlnginx.conf.j2vars/main.yam…

Oracle19C AWR报告分析之Wait Classes by Total Wait Time

Oracle19C AWR报告分析之Wait Classes by Total Wait Time 一、分析数据二、详细分析2.1 指标参数介绍2.2 数据库性能分析2.3 综合性能评估 在 Oracle 数据库的 AWR 报告中&#xff0c;Wait Classes by Total Wait Time 是评估数据库性能的重要部分。本篇文章主要是介绍指标参数…

嵌入式硬件电子电路设计(五)MOS管详解(NMOS、PMOS、三极管跟mos管的区别)

引言&#xff1a;在我们的日常使用中&#xff0c;MOS就是个纯粹的电子开关&#xff0c;虽然MOS管也有放大作用&#xff0c;但是几乎用不到&#xff0c;只用它的开关作用&#xff0c;一般的电机驱动&#xff0c;开关电源&#xff0c;逆变器等大功率设备&#xff0c;全部使用MOS管…

问题大集-01-kafka问题

1、问题&#xff1a;Windows下启动单机kafka出现&#xff1a;系统找不到指定路径 解决&#xff1a; 是kafka不能识别本机的java环境&#xff08;JVM&#xff09;&#xff0c;故需要指定java路径&#xff0c; 进入kafka路径下的\bin\windows&#xff0c;找到&#xff1a;kafk…

C++ 的发展

目录 C 的发展总结&#xff1a;​编辑 1. C 的早期发展&#xff08;1979-1985&#xff09; 2. C 标准化过程&#xff08;1985-1998&#xff09; 3. C 标准演化&#xff08;2003-2011&#xff09; 4. C11&#xff08;2011年&#xff09; 5. C14&#xff08;2014年&#xf…

Ubuntu问题 -- 允许ssh使用root用户登陆

目的 新重装的系统, 普通用户可以使用ssh登陆服务器, 但是root不能使用ssh登陆 方法 vim 编辑ssh配置文件 sudo vim /etc/ssh/sshd_config找到 PermitRootLogin 这一行, 把后面值改成 yes 重启ssh sudo service sshd restart然后使用root账号登陆即可

HarmonyOS4+NEXT星河版入门与项目实战--------开发工具与环境准备

文章目录 1、熟悉鸿蒙官网1、打开官网2、下载 DevEco Studio3、HarmonyOS 资源库4、开发指南与API 2、安装 DevEco Studio1、软件安装2、配置开发工具 1、熟悉鸿蒙官网 1、打开官网 百度搜索 鸿蒙开发者官网 点击进入开发者官网&#xff0c;点击开发&#xff0c;可以看到各种…

使用 start-local 脚本在本地运行 Elasticsearch

警告&#xff1a;请勿将这些说明用于生产部署 本页上的说明仅适用于本地开发。请勿将此配置用于生产部署&#xff0c;因为它不安全。请参阅部署选项以获取生产部署选项列表。 使用 start-local 脚本在 Docker 中快速设置 Elasticsearch 和 Kibana 以进行本地开发或测试。 此设…

【大数据学习 | HBASE高级】hbase-phoenix 与二次索引应用

1. hbase-phoenix的应用 1.1 概述&#xff1a; 上面我们学会了hbase的操作和原理&#xff0c;以及外部集成的mr的计算方式&#xff0c;但是我们在使用hbase的时候&#xff0c;有的时候我们要直接操作hbase做部分数据的查询和插入&#xff0c;这种原生的方式操作在工作过程中还…

Nginx server_name配置错误导致路由upstream超时问题

一、问题描述 某次本平台和外部平台接口调用&#xff0c;同样Nginx location配置&#xff0c;测试环境调用正常&#xff0c;生产环境调用返回失败&#xff1b; 相关链接&#xff1a;Nginx官方文档、server_name、How nginx processes a request 二、排查处理 1&#xff09…

Android Studio 控制台输出的中文显示乱码

1. Android Studio 控制台输出的中文显示乱码 1.1. 问题 安卓在调试阶段&#xff0c;需要查看app运行时的输出信息、出错提示信息。乱码&#xff0c;会极大的阻碍开发者前进的信心&#xff0c;不能及时的根据提示信息定位问题&#xff0c;因此我们需要查看没有乱码的打印信息。…

linux001.在Oracle VM VirtualBox中ubuntu虚拟系统扩容

1.打开终端切换到virtualBox安装目录 2.输入命令扩容 如上终端中的代码解释&#xff1a; D:\Program Files\Oracle\VirtualBox>.\VBoxManage modifyhd D:\ubuntu18.04\Ubuntu18.04\Ubuntu18.04.vdi --resize 40960如上代码说明&#xff1a;D:\Program Files\Oracle\Virtual…

【桌面应用程序】Vue-Electron 环境构建、打包与测试(Windows)

前言 Vue 与 Electron 环境构建、打包与测试。 目录 前言 一、基本环境准备 二、配置npm源 三、创建Vue项目 四、添加Electron支持 五、应用启动 ​六、添加UI框架 ElementUI ​七、打包 一、基本环境准备 npm版本&#xff1a;8.6.0node版本&#xff1a;v18.0.0Vue/…

C#获取视频第一帧_腾讯云媒体处理获取视频第一帧

一、 使用步骤&#xff1a; 第一步、腾讯云开启万象 第二步、安装Tencent.QCloud.Cos.Sdk 包 第三步、修改 腾讯云配置 图片存储目录配置 第四步、执行获取图片并保存 二、封装代码 using System.Text; using System.Threading.Tasks;using COSXML.Model.CI; using COSXML.A…

Jav项目实战II基于微信小程序的助农扶贫的设计与实现(开发文档+数据库+源码)

目录 一、前言 二、技术介绍 三、系统实现 四、文档参考 五、核心代码 六、源码获取 全栈码农以及毕业设计实战开发&#xff0c;CSDN平台Java领域新星创作者&#xff0c;专注于大学生项目实战开发、讲解和毕业答疑辅导。获取源码联系方式请查看文末 一、前言 在当前社会…