[实现Rpc] 客户端 | Requestor | RpcCaller的设计实现

目录

Requestor类的实现

框架

完善

onResponse处理回复

完整代码

RpcCaller类的实现

1. 同步调用 call

2. 异步调用 call

3. 回调调用 call

Requestor类的实现

（1）主要功能：

  • 客户端发送请求的功能，进行请求描述
  • 对服务器响应的处理机制，并对返回信息 进行对应接收

（2）具体实现：

  • 意义：针对客户端的每一条请求进行管理，以便于对请求对应的响应做出合适操作。
  • 对于客户端而言，其通常是主动发起请求服务的一方。然而，在多线程网络通信中，针对多个请求进行响应时可能会存在时序问题，导致无法保证一个线程发送的请求后接收到的响应就是针对这条请求的响应，这是非常危险的情况。
  • 异步IO挑战：类似于Muduo库这种异步IO网络通信库，通常IO操作都是异步的，即发送数据是将数据放入发送缓冲区，而何时发送由底层网络库协调，并且不提供recv接口，而是连接触发可读事件后，IO读取数据完成调用处理回调进行数据处理，因此在发送请求后无法直接等待该条请求的响应。

解决方案：

  • 创建请求管理模块，通过给每个请求设定一个请求ID来解决上述问题。服务端响应时会标识出响应针对的是哪个请求（即响应信息包含请求ID）。
  • 客户端无论收到 哪条请求的响应，都将数据存储入hash_map中，以请求ID作为映射，并提供获取指定请求ID响应的阻塞接口。这样，只要知道自己的请求ID，就能准确获取到想要的响应。
  • 进一步优化：可以将每个请求封装描述，添加异步future控制或设置回调函数的方式，不仅支持阻塞获取响应，也能实现异步获取响应及 回调处理响应。

框架

namespace bitrpc{
namespace client
{//客户端 部分class Requestor{public:using ptr = std::shared_ptr<Requestor>;using RequestCallback = std::function<void(const BaseMessage::ptr&)>;using AsyncResponse = std::future<BaseMessage::ptr>;struct RequestDescribe{using ptr=std::shared_ptr<RequestDescribe>;//智能指针 管理};//请求 信息描述//之后 好调用 所需要的rsp函数//Dispatcher调用void onResponse(const BaseConnection::ptr &conn,BaseMessage::ptr &msg){}//异步发送bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, AsyncResponse &async_rsp){}//同步发送bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, BaseMessage::ptr &rsp) {}//回调发送bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, const RequestCallback &cb) {}private://对于 请求 描述进行CURD//增RequestDescribe::ptr newDescribe(const BaseMessage::ptr &req, RType rtype, const RequestCallback &cb = RequestCallback()) {}//查 ridRequestDescribe::ptr getDescribe(const std::string &rid){}//删void delDescribe(const std::string &rid){}private:std::mutex _mutex;std::unordered_map<std::string, RequestDescribe::ptr> _request_desc;};
}
}

完善

信息描述

struct RequestDescribe {using ptr = std::shared_ptr<RequestDescribe>;BaseMessage::ptr request;RType rtype;std::promise<BaseMessage::ptr> response;RequestCallback callback;};

对收到的响应 通过 uid ，对应上是哪个请求发出的

实现了上面的解决问题

void onResponse(const BaseConnection::ptr &conn, BaseMessage::ptr &msg){std::string rid = msg->rid();RequestDescribe::ptr rdp = getDescribe(rid);//根据先获取msg->rid() 来进行结果的调用if (rdp.get() == nullptr) {ELOG("收到响应 - %s，但是未找到对应的请求描述！", rid.c_str());return;}if (rdp->rtype == RType::REQ_ASYNC) {rdp->response.set_value(msg);//调用 不同的接口}else if (rdp->rtype == RType::REQ_CALLBACK){if (rdp->callback) rdp->callback(msg);}else {ELOG("请求类型未知！！");}delDescribe(rid);
}
onResponse处理回复
  • onResponse方法是对收到的消息进行处理的入口点。当收到服务器的响应时，该方法会被调用来匹配相应的请求描述(RequestDescribe)，并通过请求类型(RType)来决定如何处理响应：
    • 如果是 异步请求(RType::REQ_ASYNC)，则通过设置std::promise的值(response.set_value(msg))来完成对应的std::future，使得调用者可以通过未来对象获取响应。
    • 如果是带有回调的请求(RType::REQ_CALLBACK)，则直接调用注册的回调函数(rdp->callback(msg))来处理响应。
    • 如果请求类型未知，则记录错误日志。

