HSF 开发

 

HSF 简介 HSF(High Speed Service Framework),高速服务框架,是阿里-主要采用的服务框架,其目的是 做为桥梁联通不一样的业务系统,解耦系统之间的实现依赖。java

1: RPC 远程过程调用(Remote Procedure Call)是一种经过网络从远程计算机程序上请求服务的协 议,它的特色在于不须要了解底层网络技术。在 OSI 网络通讯模型中,RPC 跨越了传输层和 应用层。RPC 使得开发分布式应用更加容易web

2: ConfigServer(地址注册中心) HSF 是一个 RPC 框架,服务端须要将地址发送到注册中心让客户端可以进行服务发现,客 户端须要经过注册中心订阅一个服务的地址。服务与地址的对应关系是多对多的关系,一个 服务能够由多个地址提供,一      个地址能够提供多种服务。当一个服务有了新地址(机器)或 者减小了地址(机器)时,注册中心会通知这个服务的订阅方将地址增长或者减小,这个注 册中心就是 Configserver,它负责存储地址信息以及地址变动的推送。spring

3: Diamond(配置中心) HSF 持久化的配置中心是 Diamond。HSF 提供软负载服务,其中的路由规则是在 Diamond 上 进行配置,而后推送到客户端进行解析,第二章节中开发环境搭建已经包含 Diamond。api

4: Pandora Pandora 是 HSF 生存的容器,由 pandora 来管理整个 HSF 的生命周期和二方包的隔离网络

HSF 标签清单app

Provider 配置:框架

属性 描述
interface interface 必须配置[String],为服务对外提供的接口
version version 为可选配置[String],含义为服务的版本,默认为 1.0.0
group serviceGroup 为可选配置[String],含义为服务所属的组别,以便按 组别来管理服务的配置,默认为 HSF
clientTimeout 该配置对接口中的全部方法生效,可是若是客户端经过 MethodSpecial 属性对某方法配置了超时时间,则该方法的超时时间以客户端配置为准,其余方法不受影响,仍是以服务端配置为 准
serializeType serializeType 为可选配置[String(hessian|java)],含义为序列化类 型,默认为 hessian
corePoolSize 单独针对这个服务设置核心线程池,是从公用线程池这个大蛋糕 里切一块下来
maxPoolSize 单独针对这个服务设置线程池,是从公用线程池这个大蛋糕里切 一块下来
enableTXC 开启分布式事务 Txc
ref ref 必须配置[ref],为须要发布为 HSF 服务的 spring bean id
methodSpecials methodSpecials 为可选配置,用于为方法单独配置超时(单位 ms), 这样接口中的方法能够采用不一样的超时时间,该配置优先级高于 上面的 clientTimeout 的超时配置,低于客户端的 methodSpecials 配置

 

 

 

 

 

 

 

 

 

 

 

标签配置示例:  eclipse

 

Consumer 配置 :
webapp

属性 描述
interface interface 必须配置[String],为须要调用的服务的接口。
version version 为可选配置[String],含义为须要调用的服务的版本,默认为 1.0.0
group group 为可选配置[String],含义为须要调用的服务所在 的组,默认为 HSF,建议配置。
methodSpecials methodSpecials 为可选配置,含义为为方法单独配置超时 (单位 ms),这样接口中的方法能够采用不一样的超时时间, 该配置优先级高于服务端的超时配置。
target 主要用于单元测试环境和 hsf.runmode=0 的开发环境中, 在运行环境下,此属性将无效,而是采用配置中心推送回 来的目标服务地址信息。
connectionNum connectionNum 为可选配置,含义为支持设置链接到 server 链接数,默认为 1,在小数据传输,要求低延迟的状况下设 置多一些,会提高 tps。
clientTimeout 客户端统一设置接口中全部方法的超时时间(单位 ms),超 时设置优先级由高到低是:客户端 MethodSpecial,客户端 接口级别,服务端 MethodSpecial,服务端接口级别。
asyncallMethods

asyncallMethods 为可选配置[List],含义为调用此服务时需 要采用异步调用的方法名列表以及异步调用的方式。 异步

默认为空集合,即全部方法都采用同步调用。

