前言

xrpc 协议插件 xrpc 协议插件的上传和部署 演示开发完私有 XML RPC 协议插件后部署和调用流程。ESB XML 协议插件深度解析 介绍金融场景 ESB 的协议接入。课后练习:通过 MOSN mecha 完成 xrpc 开发 介绍 xrpc 协议、xrpc 协议插件的开发...

XML 类型

当一个字符串不是使用 XMLPARSE 造型成 xml 或者不是使用 XMLSERIALIZE 从 xml 造型得到,对于 DOCUMENT 和 CONTENT 两者的选择是根据“XML option”会话配置参数决定的,它可以使用标准命令设置:SET XML OPTION { DOCUMENT|CONTENT };...

pom.xml配置

本文主要对 SOFABoot Web 工程和 Core 工程中的配置文件 pom.xml 进行说明。2 个工程在配置上的区别,主要是内容的不同。Web 工程的 pom.xml 配置说明 Web 工程完整版 pom.xml 配置,请参考 完整版 pom.xml。下文将就 SOFABoot Web 工程 ...

引入 SOFA 中间件

枚举值说明如下:DEV:表示 RPC 路由时,强制本地模式(客户端和服务端均在一台机器)。TEST:表示 RPC 路由时,强制 test-url 参数指定的地址(点对点连接)。NORMAL:表示 RPC 路由时,使用软负载的路由,也是线上正确的模式。...

异步处理

此种情况下不会造成下一个 RPC 请求错上一个请求的 tracerContext 数据问题 异步调用,由于异步回调并非是在 callback 中清理上下文,而是提前清理的,所以也不会存在数据串用问题。callback 异步回调,这个本质上就是异步调用,所以...

Apache HDFS透明缓存加速

jindofsx.hdfs.XXX.dfs.namenode.rpc-address.nn1 表示hdfs-site.xml中 dfs.namenode.rpc-address.XXX.nn1 的值。例如:master-1-1:8020。jindofsx.hdfs.XXX.dfs.namenode.rpc-address.nn2 表示hdfs-site.xml中 dfs.namenode.rpc-address....

调用重试

SOFARPC 支持进行框架层面的重试策略,前提是集群模式为 ...XML 方式 如果使用 XML 方式订阅服务,可以设置 sofa:global-attrs 的 retries 参数设置重试次数:<sofa:reference jvm-first="false"id="retriesServiceReferenceBolt"interface=...

Broker Load

对于不想导入,也不想记录为“错误数据”的数据,可以使用where predicate过滤。column_separator COLUMNS TERMINATED BY column_separator,用于指定导入文件中的列分隔符,默认为\t。如果是不可见字符,则需要加\x作为前缀,使用十六进...

引用 SOFARPC 服务

引用 RPC 服务 在配置文件 META-INF/APPNAME/APPNAME-web.xml 中,根据接口配置引用一个 RPC 服务:<sofa:reference id="sampleRpcService" interface="com.alipay.APPNAME.facade.SampleService"><sofa:binding.bolt/>此处的 RPC 引用也是...

发布 SOFARPC 服务

RPC 是日常开发中最常用的中间件,本文主要说明如何发布一个 RPC 服务。前提条件 已完成环境搭建。具体步骤,请参见 搭建环境。已下载 示例工程。已将工程导入 IDE 工具。具体操作,请参见 快速入门。发布 SOFARPC 服务 要发布一个 RPC ...

隔离功能扩展

SOFABoot 支持模块化隔离,在实际的使用场景中,一个模块中的 bean 有时候需要开放...客户端限制 由于扩展的定义强依赖 XML,因此虽然此处通过客户端发布扩展点和扩展,但是扩展自身的内容还是需要 XML 描述,并没有真正做到只使用客户端。

配置方式

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

发布和引用 JVM 服务

服务发布 使用方式 在实现类上加一个@SofaService 注解,对于该注解,说明如下:如果一个服务已经被加上了@SofaService 的注解,它就不能再 XML 的方式去发布服务了。两种方式不能混用。SofaService 的作用是将一个 Bean 发布成一个 JVM ...

SOFARPC 快速入门

微服务(SOFAStack MicroService)主要是通过 SOFARPC 实现服务的发布和引用,微服务中的其它模块也都围绕 SOFARPC 展开。本文以微服务本地开发到云端发布的整体流程为框架,让您了解 SOFARPC 如何在本地实现、如何发布到云端、如何...

