gRPC 四模式之 一元RPC模式

一元RPC模式

一元 RPC 模式也被称为简单 RPC 模式。在该模式中，当客户端调用服务器端的远程方法时，客户端发送请求至服务器端并获得一个响应，与响应一起发送的还有状态细节以及 trailer 元数据（这部分不是默认发送的，需要自己实现）。

![[Pasted image 20231115104223.png]]

使用场景

单次通讯，传输数据包的时候，返回收到应答。

在一元RPC模式中，状态细节和trailer元数据并不是默认就有的，它们是由服务器端根据需要添加的。状态细节通常包含了关于RPC调用的状态信息，例如是否成功，如果失败了具体是什么原因等。而trailer元数据则是一些额外的信息，例如调用的时间，服务器的处理时间等。

具体来说，状态细节和trailer元数据的形式取决于你使用的RPC框架和编程语言。在gRPC中，状态细节和trailer元数据通常以键值对的形式存在，键和值都是字符串。例如，你可能会看到这样的状态细节：{"status": "success"}，或者这样的trailer元数据：{"processing-time": "123ms"}。

请注意，这只是一个例子，实际的状态细节和trailer元数据会根据你的应用需求和服务器的实现来定。

在gRPC中，服务器可以通过grpc::ServerContext对象来设置trailer元数据。这些元数据在RPC调用结束时发送给客户端。以下是一个C++的示例，展示了如何设置和发送trailer元数据：

#include <grpcpp/grpcpp.h>
#include "your_service.grpc.pb.h"  // 替换为你的服务的protobuf头文件class YourServiceImpl final : public YourService::Service {grpc::Status YourMethod(grpc::ServerContext* context, const YourRequest* request,YourResponse* reply) override {// 处理你的方法逻辑...// 在RPC调用结束时，设置trailer元数据context->AddTrailingMetadata("processing-time", "123ms");return grpc::Status::OK;}
};

在这个例子中，服务器在处理完YourMethod方法后，通过AddTrailingMetadata方法添加了一个名为"processing-time"的trailer元数据，值为"123ms"。这个元数据会在RPC调用结束时发送给客户端。

至于状态细节，它通常包含在返回的grpc::Status对象中。例如，如果你的方法出现了错误，你可以返回一个包含错误信息的grpc::Status对象：

return grpc::Status(grpc::StatusCode::INTERNAL, "An internal error occurred");

在这个例子中，服务器返回了一个状态码为INTERNAL的grpc::Status对象，状态细节为"An internal error occurred"。这个状态细节会被发送给客户端，客户端可以通过检查返回的grpc::Status对象来获取这个信息。

在服务端返回时，设置多个状态和元数据

在gRPC中，你可以通过多次调用AddTrailingMetadata方法来添加多个trailer元数据。每次调用都会添加一个新的键值对。例如：

context->AddTrailingMetadata("processing-time", "123ms");
context->AddTrailingMetadata("server-id", "server-001");
context->AddTrailingMetadata("timestamp", "2022-01-01T00:00:00Z");

在这个例子中，服务器添加了三个trailer元数据：“processing-time”，“server-id"和"timestamp”。

至于状态细节，gRPC的grpc::Status对象只支持设置一个状态细节。如果你需要传递多个状态信息，你可以将它们编码为一个字符串，例如JSON格式的字符串，然后设置为状态细节。例如：

std::string status_detail = R"({"error": "An internal error occurred","error_code": 123,"error_info": "Some additional info"
})";
return grpc::Status(grpc::StatusCode::INTERNAL, status_detail);

在这个例子中，服务器将多个状态信息编码为一个JSON格式的字符串，然后设置为状态细节。客户端可以解析这个字符串来获取这些状态信息。

客户端接取trailer元数据

客户端可以接收到服务端发送的trailer元数据和状态细节，并根据需要进行处理。

在gRPC中，客户端可以通过grpc::ClientContext对象来获取trailer元数据。例如：

grpc::ClientContext context;
YourResponse response;
grpc::Status status = stub->YourMethod(&context, request, &response);if (!status.ok()) {std::cout << "RPC failed with code " << status.error_code()<< ", message: " << status.error_message() << std::endl;// 获取trailer元数据auto trailers = context.GetServerTrailingMetadata();for (const auto& kv : trailers) {std::cout << "Trailer key: " << kv.first << ", value: " << kv.second << std::endl;}
}