onResponse方法则是 对接收到的响应进行处理，

关于 promise set_value: C++11 异步操作 future类_文档学习

send方法负责构建和发送请求，

//异步操作
bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, AsyncResponse &async_rsp)
{RequestDescribe::ptr rdp = newDescribe(req, RType::REQ_ASYNC);if (rdp.get() == nullptr){ELOG("构造请求描述对象失败！");return false;}conn->send(req);async_rsp = rdp->response.get_future();return true;
}
//同步操作
bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, BaseMessage::ptr &rsp)
{AsyncResponse rsp_future;bool ret = send(conn, req, rsp_future);if (ret == false){return false;}rsp = rsp_future.get();return true;
}
//回调函数
bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, const RequestCallback &cb)
{RequestDescribe::ptr rdp = newDescribe(req, RType::REQ_CALLBACK, cb);if (rdp.get() == nullptr){ELOG("构造请求描述对象失败！");return false;}conn->send(req);//！！！！！！！！！！！！！！！！return true;
}

1.

前文回顾：[C++#28][多态] 两个条件 | 虚函数表 | 抽象类 | override 和 final | 重载 重写 重定义

Requestor类中的 三个重载send方法，这些方法用于通过指定的连接对象发送消息

同：

  • 基本参数：所有三个send方法都接受两个相同的基本参数：一个指向BaseConnection的智能指针conn（表示网络连接）和一个指向BaseMessage的智能指针req（表示要发送的消息）。
  • 错误处理：每个send方法在无法成功创建请求描述对象时，都会记录错误日志并返回false，指示操作失败。
  • 消息发送：无论哪种方式，最终都是通过调用conn->send(req)来执行实际的消息发送。

异：

  • send方法（有三个重载版本）用于通过网络连接conn发送请求消息req到服务器：
    • 第一个send方法接受一个AsyncResponse &async_rsp参数，用于异步发送请求并返回一个std::future对象，以便于后续获取响应。（不阻塞
    • 第二个send方法是同步的，它 等待直到接收到服务器的响应并将结果赋值给BaseMessage::ptr &rsp。
    • 第三个send方法允许用户在发送请求时提供一个回调函数const RequestCallback &cb，当收到响应时会自动调用该回调进行处理。（send 后，就不管了，不会阻塞等待）

📒对比第一种和第三种方式：

  1. 结果获取方式：
    • 第一种方法需调用者主动通过future.get()获取结果，可能导致阻塞。
    • 第三种方法响应到达时自动调用回调函数处理结果，无需主动获取。
  1. 编程模型：
    • 第一种更接近同步编程风格，通过异步手段避免长时间阻塞。
    • 第三种是典型的异步编程模型，更适合处理并发任务和事件驱动架构。
  1. 灵活性与复杂性：
    • 第一种方法直观但可能引入复杂的依赖关系管理。
    • 第三种方法灵活，尤其适合链式异步操作，但可能导致“回调地狱”，增加代码维护难度。

<id,请求 desc> CURD

private:// 对于 请求 描述进行CURD//增RequestDescribe::ptr newDescribe(const BaseMessage::ptr &req, RType rtype,const RequestCallback &cb = RequestCallback()){std::unique_lock<std::mutex> lock(_mutex);//加锁RequestDescribe::ptr rd = std::make_shared<RequestDescribe>();rd->request = req;rd->rtype = rtype;if (rtype == RType::REQ_CALLBACK && cb){rd->callback = cb;}_request_desc.insert(std::make_pair(req->GetId(), rd));//将id 和描述 进行对应return rd;}//查RequestDescribe::ptr getDescribe(const std::string &rid){std::unique_lock<std::mutex> lock(_mutex);auto it = _request_desc.find(rid);if (it == _request_desc.end()){return RequestDescribe::ptr();}return it->second;}//删void delDescribe(const std::string &rid){std::unique_lock<std::mutex> lock(_mutex);_request_desc.erase(rid);}

完整代码

#pragma once
#include "../common/net.hpp"
#include "../common/message.hpp"
#include <future> //异步操作
#include <functional> //1.灵活的函数使用 bind functionnamespace bitrpc{
namespace client
{//客户端 部分class Requestor{public:using ptr = std::shared_ptr<Requestor>;using RequestCallback = std::function<void(const BaseMessage::ptr&)>;using AsyncResponse = std::future<BaseMessage::ptr>;//异步处理信息struct RequestDescribe {using ptr = std::shared_ptr<RequestDescribe>;BaseMessage::ptr request;RType rtype;std::promise<BaseMessage::ptr> response;RequestCallback callback;};//请求 信息描述//之后 好调用 所需要的rsp函数//Dispatcher 给RSP_RPC回复调用的void onResponse(const BaseConnection::ptr &conn, BaseMessage::ptr &msg){std::string rid = msg->GetId();RequestDescribe::ptr rdp = getDescribe(rid);if (rdp.get() == nullptr) {ELOG("收到响应 - %s，但是未找到对应的请求描述！", rid.c_str());return;}if (rdp->rtype == RType::REQ_ASYNC) {rdp->response.set_value(msg);}else if (rdp->rtype == RType::REQ_CALLBACK){if (rdp->callback) rdp->callback(msg);}else {ELOG("请求类型未知！！");}delDescribe(rid);}
//！！！！！！！对收到 的回复请求 进行id存储//异步详可见demo中的 使用//异步操作bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, AsyncResponse &async_rsp){RequestDescribe::ptr rdp = newDescribe(req, RType::REQ_ASYNC);if (rdp.get() == nullptr){ELOG("构造请求描述对象失败！");return false;}conn->send(req);async_rsp = rdp->response.get_future();return true;}//同步操作bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, BaseMessage::ptr &rsp){AsyncResponse rsp_future;bool ret = send(conn, req, rsp_future);if (ret == false){return false;}rsp = rsp_future.get();return true;}//回调函数bool send(const BaseConnection::ptr &conn, const BaseMessage::ptr &req, const RequestCallback &cb){RequestDescribe::ptr rdp = newDescribe(req, RType::REQ_CALLBACK, cb);if (rdp.get() == nullptr){ELOG("构造请求描述对象失败！");return false;}conn->send(req);return true;}//private:// <id,请求 desc> CURD//增RequestDescribe::ptr newDescribe(const BaseMessage::ptr &req, RType rtype,const RequestCallback &cb = RequestCallback()){std::unique_lock<std::mutex> lock(_mutex);RequestDescribe::ptr rd = std::make_shared<RequestDescribe>();rd->request = req;rd->rtype = rtype;if (rtype == RType::REQ_CALLBACK && cb){rd->callback = cb;}_request_desc.insert(std::make_pair(req->GetId(), rd));//将id 和描述 进行对应return rd;}//查RequestDescribe::ptr getDescribe(const std::string &rid){std::unique_lock<std::mutex> lock(_mutex);auto it = _request_desc.find(rid);if (it == _request_desc.end()){return RequestDescribe::ptr();}return it->second;}//删void delDescribe(const std::string &rid){std::unique_lock<std::mutex> lock(_mutex);_request_desc.erase(rid);}private:std::mutex _mutex;std::unordered_map<std::string, RequestDescribe::ptr> _request_desc;};
}
}