Ark 服务通信

ss2:<sofa:reference interface="com.alipay.sofa.runtime.test.service.SampleService" id="sampleService" unique-id="ss2">说明 以上示例展示的是在 XML 的方式中使用 Unique ID,当您 Annotation 的方式发布 JVM 服务和引用的时候,...

RPC 常见问题

本文汇总梳理了 RPC 使用过程中遇到的常见问题及排查思路。使用 RPC 客户端调用服务时报错 调用服务时报“RPC-02306:没有获得服务[{0}]的调用地址,请检查服务是否已经推送”错误 排查思路如下:检查服务地址是否推送。登录客户端,查看/...

自定义线程池

在非 Spring 环境下使用 API 方式 如果是在非 Spring 环境下使用 API 的方式,您可以通过如下的方式设置自定义线程池。UserThreadPool threadPool=new UserThreadPool();threadPool.setCorePoolSize(10);threadPool.setMaximumPoolSize...

REST 服务快速入门

微服务(SOFAStack MicroService)主要是通过 SOFARPC 实现服务的发布和引用,而 SOFARPC 支持 REST 协议。本文以微服务本地开发到云端发布的整体流程为框架,让您了解如何在本地实现 SOFAREST 功能,以及如何将应用发布到云端,并在云端...

部署SDK

