服务框架HSF分析之一容器启动
?
大家平时都在用这个服务框架。简单阅读了下代码，了解其原理可以方便解决一些常见hsf的问题。限于篇幅，整个分析将分几个系列发布。第一篇将简单介绍Hsf的启动和各组件之间关系。
?
一.? Hsf总体架构
?
?
?
这个图很经典，想必大家都了解，Consumer，Provider，中间通过ConfigServer联接。那么其内部是如何实现的呢？请看下文。
二.? 容器启动，jboss为例
HSF使用基于equinox(OSGi框架的eclipse实现,http://www.eclipse.org/equinox/)的OSGi，启动流程
?
?
?
1.?????/opt/xxxx/jboss/server/default/conf/xmdesc/org.jboss.deployment.MainDeployer-xmbean.xml指定sar优先加载:
?
050:.deployer,050:-deployer.xml,100:.aop,100:-aop.xml,150:.sar,150:-service.xml,200:.beans,250:.rar,300:-ds.xml,350:.har,400:.jar,400:.ejb3,400:.par,500:.war,…?
?
2.??????taobao-hsf.sar/META-INF/jboss-service.xml 指定初始化类:
?
<server> <mbeancode="com.xxxx.hsf.thirdcontainer.jboss.HSFContainerDelegator"name="hsf:service=containerdelegator"> </mbean></server>?
?
3.?????设置Jboss的class loader给HSF，以便HSF访问Jboss的类：
?
HSFContainer.setThirdContainerClassLoader(jbossClassloader);?
?
4.?????启动hsf容器?
?
HSFContainer.start(null);?
?
4.1? 寻找HSF的plugins
4.2 配置Equinox
?
FrameworkProperties.setProperty("osgi.syspath", searchPath);…..??
4.3? 启动 Equinox
?
EclipseStarter.run(new String[] { "-configuration","hsf.configuration" }, null);??
这里HSF使用了OSGi的Declarative Service(http://www.ibm.com/developerworks/cn/opensource/os-ecl-osgids/index.html)方式来启动，典型配置如下:
OSGI下的配置文件
?
<?xml version="1.0"encoding="UTF-8"?><component name="ConfigurationComponent"> <service> <provide interface="com.xxxx.hsf.configuration.service.ConfigurationService"/> </service> <implementation name="code">context = EclipseStarter.getSystemBundleContext();?
?
5.?????将hsf暴露的类注册到jboss的classloader中，方便后续app中使用，典型的比如HSFSpringProviderBean和HSFSpringConsumerBean
?
Map<String,Class<?>> exportedClasses = HSFContainer.getExportedClasses(); for (String className : exportedClasses.keySet()) { jbossRepo.cacheLoadedClass(className, exportedClasses.get(className),jbossClassloader); } ??
三.? Provider启动
当APP启动时，会用spring加载hsf的配置文件，典型provider如下:
?
<beaninit-method="init"> <propertyname="serviceInterface"> <value>com.xxxx.ump.core.service.PromotionReadService</value> </property> <propertyname="serviceName"> <value>PromotionReadService</value> </property> <propertyname="target"> <ref bean="promotionReadService"/> </property>?
?
……
??因为容器初始化时已经将HSF的类注册到了jboss的classloader中，所以在spring中可以找到HSFSpringProviderBean类定义，开始provider的初始化。
??Provider角度看，类图如下:
?
?
ProcessService是核心控制流程类，掌管发布和消费的入口。从provider端来看，基本流程如下:
1.根据服务类型，注册服务提供者，保证服务在本机的唯一性，关联业务层和通讯层。在这里会做应用服务器的初始化，服务线程池分配（如果配置）。最终的TBRemotingRPCProtocolComponent.registerProvider代码如下：
?
// 仅启动一次HSF SERVER …….providerServer.startHSFServer();…… // 注册对象到HSFServer上 providerServer.addMetadata(metadata.getUniqueName(), metadata); providerServer.addWorker(metadata.getUniqueName(),metadata.getTarget());?
?
应用服务器初始化后，本地hsf端口12200打开，可以接受请求。在这一步，我们可以通过配置修改hsf的运行期参数，比如端口，业务线程数等。
2.通过Publisher将服务注册到configServer上
四.? Consumer启动
?????当消费者启动时，我们会这样配置:
?
<beanid="shopReadServiceImpl"init-method="init"> <property name="interfaceName"> <value>com.xxxx.shopservice.core.client.ShopReadService</value> </property>?
?
? 同样通过jboss的classloader我们可以找到HSFSpringConsumerBean这个类定义，开始consumer的初始化。
? 从consumer角度看，类图如下:
?
?
同样通过ProcessService的consume方法生成一个调用的代理类。流程如下:
1.?使用jdk动态代理，生成调用远程HSF服务的代理
InvocationHandler handler = newHSFServiceProxy(metadata); Object proxyObj = Proxy.newProxyInstance(getClass().getClassLoader(), newClass[] { interfaceClass }, handler);?生成的代理类叫HSFServiceProxy，其invoke方法使用TBRemotingRPCProtocalComponent组件调用通讯层接口，发送请求。
2.?????通过metadataService订阅服务信息，包括：
a.?????通过diamond订阅服务路由规则和流量规则，路由规则即调用哪些机器，hsf可以限制consumer的调用机器范围，流量规则即流控策略，hsf可以通过推送规则限流。
b.?????通过configServer的client订阅服务地址信息，这里可以拿到所有提供该service的机器地址，consumer根据之前获得的路由规则和访问策略(默认随机)来决定请求哪台机器。
?
?
五．?????????????小结
本文简单分析了hsf容器的启动，后续将分析具体的consume和provide过程