HSF 开发

 

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

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

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

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

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

HSF 标签清单

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 配置

 

 

 

 

 

 

 

 

 

 

 

标签配置示例： 

 

Consumer 配置 :

属性	描述
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 项目

通过上面第一、二章节我们已经在开发工具中配置好对应的插件，并且搭建了本地服务注册 配置中心，下面我们以一个 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 工程是 服务提供者应用。