深入剖析grpc服务器回调机制 (grpc 服务器回调)

深入剖析gRPC服务器回调机制

gRPC是一种高效的跨平台RPC框架。它由Google开发，提供了一种简单的方法让客户端和服务器之间进行通信。gRPC不仅支持多种语言，还提供了多种不同的传输协议，包括HTTP/2和TCP。在这篇文章中，我们将重点关注gRPC服务器回调机制的实现。

1. gRPC简介

gRPC是一个基于protobuf（protobuf是一种高效的序列化数据结构的协议）的高性能、开源的RPC框架。它的目标是使客户端和服务器在不同的机器上能够像在同一台机器上一样互相通信。这种通信是无缝和透明的，并且提供了高效、稳定的传输和编解码技术。

gRPC的核心概念是服务定义，这是一个接口定义语言（IDL），用于描述服务器端如何处理客户端请求。客户端和服务器都依据此IDL生成对应的代码，使客户端和服务器可以相互通信。

gRPC提供了多种支持语言，包括Java、C++、Python、Ruby、Object-C、C#、JavaScript、Go等。

2. gRPC服务器回调机制

在gRPC中，服务器通过gRPC框架提供的直接或间接的调用进程注册回调函数来处理来自客户端的请求。gRPC服务器的回调机制是通过线程池实现的。线程池实现的目的是使服务器可以处理多个并发请求，并确保回调函数在已经分配的工作线程上执行。这样可以提高响应速度和效率。

当服务器收到客户端请求后，它使用线程池中的一个工作线程来处理该请求，并调用注册的回调函数处理该请求。回调函数将负责在服务器上执行请求并返回响应。一旦服务器处理完请求，它将向客户端发送相应的响应。

gRPC具有一套丰富的API，可让您轻松地控制回调机制。您可以注册回调函数，指定回调函数在特定条件下执行（例如，在特定端口、特定地址或特定HTTP头中的某些信息指定的请求等）。此外，您还可以指定回调函数的运行顺序，例如，您可以指定回调函数的优先级，使其在其他回调函数之前执行。

3. 实现一个简单的gRPC服务器

在本节中，我们将创建一个简单的gRPC服务器，以便更好地理解回调机制的实现。

我们需要安装和配置gRPC。gRPC提供了多种语言的SDK和工具，您可以选择最适合您的语言和操作系统的SDK和工具。

当您安装和配置好gRPC之后，就可以开始编写代码了。以下是一个使用C++编写的简单gRPC服务器的例子：

“`

#include

#include

#include

#include “greeter.grpc.pb.h”

using grpc::Server;

using grpc::ServerBuilder;

using grpc::ServerContext;

using grpc::Status;

using greeter::HelloRequest;

using greeter::HelloReply;

using greeter::Greeter;

class GreeterServiceImpl final : public Greeter::Service {

Status SayHello(ServerContext* context, const HelloRequest* request,

HelloReply* reply) override {

std::string prefix(“Hello, “);

reply->set_message(prefix + request->name());

return Status::OK;

}

};

void RunServer() {

std::string server_address(“0.0.0.0:50051”);

GreeterServiceImpl service;

grpc::ServerBuilder builder;

builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());

builder.RegisterService(&service);

std::unique_ptr server(builder.BuildAndStart());

std::cout

server->Wt();

}

int mn(int argc, char** argv) {

RunServer();

return 0;

}

“`

在上面的代码中，我们创建了一个GreeterServiceImpl类，它实现了Greeter::Service的回调函数。Greeter::Service是由IDL在proto文件中定义的服务接口，其中包含了客户端可以调用的所有函数。

在GreeterServiceImpl::SayHello函数中，当我们接收到HelloRequest请求时，我们将为它设置一个响应，并通过设置HelloReply对象的message参数将响应发送回客户端。

在RunServer函数中，我们创建了一个gRPC服务器，并将GreeterServiceImpl服务注册到该服务器上。我们还指定了服务器的地址和端口（在本例中是0.0.0.0:50051），并指定了服务器的验证模式（在本例中是InsecureServerCredentials()）。

