rpc

_相关内容

在Nginx Ingress Controller后端部署gRPC服务

The greeting service definition.service Greeter {/Sends a greeting rpc SayHello(HelloRequest)returns(HelloReply){} }/The request message containing the user's name.message HelloRequest { string name=1;}/The response ...

在gRPC服务中使用Proxyless服务网格功能

以下是一些业界框架和平台,它们与Istio的proxyless模式兼容或支持:Apache Dubbo:Dubbo是一个高性能的Java RPC框架,已经开展了与Istio的集成,支持在无代理模式下进行服务调用。具体参考:...

使用ASM为网格内gRPC服务实现负载均衡

使用基于HTTP/1.1的RPC时,一个简单的TCP负载均衡器足以胜任,因为这些连接都是短暂的,客户端将尝试重新连接,不会保持与运行中的旧Pod之间的连接。但是使用基于HTTP/2的gRPC时,TCP连接保持打开状态,这样将保持连接到即将失效的Pod,亦...

使用ASM为网格内gRPC服务实现负载均衡

使用基于HTTP/1.1的RPC时,一个简单的TCP负载均衡器足以胜任,因为这些连接都是短暂的,客户端将尝试重新连接,不会保持与运行中的旧Pod之间的连接。但是使用基于HTTP/2的gRPC时,TCP连接保持打开状态,这样将保持连接到即将失效的Pod,亦...

基于ASMGrpcJsonTranscoder实现以HTTP/JSON方式请求...

} rpc SayHelloStreamReply(HelloRequest)returns(stream HelloReply){} rpc SayHelloBidiStream(stream HelloRequest)returns(stream HelloReply){} }/The request message containing the user's name.message HelloRequest { string ...

基于ASMGrpcJsonTranscoder实现以HTTP/JSON方式请求...

} rpc SayHelloStreamReply(HelloRequest)returns(stream HelloReply){} rpc SayHelloBidiStream(stream HelloRequest)returns(stream HelloReply){} }/The request message containing the user's name.message HelloRequest { string ...

应用维度配置扩展

在 SOFABoot 的使用场景下,RPC 框架在应用层面提供一些配置参数,如端口、线程池等信息。应用参数都是通过 Spring Boot@ConfigurationProperties 进行的绑定,绑定属性类为 com.alipay.sofa.rpc.boot.config.SofaBootRpcProperties,配置...

应用维度配置

false run_mode STRING RPC 运行模式,根据实际环境设置。空 rpc_tr_port INTEGER TR 端口号。12200 rpc_bind_network_interface STRING 服务器绑定固定网卡。空 rpc_enabled_ip_range STRING 服务器绑定本地 IP 范围。空 rpc_min_pool_...

日志说明

日志列表 日志名称 说明 rpc/rpc-registry.log 服务地址订阅与接收日志。rpc/tr-threadpool.log 服务连接池日志(SOFABoot 支持该日志)。rpc/rpc-default.log SOFARPC INFO、WARN 日志,无标准格式。rpc/common-error.log SOFARPC 错误...

进阶指南

本文对移动网关 RPC 拦截器、RPC 请求头、RPC Cookie、RPC 签名的设置进行说明。重要 在 10.2.3 基线中新增设置 RPC 签名内容。RPC 拦截 在业务开发中,如果在某些情况下需要控制客户端的网络请求(例如拦截网络请求,禁止访问某些接口,...

自定义 Router

} } RPC 框架支持通过@Extension 注解来扩展 Router,并且可以覆盖重名的 Router。如需覆盖原有 Router,需将@Extension 中 override 置为 true,并确保 order 属性值大于要覆盖的重名 Router。未配置 order 属性时,默认为 0。如上自定义...

调用上下文

RPC 上下文中存放了当前调用过程中的一些其他信息,如服务提供方应用名、IP。应用开发人员可以获取这些信息做一些业务上的操作。RPC 提供获取单次调用上下文的工具类 com.alipay.sofa.rpc.api.context.RpcContextManager,您可以通过该类...

关键类介绍

优先级:System.property custom rpc-config.json(可能存在多个自定义,会排序)rpc-config-default.json。常量 全局的基本常量在 RpcConstants 中,例如:调用方式:sync、oneway。协议:bolt、grpc。序列化:hessian、java、protobuf。...

