Go（gRPC协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息

查看更多 →

创建GRPC API API网关支持创建GRPC API。gRPC是RPC（远程过程调用）的一种，只需定义每个API的Request和Response，剩下的gRPC框架就可以完成。它的典型特征就是使用protobuf（protocol buffers）作为其接口定义语言（Interface

查看更多 →

Java（gRPC协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息

查看更多 →

性，极大地提高了客户端与服务端的通信效率。更多信息参见Introduction to gRPC。 图1 gRPC示意图 在gRPC中，客户端应用程序可以直接调用位于不同机器上的服务端应用方法，可以轻松创建分布式应用程序和服务。和许多其他RPC框架一样，使用gRPC需要定义调用服务

查看更多 →

操作流程 创建API 创建gRPC类型的API，前后端协议均为GRPCS。 发布API 将gRPC类型的API发布到环境上。 验证 使用gRPC客户端测试gRPC服务可用性，如果服务端正常返回响应，则表示gRPC服务可用。 父主题： 基于API网关专享版实现gRPC服务的路由转发

查看更多 →

取，在客户端配置时，可将地址都配上。 使用TCP协议通过内网连接RocketMQ实例时，获取“连接地址”。 使用gRPC协议通过内网连接RocketMQ实例时，获取“grpc连接地址”。 使用TCP协议通过公网连接RocketMQ实例时，获取“公网连接地址”。 使用gRPC协议通

查看更多 →

前提条件 客户端与服务端均为gRPC类型。 服务端已定义proto文件，即在proto文件中定义API的Request和Response。proto文件是用于定义数据结构和服务接口的文件，通常在gRPC中使用。它基于Protobuf语言，用于描述数据的结构和交互方式，充当客户端和服务端之间通信的合同。

查看更多 →

备转发”两种类型。 负载均衡：属于普通后端服务器组，里面可以添加多个后端服务器，扩展业务的服务能力。 主备转发：必须同时向其中添加后端服务器，且只能添加两个后端服务器，一个为主服务器，一个为备服务器。当主服务器故障时，流量将转发至备服务器，提升业务的可靠性。 说明： 该特性陆续上线中，已发布区域请参见主备转发模式。

查看更多 →

第三章~第七章介绍Java、Go和Python客户端访问分布式消息服务RocketMQ版的示例代码，具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 Java（gRPC协议） 收发普通消息

查看更多 →

负载均衡器会定期向后端服务器发送请求以测试其运行状态，这些测试称为健康检查。通过健康检查来判断后端服务器是否可用。 负载均衡器如果判断后端服务器健康检查异常，就不会将流量分发到异常后端服务器，而是分发到健康检查正常的后端服务器，从而提高了业务的可靠性。当异常的后端服务器恢复正常运行后，

查看更多 →

加权轮询算法：根据后端服务器的权重，按顺序依次将请求分发给不同的服务器。它用相应的权重表示服务器的处理性能，按照权重的高低以及轮询方式将请求分配给各服务器，相同权重的服务器处理相同数目的连接数。常用于短连接服务，例如HTTP等服务。 加权最少连接：最少连接是通过当前活跃的连接数来估计服务器负载情

查看更多 →

切换至备机。 必须向后端服务器组中添加两个后端服务器，一个为主服务器，一个为备服务器。 √ ╳ 全端口转发 后端服务器组添加后端服务器时无需指定后端端口，监听器将按照前端请求端口转发流量至后端服务器对应的端口。 仅TCP、UDP和QUIC类型的后端服务器组支持全端口转发功能。 √

查看更多 →

连接RocketMQ网络要求 客户端可以通过公网连接RocketMQ实例，也可以通过内网连接RocketMQ实例。使用内网连接时，注意以下几点： 如果客户端和RocketMQ实例部署在同一个VPC内，网络默认互通。 如果客户端和RocketMQ实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和Ro

查看更多 →

obuf。 当用户使用gRPC服务时，可以通过API网关创建API，实现gRPC服务的路由转发。 约束与限制 由于GRPCS协议的约束，gRPC类型的API不支持导入、导出、调试，不支持第三方认证、自定义认证策略。 父主题： 基于API网关专享版实现gRPC服务的路由转发

查看更多 →

没有区别。 收发顺序消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费

查看更多 →

选择“GRPC”。其余配置参数可根据实际需求进行填写，详细说明请参见通过控制台创建ELB Ingress。 仅独享型ELB支持选择GRPC协议，且需开启HTTP/2，系统将自动为您添加kubernetes.io/elb.http2-enable:true注解。当前GRPC功能仅在部分区域开放，请以控制台呈现为准。

查看更多 →

TTP、HTTPS、TLS、GRPC。 若pool的protocol为HTTPS，则type可以是TCP、HTTP、HTTPS、TLS、GRPC。 若pool的protocol为GRPC，则type可以是TCP、HTTP、HTTPS、TLS、GRPC。 若pool的protoco

查看更多 →

TTP、HTTPS、TLS、GRPC。 若pool的protocol为HTTPS，则type可以是TCP、HTTP、HTTPS、TLS、GRPC。 若pool的protocol为GRPC，则type可以是TCP、HTTP、HTTPS、TLS、GRPC。 若pool的protoco

查看更多 →

没有区别。 收发顺序消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费

查看更多 →

本章节指导用户在后端服务器组创建后修改健康检查配置。 若切换健康检查协议，负载均衡会根据新的健康检查协议重新检查后端服务器。健康检查通过后，负载均衡向后端服务器继续转发流量。 健康检查切换周期内，客户端可能收到503错误码。 约束与限制 健康检查协议与服务器组的后端协议是两个相互

查看更多 →

ect;)V at io.grpc.Metadata$Key.validateName(Metadata.java:630) ~[fabric-sdk-java-1.4.1-jar-with-dependencies.jar:na] at io.grpc.Metadata$Key

查看更多 →