在这个例子中，客户端首先调用YourMethod方法并获取返回的grpc::Status对象。如果RPC调用失败，客户端会打印出错误信息，然后通过GetServerTrailingMetadata方法获取trailer元数据并打印出来。

至于状态细节，客户端可以通过grpc::Status对象的error_message方法来获取。例如：

std::cout << "Status detail: " << status.error_message() << std::endl;

在这个例子中，客户端打印出了状态细节。如果状态细节是一个编码的字符串，例如JSON格式的字符串，客户端可以解析这个字符串来获取状态信息。

客户端发送 header 元数据、状态细节

在gRPC中，客户端也可以设置和发送header元数据和状态细节。这可以通过grpc::ClientContext对象来实现。

首先，客户端可以通过AddMetadata方法来设置header元数据：

grpc::ClientContext context;
context.AddMetadata("client-id", "client-001");
context.AddMetadata("timestamp", "2022-01-01T00:00:00Z");

在这个例子中，客户端设置了两个header元数据：“client-id"和"timestamp”。

然后，客户端可以通过TryCancel方法来取消RPC调用，并通过set_cancel_message方法来设置状态细节：

context.TryCancel();
context.set_cancel_message("The request was cancelled by the client");

在这个例子中，客户端取消了RPC调用，并设置了状态细节为"The request was cancelled by the client"。

请注意，这只是一个例子，实际的使用方式会根据你的应用需求和gRPC的API来定。在gRPC中，客户端也可以设置和发送header元数据和状态细节。这可以通过grpc::ClientContext对象来实现。

首先，客户端可以通过AddMetadata方法来设置header元数据：

grpc::ClientContext context;
context.AddMetadata("client-id", "client-001");
context.AddMetadata("timestamp", "2022-01-01T00:00:00Z");

在这个例子中，客户端设置了两个header元数据：“client-id"和"timestamp”。

然后，客户端可以通过TryCancel方法来取消RPC调用，并通过set_cancel_message方法来设置状态细节：

context.TryCancel();
context.set_cancel_message("The request was cancelled by the client");

在这个例子中，客户端取消了RPC调用，并设置了状态细节为"The request was cancelled by the client"。

补充：

取消RPC调用通常是因为客户端不再需要RPC的结果，或者因为某些条件已经改变，使得继续等待响应变得没有意义。取消可以用于各种情况，例如：

  1. 超时: 如果一个RPC调用超过了预定的时间还没有响应，客户端可能会选择取消它，以避免无限期地等待。

  2. 用户干预: 如果用户发起了一个操作，然后在操作完成前改变了主意，客户端应用可能需要取消相关的RPC调用。

  3. 资源优化: 如果客户端已经发送了多个RPC调用，但是得到了足够的信息来完成任务，它可能会取消剩余的调用，以节省服务器资源和网络带宽。

  4. 错误恢复: 如果在RPC调用过程中发生了错误，客户端可能会取消该调用，并尝试其他恢复策略。

  5. 依赖关系变化: 如果RPC调用的结果依赖于某些条件，而这些条件在调用过程中发生了变化，客户端可能需要取消调用。

取消RPC调用是异步编程中常见的一种模式，它允许应用程序更有效地管理资源和用户交互。在gRPC中，客户端可以通过调用grpc::ClientContext的TryCancel方法来取消RPC调用。服务端可以通过检查grpc::ServerContext::IsCancelled来响应取消事件，并及时停止处理。

分享一个有趣的 学习链接：https://xxetb.xet.tech/s/HY8za

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

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

相关文章

.L0CK3D来袭：如何保护您的数据免受致命攻击

.L0CK3D来袭：如何保护您的数据免受致命攻击

尊敬的读者&#xff1a; 网络犯罪的威胁日益增长&#xff0c;其中.L0CK3D勒索病毒是一种极具挑战性的数字威胁。为了助您应对这一风险&#xff0c;本文将深入探讨.L0CK3D病毒的狡猾手法、毁灭性影响&#xff0c;提供详实的数据恢复方法&#xff0c;同时为您提供极具实战性的预…
阅读更多...
流量2----2