推送流程

接入消息推送组件后,客户端通过使用 mPaaS 移动网关服务,调用远程过程调用(Remote Procedure Call,简称 RPC)网关进行设备注册、用户绑定以及厂商通道的关系绑定,实现基于设备维度和用户维度的消息推送。不同的设备平台对应的消息推送...

OpenAPI 风格

本文为您详细介绍了OpenAPI的RPC风格和ROA风格,在自定义请求体之前,您必须提前知晓要调用的产品接口风格,它决定了如何构造请求体的请求方法(RequestMethod)、请求头(RequestHeader)、请求查询字符串(RequestQueryString)、请求...

概述

服务分为:服务消费方:对应 RPC 的调用端,可以理解为调用客户端,即“引用(Reference)”。服务提供方:对应 RPC 的被调用端,可以理解为调用服务端。即“服务(Service)”。SOFARPC 实现原理示意图 上述原理说明如下:register service:...

配置方式

SOFARPC 的服务发布和引用方式包括使用注解方式、使用 XML 配置方式和使用编程 API 方式。使用注解方式 SOFABoot 环境支持使用注解方式,包括以下两种:单协议注解:@SofaService 和@SofaReference....bean id="personServiceImpl"class=...

链路追踪

默认为 JSON 数据格式,具体的字段含义解释如下:RPC 客户端摘要日志(rpc-client-digest.log)日志示例如下:{"timestamp":"2018-05-20 17:03:20.708","tracerId":"1e27326d1526807000498100185597","spanId":"0","span.kind":"client",...

网关签名机制

为保证客户端请求不被篡改和伪造,RPC 请求有签名机制,RPC 模块会自动实现加签功能。基本的加签、验签过程如下:将 requestBody 中的内容转换为字符串。使用无线保镖安全模块,通过保存在加密图片(即无线保镖图片)中的加密密钥,对转化...

服务维度配置

本文介绍在 SOFABoot 环境下完整的 SOFARPC 服务发布与引用说明。...bean id="helloSyncServiceImpl"class=...属性说明:属性 默认值 说明 id Bean 名 ID class-类 ref-服务接口实现类 interface-服务接口(唯一标识元素)unique-id-服务标签...

架构模块介绍

工程架构 SOFARPC 架构如下所示:SOFARPC 从下到上分为两层:核心层:包含了 RPC 的核心组件(例如各种接口、API、公共包)以及一些通用的实现(例如随机等负载均衡算法)。功能实现层:所有的功能实现层的用户都是平等的,都是基于扩展...

大查询请求检测

在 云原生多模数据库 Lindorm 中,如果单次RPC(Remote Procedure Call)请求扫描数据块的数量超过100个,则该请求就被定义为大查询请求。当大查询请求量较多时,系统的CPU以及IO消耗严重,对系统整体吞吐存在一定影响。您可以通过大查询...

调用重试

sofa:reference jvm-first="false"id="retriesServiceReferenceBolt"interface="com.alipay.sofa.rpc.samples.retries.RetriesService" sofa:binding.bolt sofa:global-attrs retries="2"/ /sofa:binding.bolt /sofa:reference Annotation...

CreateRpcService

返回数据 名称 类型 示例值 描述 Id Long 1 Rpc服务接口ID。RequestId String 629586FE-CB2E-4742-995E-121F952CEB72 请求ID。示例 请求示例 http(s):/[Endpoint]/?Action=CreateRpcService&AppKey=WH2MptXX&InterfaceName=...

多协议发布

XML 方式 直接在 sofa:service 标签中增加多个 binding 即可:sofa:service ref="sampleFacadeImpl"interface="com.alipay.sofa.rpc.bean.SampleFacade" sofa:binding.bolt/ sofa:binding.rest/ sofa:binding.dubbo/ /sofa:service Annotation...

ListRpcServices

调用ListRpcServices查询Rpc服务接口注册记录列表。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action ...

签名机制

本文介绍 RPC 风格的 API 的签名机制。说明 轻量消息队列(原 MNS)类 API 属于 ROA 风格,其签名机制请参见 请求签名机制。安全访问类 API 接口无需签名。签名机制概述 虚商集成涉及的阿里云服务通过使用 Access Key ID 和 Access Key ...

ST_RPCGeoreference

获取Raster对象的RPC(Rational Polynomial Coefficients)相关信息。如果Raster对象具备RPC信息,则返回一个JSON格式的字符串;如果不具备RPC信息,则返回NULL。语法 text ST_RPCGeoreference(raster raster_obj)参数 参数名称 描述 ...

单元测试与性能测试

Dcontext.attachment.enable=false-Dserialize.blacklist.enable=false-Ddefault.tracer=false-Dlogger.impl=com.alipay.sofa.rpc.log.SLF4JLoggerImpl -Dmultiple.classloader.enable=false -Devent.bus.enable=false对 bolt+hessian 进行压...

ST_RPCGeoreference

获取Raster对象的RPC(Rational Polynomial Coefficients)相关信息。如果Raster对象具备RPC信息,则返回一个JSON格式的字符串;如果不具备RPC信息,则返回NULL。语法 text ST_RPCGeoreference(raster raster_obj)参数 参数名称 描述 ...

DeleteRpcService

调用DeleteRpcService根据记录ID删除Rpc服务接口注册记录。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 ...

关键配置类介绍

本文介绍 RPC 的关键配置类,您可以基于这些配置类进行开发。ProviderConfig 属性 默认值 说明 id 自动生成 ID application 空 ApplicationConfig 设置应用对象。interfaceId-设置服务接口(唯一标识元素)。无论是普通调用还是返回调用,...

ST_SetRPCGeoreference

设置Raster对象的RPC(Rational Polynomial Coefficients)参数信息。语法 raster ST_SetRPCGeoreference(raster raster_obj,text rpc_json)参数 参数名称 描述 raster_obj Raster对象。rpc_json JSON格式的RPC描述信息。描述 支持的RPC...

ST_SetRPCGeoreference

设置Raster对象的RPC(Rational Polynomial Coefficients)参数信息。语法 raster ST_SetRPCGeoreference(raster raster_obj,text rpc_json)参数 参数名称 描述 raster_obj Raster对象。rpc_json JSON格式的RPC描述信息。描述 支持的RPC...

TCC 模式接入

} catch(Throwable t){ } } 发起方配置 对于发起方的应用来说,如果参与者与发起方分别属于不同的应用,则发起方需要订阅参与者 RPC 服务。跨服务 TCC 参与者服务订阅 基于 SOFARPC 发布的服务订阅 sofa:reference id="tccAction"interface...