典型的情况是:如果使用Maven管理应用工程,可以将SDK开发包添加到 pom.xml 依赖中。将SDK开发包添加到 pom.xml 依赖中的示例如下:<dependency><groupId>com.taobao.txc</groupId> <artifactId>txc-client</artifactId> <version>${txc-...

YARN调度器

如果配置了队列优先级,同一层级的队列首先将分为两组,保障组(已使用资源小于等于保障资源)与超组(已使用资源大于保障资源),调度时优先为保障组分配资源,两组内部的所有队列再按优先级从大到小、保障资源使用比例从小到大进行排序...

实时数仓Hologres

本文为您介绍如何使用实时数仓Hologres连接器。背景信息 实时数仓Hologres 是一站式实时数据仓库引擎,支持海量数据实时写入、实时更新、实时分析,支持标准SQL(兼容PostgreSQL协议),支持PB级数据多维分析(OLAP)与即席分析(Ad Hoc)...

V2版本RPC风格请求体&签名机制

本文介绍了阿里云 OpenAPI 的 RPC风格接口,包括RPC OpenAPI 请求的组成部分,如何通过这些组成部分构造一个 OpenAPI 请求,如何获取返回结果以及签名机制等。阿里云 RPC OpenAPI 向开发者提供HTTP接口,如果您想要自研阿里云RPC调用风格的...

概述

产品特性 高可用 SOFARPC 提供软件负载均衡的能力,它是对等服务调用的调度器,会帮助服务消费方在这些对等的服务提供方中合理地选择一个执行相关的业务逻辑。高容错 一切服务调用的容错机制均由软负载和配置中心控制,这样可以在应用...

版本说明

RPC 优化了 Mesh 场景下的使用,添加 Rest 协议支持。注册中心支持订阅线程池的相关配置。更新 依赖的 SOFABoot 开源版本从 3.19.1 升级至 3.21.0,版本说明请参见 发布说明。依赖的 Spring Boot 版本从 2.7.15 升级至 2.7.18,版本说明请...

快速入门

接口需要的相关类与方法如下:/Rpc调用回调 public interface PushRpcListener {/*@param errorCode int rpc调用返回的错误码*@param response String rpc调用返回的response*/void onReply(int errorCode,String response);}/Rpc设置 ...

配置StarRocks集群以访问高可用数据集群

如果您所使用的数据集群开启了高可用,那么在查询高可用集群中的HDFS数据时,您需要进行额外的配置。建议您按照本文的操作步骤配置StarRocks集群,以实现HDFS的高可用性。前提条件 已创建包含了HDFS服务,并且开启了服务高可用的集群...

链路数据透传

链路数据透传功能支持应用向调用上下文中存放数据,使得整个链路上的应用都可以操作该数据。您可以分别向链路的 request 和 response 中放入数据...所以整体看,两者各有利弊,在有一些和业务相关的透传数据的情况下,可以选择 RPC 的透传。

配置 Bolt 服务

Bolt 服务的名称源自 RPC 使用的底层通信框架 Bolt。相对于传统的 WebService,Bolt 支持更加复杂的对象,序列化后的对象更小,且提供了更为丰富的调用方式(sync、oneway、callback、future 等),支持更广泛的应用场景。在 SOFA 中,Bolt...

移动网关常见问题

客户端在到 amr 包并解压后,会使用在项目中预置的公钥进行签名的验证。解密步骤 2 中的密文得到一个 hash 值,同时本地计算离线包的 hash 值,判断两者是否相同,如果相同则通过验证。注意 虽然离线包验签过程可以保证离线包在传输和...

通过HDFS FUSE连接并使用文件引擎

本章介绍如何使用HDFS FUSE访问文件引擎。准备运行环境 安装JDK并设置JAVA_HOME,检查JDK版本:$JAVA_HOME/bin/java-version CentOS/RedHat sudo yum install java-1.8.0-openjdk-devel-y Ubuntu sudo apt-get update sudo apt-get install...

Hadoop

site.xml中的dfs.ha.namenodes.${nameservices} 无 spark.hadoop.dfs.namenode.rpc-address.${nameservices}.${nn1/nn2} 对hdfs-site.xml中的dfs.namenode.rpc-address.${nameservices}.${nn1/nn2} 注意这里应该填写namenode域名对应的ip...

基础术语

使用一种基于 Groovy 的特定领域语言(DSL)声明项目设置,抛弃了基于 XML 的各种繁琐配置。Jetty Jetty Jetty 是一个开源的 Java servlet 容器,它为基于 Java 的 Web 容器,例如 JSP 和 servlet,提供运行环境。Log4j Log4j Apache ...

YARN高安全特性使用指南

队列ACL可以结合Capacity Scheduler调度器队列映射(Queue Mapping)特性使用,在 capacity-scheduelr.xml 配置文件中使用 yarn.scheduler.capacity.queue-mappings 配置用户或用户组提交作业的默认队列规则,通过 yarn.scheduler.capacity...

其他常见问题

如何使用 dependencyManagement 添加 SOFABoot 依赖 工程原型中是 parent 标签引入 SOFABoot 的间接依赖。也可以使用 dependencyManagement 添加依赖,如下所示:<dependencyManagement><dependencies>!SOFABoot dependencies->...

Hive

本文主要介绍如何使用DLA Spark访问用户VPC中的Hive集群。重要 云原生数据湖分析(DLA)产品已退市,云原生数据仓库 AnalyticDB MySQL 版 湖仓版支持DLA已有功能,并提供更多的功能和更好的性能。AnalyticDB for MySQL 相关使用文档,请...

调用方式

威胁情报通过使用AccessKey ID和AccessKey Secret进行对称加密的方法验证请求的发送者身份。AccessKey是为阿里云账号和RAM用户发布的一种身份凭证(类似于用户的登录密码),其中AccessKey ID用于标识访问者的身份,AccessKey Secret是...

数据导入常见问题

如果阈值过大,可能会导致远程过程调用超时,此时需要配合BE配置文件中的 tablet_writer_rpc_timeout_sec 参数适当地调整 write_buffer_size 参数的取值。BE配置项的更多信息,请参见 参数配置。报错“Value count does not match column...

领域模型概述

对于同步链路,需要实时返回调用结果的场景,建议使用RPC调用方案。您在进行产品选型时,请明确您的业务场景和主要需求。消息队列RocketMQ版领域模型 如上图所示,云消息队列 RocketMQ 版 中消息的生命周期主要分为消息生产、消息存储、...

产品架构

DataServer(数据服务器):负责存储客户端发布数据,数据存储按照数据 ID 进行一致性 hash 分片存储数据存储按照数据 ID 使用自定义 slot 分配算法分片存储,支持多副本备份,保证数据高可用。DataServer 可无限扩展以支持海量数据。...

调用方式

阿里云验证码通过使用AccessKey ID和AccessKey Secret进行对称加密的方法验证请求的发送者身份。AccessKey是为阿里云账号和RAM用户发布的一种身份凭证(类似于用户的登录密码),其中AccessKey ID 用于标识访问者的身份,AccessKey ...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云联络中心 全局事务服务 (文档停止维护) 号码隐私保护 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用