流量2----2

2
阅读更多...
ArcGIS Maps SDK for JS：监听图层的visible属性

ArcGIS Maps SDK for JS：监听图层的visible属性

文章目录 1 问题描述2 解决方案3 拓展 1 问题描述 近期有这么一个需求。在 ArcGIS Maps SDK for JavaScript 中&#xff0c;使用图层的visible属性同步显示某个组件&#xff0c;即打开图层时显示组件&#xff0c;关闭图层时隐藏组件。 首先想到的是&#xff0c;通过点击图层列…
阅读更多...
HTTP 到 HTTPS 再到 HSTS 的转变

HTTP 到 HTTPS 再到 HSTS 的转变

近些年&#xff0c;随着域名劫持、信息泄漏等网络安全事件的频繁发生&#xff0c;网站安全也变得越来越重要&#xff0c;也促成了网络传输协议从 HTTP 到 HTTPS 再到 HSTS 的转变。 HTTP HTTP&#xff08;超文本传输协议&#xff09; 是一种用于分布式、协作式和超媒体信息系…
阅读更多...
【总结】各层的校验和的特点

【总结】各层的校验和的特点

数据链路层 MAC帧头的校验码&#xff08;FCS&#xff09;&#xff08;4B&#xff09;&#xff0c;校验首部和数据&#xff0c;即从目的地址到数据尾的所有字节&#xff08;共有数据 64B-1518B&#xff09;&#xff08;4618-150018&#xff09; 网络层 IP帧头的首部校验和&am…
阅读更多...
OpenAI的多函数调用（Multiple Function Calling)简介

OpenAI的多函数调用（Multiple Function Calling)简介

我在六月份写了一篇关于GPT 函数调用&#xff08;Function calling) 的博客https://blog.csdn.net/xindoo/article/details/131262670&#xff0c;其中介绍了函数调用的方法&#xff0c;但之前的函数调用&#xff0c;在一轮对话中只能调用一个函数。就在上周&#xff0c;OpenAI…
阅读更多...
C# IEnumerable＜T＞介绍

C# IEnumerable＜T＞介绍

IEnumerable 是 C# 中的一个接口&#xff0c;它是 .NET Framework 中的集合类型的基础。任何实现了 IEnumerable 接口的对象都可以进行 foreach 迭代。 IEnumerable 只有一个方法&#xff0c;即 GetEnumerator&#xff0c;该方法返回一个 IEnumerator 对象。IEnumerator 对象用…
阅读更多...
Ubuntu22.04 部署Mqtt服务器

Ubuntu22.04 部署Mqtt服务器

1、打开Download EMQX &#xff08;www.emqx.io&#xff09;下载mqtt服务器版本 2、Download the EMQX repository curl -s https://assets.emqx.com/scripts/install-emqx-deb.sh | sudo bash 3.Install EMQX sudo apt-get install emqx 4.Run EMQX sudo systemctl start…
阅读更多...
开源与闭源：数字化时代的辩论与未来走向

开源与闭源：数字化时代的辩论与未来走向

在当今的数字化时代&#xff0c;关于开源和闭源软件的辩论一直是技术界的热门话题。 特斯拉CEO马斯克最近也加入了这场辩论&#xff0c;公开表示OpenAI不应该闭源&#xff0c;而他自己的首款聊天机器人将选择开源。 这引发了人们对开源与闭源软件的进一步思考&#xff1a;开源是…
阅读更多...
下厨房网站月度最佳栏目菜谱数据获取及分析

下厨房网站月度最佳栏目菜谱数据获取及分析

目录 概要 源数据获取 写Python代码爬取数据 Scala介绍与数据处理 1.Sacla介绍
阅读更多...
《全程软件测试 第三版》拆书笔记

《全程软件测试 第三版》拆书笔记

第一章 对软件测试的全面认识&#xff0c;测试不能是穷尽的 软件测试的作用&#xff1a; 1.产品质量评估&#xff1b;2.持续质量反馈&#xff1b;3.客户满意度提升&#xff1b;4.缺陷的预防 正反思维&#xff1a;正向思维&#xff08;广度&#xff0c;良好覆盖面&#xff09;逆…
阅读更多...
sql注入 [极客大挑战 2019]LoveSQL 1