SOFARPC 使用 SOFARegistry

主要存储的信息包括:服务提供方的地址信息 服务消费方的订阅信息 主要工作机制为:和服务消费方、服务提供方都建立长连接。动态感知服务发布地址变更并通知消费方。...软负载即软件负载,当需要调用服务时,消费方根据软负载策略,从 ...

HDFS指标

CopyBlockOpNumOps hdfs_datanode_rpc_CopyBlockOpNumOps DataNode RPC CopyBlock调用次数 HeartbeatsAvgTime hdfs_datanode_rpc_HeartbeatsAvgTime DataNode RPC Heartbeats调用平均时间。单位:毫秒。HeartbeatsNumOps hdfs_datanode_rpc...

uservice

初始化 RPC,设置 RPC 的命令号(cmd_id),命令调用的超时时间(timeout_ms),单位毫秒 参数:rpc:rpc cmd_id:RPC 的命令号 timeout_ms:命令调用等待超时时间,0时为异步调用,调用者立即返回,等于 AOS_WAIT_FOREVER为同步调用,等到...

自动故障剔除

自动故障剔除功能会自动监控 RPC 调用的情况,当某个节点出现故障时,可对故障节点进行权重降级,并在节点恢复健康时进行权重恢复。目前支持 Bolt 协议。配置方式 将自动故障剔除的参数配置到 SOFABoot 中的 application....配置示例 ...

自定义 Filter

}else if(response.isError()){ LOGGER.info("server rpc error:{}",response.getErrorMsg());}else{ Object ret=response.getAppResponse();if(ret instanceof Throwable){ LOGGER.error("server biz error:{}",(Throwable)ret);}else{ ...
< 1 2 3 4 ... 29 >
共有29页 跳转至: GO
新人特惠 爆款特惠 最新活动 免费试用