当我们运行这段代码时，服务器将启动并开始监听来自客户端的请求。当客户端向服务器发出请求时，服务器将使用Callbacks机制将请求分配给上述的GreeterServiceImpl中实现的回调函数，并返回相应的响应。客户端稍后将收到该响应。

4.

回调机制是使gRPC成为可靠、高效、快速通信框架的重要组成部分。gRPC框架的多语言支持意味着您可以使用任何最适合您的语言来实现服务器和客户端。

相关问题拓展阅读：

• 使用 Rust 构建 gRPC 服务器
• gRPC 4种rpc定义方法与3种stub介绍

使用 Rust 构建 gRPC 服务器

弗洛里安·克鲁姆 ( Florian Krumm ) 在Unsplash上拍摄的照片

一旦我了解了gRPC和Thrift，就很难再回到使用更具过渡性的基于 ON 的 REST API 或SOAP API 了。

两个著名的RPC框架 gRPC 和 Thrift 有很多相似之处。前者源自谷歌，后者源自Facebook。它们都易于坦岁使用，对多种编程语言都有很好的支持，并且都具有高性能。

最有价值的功能是多种语言的代码生成以及服务器端反射。这些使 API 本质上是类型安全的。使用服务器端反射，可以更轻松地 探索 API 的模式定义，而无需阅读和理解实现。

Apache Thrift在 历史 上一直是一个流行的选择。然而近年来，由于缺乏来自 Facebook 的持续支持，以及与fbthrift的分叉分叉，慢慢失去了人气。

与此同时，gRPC 已经赶上了越来越多的功能，拥有更 健康 的生态系统。

GRPC（蓝色）与 Apache Thrift（红色）的比较。谷歌趋势

gRPC、fbThrift 和 Apache Thrift 之间的 GitHub 明星 历史 。

到今天为止，除非您的应用程序以某种方式隶属于 Facebook，否则没有充分的理由考虑 Thrift。

GraphQL是另一个由 Facebook 发神信歼起的框架。它与上面的两个 RPC 框架有很多相似之处。

移动 API 开发的更大痛点之一是一些用户从不升级他们的应用程序。因为我们想保持向后兼容性，我们要么必须在 API 中保留旧的未使用字段，要么创建 API 的多个版本。GraphQL 的一个动机就是解决这个问题。它被设计成一种“查询语言”，允许客户端指定它需要的数据字段。这使得处理向后兼容性变得更容易。

GraphQL 在开发移动 API 以及面向公众的 API（例如GitHub）方面具有巨大价值。因为，在这两种情况下，我们都无法轻易控制客户端的行为。

但是，如果我们正在为 Web 前端构建 API 或为内部后端服务构建 API，那么选择 GraphQL 而不是 gRPC 几乎没有什么好处。

以上是迄今为止网络框架的一个小概述。除了网络，我们还需要决定应用服务器的语言。

基于Stack Overflow 调查：“六年来，Rust 是更受欢迎的语言。” 尽管学习曲线相对陡峭，但它的类型安全、优雅的内存管理、广泛的社区支持和性能，都使 Rust 成为一种非常有吸引力和有前途的后端服务开发编程语言。

Rust 是更受欢迎的语言。2023 年 Stackoverflow 调查

我们也开始看到 Rust 在行业中得到越来越广泛的采用：Facebook、Dropbox、Yelp、AWS、Google等。很明显，Rust 将继续增长并继续存在。

这就是我们将在今天的教程中看到的内容—游冲—在 Rust 中使用 gRPC 构建一个小型服务器。

使用以下命令安装 Rust：

如果您以前安装过 Rust，我们可以通过以下方式对其进行更新：

让我们仔细检查rustc（Rust 编译器）和cargo（Rust 包管理器）的安装版本：

有关安装的更多信息，请查看

运行以下命令创建一个新的“Hello World”项目：

让我们编译并运行程序：

这显示了我们到目前为止的文件结构：

gRPC 使用协议缓冲区来序列化和反序列化数据。.proto让我们在一个文件中定义服务器 API 。