sql注入 [极客大挑战 2019]LoveSQL 1

打开题目 几次尝试&#xff0c;发现输1 1"&#xff0c;页面都会回显NO,Wrong username password&#xff01;&#xff01;&#xff01; 只有输入1&#xff0c;页面报错&#xff0c;说明是单引号的字符型注入 那我们万能密码试试能不能登录 1 or 11 # 成功登录 得到账号…
阅读更多...
系列六、JVM的内存结构【栈】

系列六、JVM的内存结构【栈】

一、产生背景 由于跨平台性的设计&#xff0c;Java的指令都是根据栈来设计的&#xff0c;不同平台的CPU架构不同&#xff0c;所以不能设计为基于寄存器的。 二、概述 栈也叫栈内存&#xff0c;主管Java程序的运行&#xff0c;是在线程创建时创建&#xff0c;线程销毁时销毁&…
阅读更多...
从0开始学习JavaScript--JavaScript 循环与迭代详解

从0开始学习JavaScript--JavaScript 循环与迭代详解

JavaScript中的循环和迭代是编写高效和灵活代码的关键。循环用于重复执行一段代码&#xff0c;而迭代则用于遍历数据结构。本文将深入研究JavaScript中常见的循环结构和迭代方法&#xff0c;并通过丰富的示例代码来帮助读者更好地理解和运用这些概念。 基本的for循环 for循环…
阅读更多...
el-table固定表头（设置height）出现内容过多时不能滚动问题

el-table固定表头（设置height）出现内容过多时不能滚动问题

主要原因是el-table没有div包裹 解决&#xff1a;加一个div并设置其高度和overflow 我自己的主要代码 <div class"contentTable"><el-tableref"table":data"tableData"striperow-dblclick"onRowDblclick"height"100%&q…
阅读更多...
B031-网络编程 Socket Http TomCat

B031-网络编程 Socket Http TomCat

目录 计算机网络网络编程相关术语IP地址ip的概念InerAdress的了解与测试 端口URLTCP、UDP和7层架构TCPUDPTCP与UDP的区别和联系TCP的3次握手七层架构 Socket编程服务端代码客户端代码 http协议概念Http报文 Tomcat模拟 计算机网络 见文档 网络编程相关术语 见文档 IP地址 …
阅读更多...
3.3 Windows驱动开发：内核MDL读写进程内存

3.3 Windows驱动开发：内核MDL读写进程内存

MDL内存读写是一种通过创建MDL结构体来实现跨进程内存读写的方式。在Windows操作系统中&#xff0c;每个进程都有自己独立的虚拟地址空间&#xff0c;不同进程之间的内存空间是隔离的。因此&#xff0c;要在一个进程中读取或写入另一个进程的内存数据&#xff0c;需要先将目标进…
阅读更多...
unity教程

unity教程

前言 伴随游戏行业的兴起&#xff0c;unity引擎的使用越来越普遍&#xff0c;本文章主要记录博主本人入门unity的相关记录大部分依赖siki学院进行整理。12 一、认识unity引擎&#xff1f; 1、Unity相关信息&#xff1a; Unity的诞生&#xff1a;https://www.jianshu.com/p/550…
阅读更多...
Springboot更新用户头像

Springboot更新用户头像

人们通常(为徒省事)把一个包含了修改后userName的完整userInfo对象传给后端&#xff0c;做完整更新。但仔细想想&#xff0c;这种做法感觉有点二&#xff0c;而且浪费带宽。 于是patch诞生&#xff0c;只传一个userName到指定资源去&#xff0c;表示该请求是一个局部更新&#…
阅读更多...
Filter和ThreadLocal结合存储用户id信息

Filter和ThreadLocal结合存储用户id信息

ThreadLocal并不是一个Thread&#xff0c;而是Thread的局部变量。当使用ThreadLocal维护变量时&#xff0c;ThreadLocal为每个使用该变量的线程提供独立的变量副本&#xff0c;所以每一个线程都可以独立地改变自己的副本&#xff0c;而不会影响其它线程所对应的副本。ThreadLoc…
阅读更多...
最新文章

Copyright @ 2022~2023