对gRPC中常见的 grpc::CreateChannel()这个类所创建的对象所包含的属性做详细介绍

简介: 对gRPC中常见的 grpc::CreateChannel()这个类所创建的对象所包含的属性做详细介绍

简介

在 gRPC 中,grpc::CreateChannel 函数用于创建一个 grpc::Channel 对象,这个对象代表了与 gRPC 服务端的连接。这个函数是客户端用来初始化与服务器通信的起点。

grpc::Channel 对象的一些常见属性和功能:

  1. Channel State (grpc_connectivity_state): grpc::Channel 对象维护着一个状态,表示当前与服务端的连接状态。状态可以是 IDLE, CONNECTING, READY, TRANSIENT_FAILURE, SHUTDOWN 等。
  2. Channel Credentials: 当创建 grpc::Channel 对象时,需要指定认证凭证(credentials)。gRPC 提供了多种类型的认证方式grpc::InsecureChannelCredentials(不安全的连接,不推荐在生产环境中使用)和 grpc::SslCredentials(安全的 SSL/TLS 连接)。
  3. Target Address (host): 这是服务端的地址,包括主机名和端口号。客户端通过这个地址来连接到服务端。
  4. Load Balancing Policy: grpc::Channel 可以配置负载均衡策略,以优化请求的分发。
  5. Interceptors: 拦截器允许开发者拦截和修改 gRPC 调用,这在需要添加额外的逻辑(如日志记录、认证、监控等)时非常有用。
  6. Service Config: 服务配置(Service Config)是一个 JSON 格式的配置,它可以用来控制服务的行为,如设置超时、重试策略等。
  7. Completion Queue (grpc::CompletionQueue): 用于异步操作的回调。每个 grpc::Channel 对象可以关联一个或多个 grpc::CompletionQueue 对象。
  8. Calls: grpc::Channel 对象可以创建 grpc::Call 对象,这些对象代表了单个 RPC 调用。
  9. Interceptor Creators: 用于创建拦截器的工厂接口,可以通过这些接口创建自定义的拦截器。
  10. Channel Arguments: 这些是用于配置 grpc::Channel 的参数,如设置最大消息大小、启用或禁用压缩等。
  11. Error Handling: grpc::Channel 提供了错误处理机制,可以捕获和处理与服务端通信过程中出现的错误。
  1. Watchers: 可以注册状态变化的观察者,当通道状态发生变化时,观察者会被通知。
  2. Liveness Probes: 用于健康检查的接口,可以定期检查服务端是否存活。
  3. Resource Quotas: 可以为 grpc::Channel 设置资源配额,以限制其使用的资源。
  4. Security: 提供了安全相关的属性,如 SSL/TLS 配置,用于保护传输的数据。

grpc::Channel 对象是 gRPC 客户端的核心,它封装了与服务端通信所需的所有细节。通过配置和使用 grpc::Channel,开发者可以灵活地控制 gRPC 客户端的行为,以满足不同的应用场景需求。

深入了解 grpc::Channel 对象的属性和功能

在这一章节,我提供一些 C++ 伪代码示例来展示如何使用它们。

1. Channel State

属性:grpc_connectivity_state

用途:获取当前通道的状态。

伪代码:

grpc::ChannelArguments args;
grpc::shared_ptr<grpc::Channel> channel = grpc::CreateChannel("server_address", grpc::InsecureChannelCredentials());
grpc_connectivity_state state = channel->GetState(true); // 尝试连接

2. Channel Credentials

用途:设置通道的安全凭证。

伪代码:

grpc::SslCredentialsOptions ssl_opts;
grpc::shared_ptr<grpc::Channel> secure_channel = grpc::CreateChannel("server_address", grpc::SslCredentials(ssl_opts));

3. Target Address

用途:指定服务端的地址。

伪代码:

const std::string server_address = "192.168.1.1:50051";
grpc::shared_ptr<grpc::Channel> channel = grpc::CreateChannel(server_address, grpc::InsecureChannelCredentials());

4. Load Balancing Policy

用途:配置负载均衡策略。

伪代码:

grpc::ChannelArguments args;
args.SetLoadBalancingPolicyName("round_robin"); // 设置为轮询策略
grpc::shared_ptr<grpc::Channel> channel = grpc::CreateChannel("server_address", grpc::InsecureChannelCredentials(), args);

5. Interceptors

用途:拦截和修改 gRPC 调用。

伪代码:

class MyInterceptor : public grpc::ClientInterceptor {
public:
  grpc::ClientInterceptor::InterceptionHookResult Intercept(
      grpc::ClientInterceptor::InterceptionHookPoints points,
      grpc::ChannelInterface* channel,
      const grpc::ChannelArgs& args,
      grpc::ClientContext* context,
      const grpc::ByteBuffer* request,
      grpc::CompletionQueue* cq,
      void** tag) override {
    // 自定义拦截逻辑
  }
};