maxWaitTimeForCsAddress 配置这个,在服务订阅的时候,会在指定的时间内,等待 地址推送过来,避免地址为过来后,调用该服务出现找不 到地址的状况,超过指定时间未等到地址,将继续初始化 完成。

 

 

 

 

 

 

 

 

 

 

 

 

 

 

标签配置示例: 

 

HSF jvm 参数配置

-Dhsf.server.port

指定 HSF 的启动服务绑定端口,默认为 12200

-Dhsf.serializer

指定 HSF 的序列化方式,默认值为 hessian

-DdefaultHsfClientTimeout

指定 HSF 的客户端超时时间 ms,默认为 3000

-Dhsf.server.max.poolsize

指定 HSF 的服务端最大线程池大小,默认值为 600

-Dhsf.server.min.poolsize 指定 HSF 的服务端最小线程池大小。默认值为 50

 

HSF 基础开发

参考下面的 demo 编写示例,来快速的开发一个基础版的 HSF 应用

1 建立 Web 项目

经过上面第1、二章节咱们已经在开发工具中配置好对应的插件,而且搭建了本地服务注册 配置中心,下面咱们以一个 demo 展开介绍 Hsf 开发的相关细节。

以 eclipse 为例建立一个 maven web 项目。

请点击 File -> New -> Project -> Maven Project -> maven-archetype-webapp ,在弹 出的界面输入 groupId、artifactId ,而后连续点击 Next,完成项目建立。项目目录结构 如图:

2 添加 Maven 依赖

在项目 pom.xml 中添加以下依赖:

3 编写发布 HSF 的服务

建立须要发布的服务接口:com.alibaba.edas.SampleService

编写实现类:com.alibaba.edas.impl.SampleServiceImpl

4 发布服务配置文件

请按照如下步骤配置发布者的服务配置文件。

  1. 在 web.xml 中配置 spring 的监听器:

  

  2. 在 resources 目录下面添加 spring 配置文件:application-config.xml

    

  <?xml version="1.0" encoding="UTF-8"?>
  <beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">

<import resource="hsf-provider-beans.xml"/>
<!--<import resource="hsf-consumer-beans.xml"/>-->

  </beans>

  3. 在 resources 目录下面添加发布者的配置文件:hsf-provider-beans.xml

  <?xml version="1.0" encoding="UTF-8"?>
  <beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:hsf="http://www.taobao.com/hsf"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.taobao.com/hsf
http://www.taobao.com/hsf/hsf.xsd" default-autowire="byName">

  <bean id="stationService" class="com.sgcc.echarge.stationserver.service.StationServiceHsfImpl"/>
   <hsf:provider version="1.0.0" group="grp_sgcc_xpcz_app" ref="stationService"
id="stationSP" interface="com.sgcc.echarge.proxy_hsfapi.station.iface.StationService"/>

  </beans>

  到此发布者就编写好了。

4. 右键点击建立的项目,点击 Run As,选择 Run configuration,在弹出页面选择 AliTomcat Webapp, 右键 new 新建,以下图:

  

5. 填写好相关配置,点击 Run,启动应用,此时经过第二章节建的配置中心能够看到发布 的服 务,以下图:

   

5 消费服务配置文件

1. 在配置文件 application-config.xml 添加消费者配置:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">

<import resource="hsf-consumer-beans.xml"/>

</beans>
2. 在 resources 目录下面添加消费者的配置文件 hsf-consumer-beans.xml 配置:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:hsf="http://www.taobao.com/hsf"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.taobao.com/hsf
http://www.taobao.com/hsf/hsf.xsd" default-autowire="byName">

<hsf:consumer version="1.0.0" group="grp_sgcc_xpcz_app" clientTimeout="1000000"
id="helloServiceConsumer" interface="com.sgcc.echarge.proxy_hsfapi.station.iface.StationService"/>

</beans>
3. 已经完成了消费者的定义

6 Demo 下载地址
经过以下地址下载: http://edas-public.oss-cn-hangzhou.aliyuncs.com/install_package%2Fedas-app-demo%2Fedas-ap p-demo.zip 将下载下来的压缩包解开后,能够看到 itemcenter-api,itemcenter 和 detail 三个 Maven 工程。其中 itemcenter-api 工程提供接口定义,detail 工程是消费者应用,Itemcenter 工程是 服务提供者应用。
相关文章
相关标签/搜索