RpcCaller类的实现

（Requestor 的处理 调用 RpcCaller）

（1）主要功能：

  • 给Requestor() 提供接口。

（2）具体实现：

  • 意义：向用户提供进行RPC调用的模块。这个模块相对简单，主要功能是向外提供几个RPC调用接口，内部实现向服务端发送请求并等待获取结果。
  • 调用方式：
    1. 同步调用：发起调用后，等到收到响应结果后返回。
    2. 异步调用：发起调用后立即返回，可以在需要的时候获取结果。
    3. 回调调用：发起调用的同时设置结果的处理回调，收到响应后自动对结果进行回调处理。

❗❗❗❗ 

// requestor中的处理是针对BaseMessage进行处理的
// 用于在rpccaller中针对结果的处理是针对 RpcResponse里边的result进行的
#pragma once
#include "requestor.hpp"// request 有 rpc topic server
// 其中 rpc部分的 调用函数的 实现namespace bitrpc
{namespace client{class RpcCaller{public:using ptr = std::shared_ptr<RpcCaller>;using JsonAsyncResponse = std::future<Json::Value>;using JsonResponseCallback = std::function<void(const Json::Value &)>;RpcCaller(const Requestor::ptr &requestor) : _requestor(requestor) {}// requestor中的处理是针对BaseMessage进行处理的// 用于在rpccaller中针对结果的处理是针对 RpcResponse里边的result进行的//1.bool call(const BaseConnection::ptr &conn, const std::string &method,const Json::Value &params, Json::Value &result){DLOG("开始同步rpc调用...");// 1. 组织请求auto req_msg = MessageFactory::create<RpcRequest>();req_msg->SetId(UUID::uuid());req_msg->setMethod(method);req_msg->setParams(params);req_msg->SetMType(MType::REQ_RPC);BaseMessage::ptr rsp_msg;// 2. 发送请求bool ret = _requestor->send(conn, std::dynamic_pointer_cast<BaseMessage>(req_msg), rsp_msg);if (ret == false){ELOG("同步Rpc请求失败！");return false;}DLOG("收到响应，进行解析，获取结果!");// 3. 等待响应auto rpc_rsp_msg = std::dynamic_pointer_cast<RpcResponse>(rsp_msg);if (!rpc_rsp_msg){ELOG("rpc响应，向下类型转换失败！");return false;}if (rpc_rsp_msg->rcode() != RCode::RCODE_OK){ELOG("rpc请求出错：%s", errReason(rpc_rsp_msg->rcode()));return false;}result = rpc_rsp_msg->result();DLOG("结果设置完毕！");return true;}////2.bool call(const BaseConnection::ptr &conn, const std::string &method,const Json::Value &params, JsonAsyncResponse &result){// 向服务器发送异步回调请求，设置回调函数，回调函数中会传入一个promise对象，在回调函数中去堆promise设置数据auto req_msg = MessageFactory::create<RpcRequest>();req_msg->SetId(UUID::uuid());req_msg->SetMType(MType::REQ_RPC);req_msg->setMethod(method);req_msg->setParams(params);auto json_promise = std::make_shared<std::promise<Json::Value>>();result = json_promise->get_future();Requestor::RequestCallback cb = std::bind(&RpcCaller::Callback,this, json_promise, std::placeholders::_1);bool ret = _requestor->send(conn, std::dynamic_pointer_cast<BaseMessage>(req_msg), cb);if (ret == false){ELOG("异步Rpc请求失败！");return false;}return true;}//3.bool call(const BaseConnection::ptr &conn, const std::string &method,const Json::Value &params, const JsonResponseCallback &cb){auto req_msg = MessageFactory::create<RpcRequest>();req_msg->SetId(UUID::uuid());req_msg->SetMType(MType::REQ_RPC);req_msg->setMethod(method);req_msg->setParams(params);Requestor::RequestCallback req_cb = std::bind(&RpcCaller::Callback1,this, cb, std::placeholders::_1);bool ret = _requestor->send(conn, std::dynamic_pointer_cast<BaseMessage>(req_msg), req_cb);if (ret == false){ELOG("回调Rpc请求失败！");return false;}return true;}private:void Callback1(const JsonResponseCallback &cb, const BaseMessage::ptr &msg){auto rpc_rsp_msg = std::dynamic_pointer_cast<RpcResponse>(msg);if (!rpc_rsp_msg){ELOG("rpc响应，向下类型转换失败！");return;}if (rpc_rsp_msg->rcode() != RCode::RCODE_OK){ELOG("rpc回调请求出错：%s", errReason(rpc_rsp_msg->rcode()));return;}cb(rpc_rsp_msg->result());}void Callback(std::shared_ptr<std::promise<Json::Value>> result, const BaseMessage::ptr &msg){auto rpc_rsp_msg = std::dynamic_pointer_cast<RpcResponse>(msg);if (!rpc_rsp_msg){ELOG("rpc响应，向下类型转换失败！");return;}if (rpc_rsp_msg->rcode() != RCode::RCODE_OK){ELOG("rpc异步请求出错：%s", errReason(rpc_rsp_msg->rcode()));return;}result->set_value(rpc_rsp_msg->result());}private:Requestor::ptr _requestor;};}
}

RpcCaller类中 三个重载的call方法，这些方法提供了不同的方式来发起RPC调用，并处理从服务器返回的响应。每个call方法根据其参数和使用场景的不同，具有特定的功能和适用性：

1. 同步调用 call

  • 目的：同步地发起一个RPC请求，并等待直到收到服务器的响应。
  • 实现：
    • 创建并配置一个RpcRequest消息。
    • 使用_requestor->send()发送请求，并阻塞等待响应。
    • 接收到响应后解析结果，并检查是否有错误发生。
    • 将结果设置到输出参数result中 返回给调用者。
  • 应用场景：适用于需要立即获取结果且可以接受当前线程被阻塞的情况。

2. 异步调用 call

  • 目的：异步地发起一个RPC请求，不阻塞当前线程，允许后续通过std::future机制获取结果。
  • 实现：
    • 创建并配置一个RpcRequest消息。
    • 绑定一个回调函数Callback用于在接收到响应时设置std::promise的值。
    • 使用_requestor->send()发送请求，并立即返回（非阻塞）。
    • 结果 可以通过result.get()在未来某个时刻获取。
  • 应用场景：适合于那些希望避免阻塞主线程，但仍然需要明确获取结果的场景。

3. 回调调用 call

  • 目的：异步发起RPC请求并在接收到响应时自动调用用户提供的回调函数进行处理。
  • 实现：
    • 创建并配置一个RpcRequest消息。
    • 绑定一个回调函数Callback1，该回调会在接收到响应时被调用，并进一步调用用户提供的回调函数处理结果。
    • 使用_requestor->send()发送请求，并立即返回（非阻塞）。
  • 应用场景：适用于不需要立即处理响应结果，到了 就回调 来处理响应数据的场景。

本节重点，通过 重载 来实现同步 回调 异步

  • 同步：阻塞 返回结果参数
  • 回调：非阻塞 到了就返回结果
  • 异步：非阻塞 .get()获取

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

WPS计算机二级•文档的页面设置与打印

WPS计算机二级•文档的页面设置与打印

听说这是目录哦 纸张大小页边距和装订线❤️‍&#x1f525;打印界面讲解❤️缩印&#x1f495;打印作文稿纸&#x1f49e;将文档打印成书籍&#x1f493;限制编辑设置&#x1f497;给文字文档加密&#x1f496;文档导出为 PDF格式&#x1f498;协作编辑模式&#x1f49d;能量站…
阅读更多...
hackmyvm-buster

hackmyvm-buster

题目地址 信息收集 主机发现 ┌──(root㉿kali)-[/home/kali] └─# arp-scan -I eth1 192.168.56.0/24 Interface: eth1, type: EN10MB, MAC: 00:0c:29:34:da:f5, IPv4: 192.168.56.103 WARNING: Cannot open MAC/Vendor file ieee-oui.txt: Permission denied WARNING: C…
阅读更多...
【入门音视频】音视频基础知识

【入门音视频】音视频基础知识

&#x1f308;前言&#x1f308; 这个系列在我学习过程中&#xff0c;对音视频知识归纳总结的笔记。因为音视频相关讲解非常稀少&#xff0c;所以我希望通过这个音视频系列&#xff0c;跟大家一起学习音视频&#xff0c;希望减少初学者在学习上的压力。同时希望也欢迎指出文章的…
阅读更多...
将Ubuntu操作系统的安装源设置为阿里云

将Ubuntu操作系统的安装源设置为阿里云

在使用Ubuntu操作系统时，默认的软件源通常是国外的仓库，这可能会导致软件安装和更新速度较慢。为了提高下载速度和稳定性，我们可以将Ubuntu的安装源设置为阿里云镜像源。以下是详细步骤： 一、准备工作 在开始之前，请确保您的Ubuntu系统可以正常上网，并且您拥有管理员权…
阅读更多...
基于 Python 的项目管理系统开发

基于 Python 的项目管理系统开发

基于 Python 的项目管理系统开发 一、引言 在当今快节奏的工作环境中&#xff0c;有效的项目管理对于项目的成功至关重要。借助信息技术手段开发项目管理系统&#xff0c;能够显著提升项目管理的效率和质量。Python 作为一种功能强大、易于学习且具有丰富库支持的编程语言&…
阅读更多...
LabVIEW C编译支持工具库CCompileSupp.llb

LabVIEW C编译支持工具库CCompileSupp.llb

路径&#xff1a;C:\Program Files (x86)\National Instruments\LabVIEW 2019\vi.lib\Platform\CCompileSupp.llb ​ 1. 工具库概述 定位&#xff1a;LabVIEW内置的C语言编译支持工具库&#xff0c;用于处理LabVIEW与C/C代码的混合编程接口&#xff0c;涵盖编译器配置、代码生成…
阅读更多...
JVM之JVM的组成

JVM之JVM的组成

Java 虚拟机&#xff08;JVM&#xff09;是 Java 程序的运行核心&#xff0c;它主要由类加载系统、运行时数据区、执行引擎和本地方法接口这几个关键部分组成。 类加载系统&#xff08;Class Loading System&#xff09; 类加载系统负责在程序运行时动态地将 Java 类加载到 J…
阅读更多...
pycharm 调试 debug 进入 remote_sources

pycharm 调试 debug 进入 remote_sources

解决办法1&#xff1a; pycharm函数跳转到remote_sources中的文件中_pycharm修改remotesource包存放地址-CSDN博客 file->settings->project structure将项目文件夹设为"Sources"&#xff08;此时文件夹会变为蓝色&#xff09;。 解决方法2 Debug:使用Pychar…
阅读更多...
iOS App的启动与优化

iOS App的启动与优化

App的启动流程 App启动分为冷启动和热启动 冷启动&#xff1a;从0开始启动App热启动&#xff1a;App已经在内存中&#xff0c;但是后台还挂着&#xff0c;再次点击图标启动App。 一般对App启动的优化都是针对冷启动。 App冷启动可分为三个阶段&#xff1a; dyld&#xff1a…
阅读更多...
StarRocks FE leader节点CPU使用率周期性的忽高忽低问题分析

StarRocks FE leader节点CPU使用率周期性的忽高忽低问题分析

背景 本文基于 StarRocks 3.3.5 最近在做一些 StarRocks 相关的指标监控的时候&#xff0c;看到了FE master的CPU使用率相对其他FE节点是比较高的&#xff0c;且 呈现周期性的变化&#xff08;周期为8分钟&#xff09;&#xff0c; 于此同时FE master节点的GC频率相对于其他节…
阅读更多...
Spring高级篇-Spring IOC容器 Aware 接口

Spring高级篇-Spring IOC容器 Aware 接口

一、概述 在Spring框架中&#xff0c;IOC&#xff08;Inversion of Control&#xff09;容器负责管理应用程序中的对象&#xff08;即Bean&#xff09;的生命周期和依赖关系。Spring提供了一系列的Aware接口&#xff0c;允许Bean在初始化时获取Spring容器中的某些资源或信息。…
阅读更多...
数字信任的底层逻辑：密码学核心技术与现实应用

数字信任的底层逻辑：密码学核心技术与现实应用

安全和密码学 --The Missing Semester of Your CS Education 目录 熵与密码强度密码散列函数密钥体系 3.1 对称加密 3.2 非对称加密信任模型对比典型应用案例安全实践建议扩展练习杂项 密码学是构建数字信任的基石。 本文浅析密码学在现实工具中的应用&#xff0c;涵盖 1&…
阅读更多...
MySQL数据库连接池泄露导致MySQL Server超时关闭连接

MySQL数据库连接池泄露导致MySQL Server超时关闭连接

前言 最近做项目&#xff0c;发现老项目出现xxx&#xff0c;这个错误其实很简单&#xff0c;出现在MySQL数据库Server端对长时间没有使用的client连接执行清楚处理&#xff0c;因为是druid数据库&#xff0c;且在github也出现这样的issue&#xff1a;The last packet successf…
阅读更多...
DirectX12（D3D12）基础教程三 线性代数与3D世界空间

DirectX12（D3D12）基础教程三 线性代数与3D世界空间

线性代数是数学的一个分支&#xff0c;它的研究对象是向量&#xff0c;向量空间&#xff08;或称线性空间&#xff09;&#xff0c;线性变换和有限维的线性方程组。 向量和矩阵是学习3D入门最基本的理论基础。本章重点讲向量和矩阵. 向量概念 向量最基本的定义就是一个方向和…
阅读更多...
LeetCode 230.二叉搜索树中第K小的元素

LeetCode 230.二叉搜索树中第K小的元素

题目&#xff1a;给定一个二叉搜索树的根节点 root &#xff0c;和一个整数 k &#xff0c;请你设计一个算法查找其中第 k 小的元素&#xff08;从 1 开始计数&#xff09;。 思路&#xff1a; 代码&#xff1a; /*** Definition for a binary tree node.* public class Tre…
阅读更多...
Android 老项目 jcenter 库失效

Android 老项目 jcenter 库失效

最近重新维护了一些老项目发现大部分jcenter库失效了&#xff0c; Could not resolve com.xx:2.1.3. 如果你也遇到了&#xff0c;不妨试试 替换为 aliyun的jcenter服务&#xff0c;就不用一个个找代替库了。 project 下的 build.gradle 文件添加&#xff1a; maven { url htt…
阅读更多...
Python数据结构：哈希表-高效存储与查找的秘密武器！

Python数据结构：哈希表-高效存储与查找的秘密武器！

大家周一好&#xff01;今天我们来聊聊Python中一个非常重要的数据结构——哈希表。无论是算法面试还是实际开发&#xff0c;哈希表都扮演着至关重要的角色。掌握它&#xff0c;你就能轻松解决许多复杂的编程问题&#xff01; 在编程中&#xff0c;如何实现快速的存储与查找操…
阅读更多...
【复习】Redis

【复习】Redis

数据结构 Redis常见的数据结构 String&#xff1a;缓存对象Hash&#xff1a;缓存对象、购物车List&#xff1a;消息队列Set&#xff1a;点赞、共同关注ZSet&#xff1a;排序 Zset底层&#xff1f; Zset底层的数据结构是由压缩链表或跳表实现的 如果有序集合的元素 < 12…
阅读更多...
【电机控制器】ESP32-C3语言模型——DeepSeek

【电机控制器】ESP32-C3语言模型——DeepSeek

【电机控制器】ESP32-C3语言模型——DeepSeek 文章目录 [TOC](文章目录) 前言一、简介二、代码三、实验结果四、参考资料总结 前言 使用工具&#xff1a; 提示&#xff1a;以下是本篇文章正文内容&#xff0c;下面案例可供参考 一、简介 二、代码 #include <Arduino.h&g…
阅读更多...
STM32-智能小车项目

STM32-智能小车项目

项目框图 ST-link接线 实物图&#xff1a; 正面&#xff1a; 反面&#xff1a; 相关内容 使用L9110S电机模块 电机驱动模块L9110S详解 | 良许嵌入式 一、让小车动起来 新建文件夹智能小车项目 在里面复制19-串口打印功能 重命名为01-让小车动起来 新建文件夹motor&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023