grpc::ChannelArguments args;
args.SetInterceptorCreator([]() { return new MyInterceptor; });
grpc::shared_ptr<grpc::Channel> channel_with_interceptor = grpc::CreateChannel("server_address", grpc::InsecureChannelCredentials(), args);

6. Service Config

用途:获取服务配置的 JSON 字符串。

伪代码:

std::string service_config_json = channel->GetServiceConfigJSON();

7. Completion Queue

用途:用于异步 RPC 调用的回调。

伪代码:

grpc::CompletionQueue cq;
grpc::ClientContext context;
// 创建异步调用
auto reader = stub_->PrepareAsyncSomeCall(&context, request, &cq);
// 从 completion queue 中获取结果
void* tag; bool ok;
cq.Next(&tag, &ok);

8. Calls

用途:创建和发起 RPC 调用。

伪代码:

grpc::ClientContext context;
SomeRequest request;
SomeResponse response;
// 同步调用
stub_->SomeCall(&context, request, &response);
// 或者异步调用

9. Channel Arguments

用途:设置通道参数,如最大消息大小。

伪代码:

grpc::ChannelArguments args;
args.SetMaxReceiveMessageSize(1024 * 1024); // 设置最大接收消息大小为1MB
grpc::shared_ptr<grpc::Channel> channel = grpc::CreateChannel("server_address", grpc::InsecureChannelCredentials(), args);


10. Error Handling

用途:处理通道错误。

伪代码:

grpc::Status status = context.GetStatus();
if (!status.ok()) {
  // 处理错误
}

11. Watchers

用途:注册状态变化的观察者。

伪代码:

channel->NotifyOnStateChange(GRPC_CHANNEL_READY, deadline, &cq, this);

12. Liveness Probes

用途:定期检查服务端是否存活。

伪代码:

// 通常由 gRPC 内部处理,客户端不需要显式调用


13. Resource Quotas

用途:为通道设置资源配额。

伪代码:

grpc::ChannelArguments args;
args.SetResourceQuota("some_quota_name");
grpc::shared_ptr<grpc::Channel> channel = grpc::CreateChannel("server_address", grpc::InsecureChannelCredentials(), args);

请注意,上述伪代码仅用于演示目的,实际代码可能会根据 gRPC API 的具体版本和您的应用程序需求有所不同。


如果有gRPC 相关的其他问题,欢迎评论区留言。我看到都会回复的。


分享一个有趣的 学习链接

目录
相关文章
|
2月前
|
Kubernetes 负载均衡 网络协议
k8s学习-Service(概念、模板、创建、外部代理、删除等)
k8s学习-Service(概念、模板、创建、外部代理、删除等)
195 0
|
2月前
|
监控 Java API
如何动态通过API的形式在XxlJob上创建任务
如何动态通过API的形式在XxlJob上创建任务
93 0
|
API 图形学
U3D客户端框架之实现基于UnityWebRequest的Http服务 实现HttpCallBackArgs参数类、HttpRoutine访问器、HttpManager管理器
Unity3D 在2018版本中弃用了WWW请求,使用UnityWebRequest 进行网络请求,这个方法是为了满足今天的 HTTP 通信的需求,而且诞生的新类,相对于WWW这个方法,会更灵活一些,但是用起来却很不方便。
U3D客户端框架之实现基于UnityWebRequest的Http服务 实现HttpCallBackArgs参数类、HttpRoutine访问器、HttpManager管理器
.NET Core反射获取带有自定义特性的类,通过依赖注入根据Attribute元数据信息调用对应的方法
.NET Core反射获取带有自定义特性的类,通过依赖注入根据Attribute元数据信息调用对应的方法
139 0
|
存储 Java Linux
知识分享之Golang——Bleve中如何定义一个自定义文档映射对象
知识分享之Golang篇是我在日常使用Golang时学习到的各种各样的知识的记录,将其整理出来以文章的形式分享给大家,来进行共同学习。欢迎大家进行持续关注。 知识分享系列目前包含Java、Golang、Linux、Docker等等。
96 0
知识分享之Golang——Bleve中如何定义一个自定义文档映射对象
|
XML 开发框架 监控
直观讲解一下 RPC 调用和 HTTP 调用的区别!
第一层:应用层。定义了用于在网络中进行通信和传输数据的接口; 第二层:表示层。定义不同的系统中数
直观讲解一下 RPC 调用和 HTTP 调用的区别!
|
Kotlin
【Kotlin】扩展接收者 与 分发接收者 ( 类内部扩展用法 | 注意事项 | open 修饰扩展 )
【Kotlin】扩展接收者 与 分发接收者 ( 类内部扩展用法 | 注意事项 | open 修饰扩展 )
165 0
【Kotlin】扩展接收者 与 分发接收者 ( 类内部扩展用法 | 注意事项 | open 修饰扩展 )
|
XML 开发框架 监控
直观讲解一下RPC调用和HTTP调用的区别!
直观讲解一下RPC调用和HTTP调用的区别!
245 0
直观讲解一下RPC调用和HTTP调用的区别!