我们定义了一个书店服务，只有一个方法：提供一个书本 id，并返回有关该书的一些详细信息。

我们将使用tonic创建我们的 gRPC 服务。将以下依赖项添加到Cargo.toml文件中：

为了从 生成 Rust 代码bookstore.proto，我们tonic-build在 crate 的build.rs构建脚本中使用。

将以下内容添加到build.rs文件中：

需要特别指出的一件事是，我们添加它.out_dir(“./src”)是为了将默认输出目录更改为该src目录，以便我们可以更轻松地查看生成的文件，以达到本文的目的。

在我们准备编译之前还有一件事。tonic-build依赖于Protocol Buffers 编译器将文件解析.proto为可以转换为 Rust 的表示。让我们安装protobuf：

并仔细检查

protobuf

编译器是否安装正确：

准备编译：

有了这个，我们应该src/bookstore.rs生成一个文件。此时，我们的文件结构应该如下所示：

最后，是时候将服务放在一起了。替换为main.rs以下内容：

正如我们所见，为了简单起见，我们并没有真正的图书设置数据库。在这个端点中，我们只是返回一本假书。

运行服务器的时间：

很好，我们在 Rust 中启动并运行了 gRPC 服务器！

正如开头所说，gRPC 最初给我留下了深刻的印象，因为它具有做服务器反射的能力。它不仅在服务开发过程中很方便，而且还使与前端工程师的沟通变得更加容易。因此，如果不解释如何为 Rust 服务器添加它，那么结束本教程是不完整的。

将以下内容添加到依赖项中：

更新build.rs。需要更改的行用// Add this注释标记。

最后，将其更新main.rs为以下内容。

有许多 GUI 客户端可以使用 gRPC Server，例如Postman、Kreya、bloomrpc、grpcox等。为了简单起见，我们将使用命令行工具grpc_cli。

安装：

并测试我们的之一个 gRPC 端点：

看起来它有效！我的朋友，这就是我们在 Rust 中构建 gRPC 服务器的方式。

这就是今天的内容。感谢阅读和快乐的编码！与往常一样，源代码可在GitHub 上获得。

gRPC 4种rpc定义方法与3种stub介绍

有关gRPC官方介绍（

）如下：

gRPC是一个能在不同语言不同平台中进行高效通信的服务。gRPC默认使用Protocol Buffers数据格式：

Protocol Buffers以.proto作为拓展名，是一系列以name-value键值对的形式存储的数据格式。

Protocol Buffers从开源到现在已经经过很长时间，目前已经到了proto3版本，有着更加简化的语法，更加有用的特性，能够支持更多的语言。你可以从 proto3 language guide 和  reference documentation 看到更多有用的东西。另外.proto的文燃瞎件格式能够从 formal specification 获取到更详细的讲解。

每个参数带有一个唯一的标识符，这些标识符被用来在message的二进制中被识别出来。不是代表每个数据的数值。

有了gRPC，我们可以在.proto文件中定义我们的服务，并用gRPC支持的任何语言生成客户端和服务器，它可以在从大型数据中心内的服务器到您自己的平板电脑的各种环境中运行，不同语言和环境之间的所有复杂通信都由gRPC为您处理。我们还获得了使用协议缓冲区的所有优点，包括高效的序列岩段坦化、简单的IDL和容易的接口更新。

声明定义proto使用3版本，如果不生命默认2版本号。

在proto文件中定义java_package，指定了我们要用于生成的Java类的包。如果.proto文件中没有显式的java_package选项，那么默认情况下将使用proto包（使用“package”关键字指定）。

使用service定义服务。然后在service中使用rpc方法定义，gRPC允许使用4种不同的定粗桐义方式，定义方法。

区别在客户端调用Grpc中Stub发送请求方法时：

可以使用message定义所有的request and response types，在service中使用到的数据格式。

grpc 服务器回调的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于grpc 服务器回调,深入剖析grpc服务器回调机制,使用 Rust 构建 gRPC 服务器,gRPC 4种rpc定义方法与3种stub介绍的信息别忘了在本站进行查找喔。