消费者订阅服务是什么？_问答-阿里云开发者社区

消费者的订阅从代码编写的角度分为两个部分：首先 Spring 的配置文件使用标签<hsf:consumer/>定义好一个 Bean；然后在使用的时候从 Spring 的 context 中将 Bean 取出来即可。Demo 工程的 detail 为消费者的示例，示例代码说明如下。

消费者配置

与生产者一样消费者的配置文件分为 Maven 依赖配置与 Spring 的配置，且 Maven 的依赖与生产者依赖一样，详情请参考文档生产者实现服务的 [backcolor=transparent]服务配置小节。
除了必要的 Spring 所定义的配置之外，还需要在 Spring 的配置文件中增加消费者的定义，HSF 框架将根据该配置文件去服务中心订阅所需的服务，配置文件 /resource/hsf-consumer-beans.xml 内容与释义如下：

[backcolor=transparent]<?[backcolor=transparent]xml version[backcolor=transparent]=[backcolor=transparent]"1.0"[backcolor=transparent] encoding[backcolor=transparent]=[backcolor=transparent]"UTF-8"[backcolor=transparent]?>
[backcolor=transparent]<beans[backcolor=transparent] [backcolor=transparent]xmlns:xsi[backcolor=transparent]=[backcolor=transparent]"http://www.w3.org/2001/XMLSchema-instance"
[backcolor=transparent] [backcolor=transparent]xmlns:hsf[backcolor=transparent]=[backcolor=transparent]"http://www.taobao.com/hsf"
[backcolor=transparent] [backcolor=transparent]xmlns[backcolor=transparent]=[backcolor=transparent]"http://www.springframework.org/schema/beans"
[backcolor=transparent] [backcolor=transparent]xsi:schemaLocation[backcolor=transparent]=[backcolor=transparent]"http://www.springframework.org/schema/beans
[backcolor=transparent] http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
[backcolor=transparent] http://www.taobao.com/hsf
[backcolor=transparent] http://www.taobao.com/hsf/hsf.xsd"[backcolor=transparent] [backcolor=transparent]default-autowire[backcolor=transparent]=[backcolor=transparent]"byName"[backcolor=transparent]>
[backcolor=transparent] [backcolor=transparent]
[backcolor=transparent] <hsf:consumer
[backcolor=transparent] [backcolor=transparent]
[backcolor=transparent] id="item"
[backcolor=transparent] [backcolor=transparent]
[backcolor=transparent] interface="com.alibaba.edas.carshop.itemcenter.ItemService"
[backcolor=transparent] [backcolor=transparent]
[backcolor=transparent] version="1.0.0"
[backcolor=transparent] [backcolor=transparent]
[backcolor=transparent] group="testHSFGroup">
[backcolor=transparent] [backcolor=transparent]</hsf:consumer>
[backcolor=transparent]</beans>

消费者使用服务

Demo 中的示例代码如下：

[backcolor=transparent]public[backcolor=transparent] [backcolor=transparent]class[backcolor=transparent] [backcolor=transparent]StartListener[backcolor=transparent] [backcolor=transparent]implements[backcolor=transparent] [backcolor=transparent]ServletContextListener[backcolor=transparent]{
[backcolor=transparent] [backcolor=transparent]@Override
[backcolor=transparent] [backcolor=transparent]public[backcolor=transparent] [backcolor=transparent]void[backcolor=transparent] contextInitialized[backcolor=transparent]([backcolor=transparent] [backcolor=transparent]ServletContextEvent[backcolor=transparent] sce [backcolor=transparent])[backcolor=transparent] [backcolor=transparent]{
[backcolor=transparent] [backcolor=transparent]ApplicationContext[backcolor=transparent] ctx [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]WebApplicationContextUtils[backcolor=transparent].[backcolor=transparent]getWebApplicationContext[backcolor=transparent]([backcolor=transparent] sce[backcolor=transparent].[backcolor=transparent]getServletContext[backcolor=transparent]()[backcolor=transparent] [backcolor=transparent]);
[backcolor=transparent] [backcolor=transparent]// 根据 Spring 配置中的Bean ID “item” 获取订阅到的服务
[backcolor=transparent] [backcolor=transparent]final[backcolor=transparent] [backcolor=transparent]ItemService[backcolor=transparent] itemService [backcolor=transparent]=[backcolor=transparent] [backcolor=transparent]([backcolor=transparent] [backcolor=transparent]ItemService[backcolor=transparent] [backcolor=transparent])[backcolor=transparent] ctx[backcolor=transparent].[backcolor=transparent]getBean[backcolor=transparent]([backcolor=transparent] [backcolor=transparent]"item"[backcolor=transparent] [backcolor=transparent]);
[backcolor=transparent] [backcolor=transparent]……
[backcolor=transparent] [backcolor=transparent]// 调用服务 ItemService 的 getItemById 方法
[backcolor=transparent] [backcolor=transparent]System[backcolor=transparent].[backcolor=transparent]out[backcolor=transparent].[backcolor=transparent]println[backcolor=transparent]([backcolor=transparent] itemService[backcolor=transparent].[backcolor=transparent]getItemById[backcolor=transparent]([backcolor=transparent] [backcolor=transparent]1111[backcolor=transparent] [backcolor=transparent])[backcolor=transparent] [backcolor=transparent]);
[backcolor=transparent] [backcolor=transparent]// 调用服务 ItemService 的 getItemByName 方法
[backcolor=transparent] [backcolor=transparent]System[backcolor=transparent].[backcolor=transparent]out[backcolor=transparent].[backcolor=transparent]println[backcolor=transparent]([backcolor=transparent] itemService[backcolor=transparent].[backcolor=transparent]getItemByName[backcolor=transparent]([backcolor=transparent] [backcolor=transparent]"myname is le"[backcolor=transparent] [backcolor=transparent])[backcolor=transparent] [backcolor=transparent]);
[backcolor=transparent] [backcolor=transparent]……
[backcolor=transparent] [backcolor=transparent]}
[backcolor=transparent]}

消费者配置属性清单

除了示例代码中体现的属性(interface，group，version)之外，还有下表的属性配置以供选择：

属性	描述
interface	interface 必须配置 [String]，为需要调用的服务的接口。
version	version 为可选配置 [String]，含义为需要调用的服务的版本，默认为1.0.0。
group	group 为可选配置 [String]，含义为需要调用的服务所在的组，以便按组别来管理服务的配置，默认为 HSF，建议配置。
methodSpecials	methodSpecials 为可选配置，含义为为方法单独配置超时(单位 ms)，这样接口中的方法可以采用不同的超时时间，该配置优先级高于服务端的超时配置。
target	主要用于单元测试环境和开发环境中在消费者端指定 -Dhsf.run.mode=0 的情况下，在运行环境下，此属性将无效，而是采用配置中心推送回来的目标服务地址信息。
connectionNum	connectionNum 为可选配置，含义为支持设置连接到 server 连接数，默认为1，在小数据传输，要求低延迟的情况下设置多一些，会提升 TPS。
clientTimeout	客户端统一设置接口中所有方法的超时时间(单位 ms)，超时设置优先级由高到低是：客户端 MethodSpecial，客户端接口级别，服务端 MethodSpecial，服务端接口级别。
asyncallMethods	asyncallMethods 为可选配置 [List]，含义为调用此服务时需要采用异步调用的方法名列表以及异步调用的方式。默认为空集合，即所有方法都采用同步调用。
maxWaitTimeForCsAddress	配置该参数，目的是当服务进行订阅时，会在该参数指定时间内，阻塞线程等待地址推送，避免调用该服务时因为地址为空而出现地址找不到的情况。若超过该参数指定时间，地址还是没有推送，线程将不再等待，继续初始化后续内容。

标签配置示例:

[backcolor=transparent]<hsf:consumer[backcolor=transparent] [backcolor=transparent]id[backcolor=transparent]=[backcolor=transparent]"service"[backcolor=transparent] [backcolor=transparent]interface[backcolor=transparent]=[backcolor=transparent]"com.taobao.edas.service.SimpleService"
[backcolor=transparent] [backcolor=transparent]version[backcolor=transparent]=[backcolor=transparent]"1.1.0"[backcolor=transparent] [backcolor=transparent]group[backcolor=transparent]=[backcolor=transparent]"test1"[backcolor=transparent] [backcolor=transparent]clientTimeout[backcolor=transparent]=[backcolor=transparent]"3000"
[backcolor=transparent] [backcolor=transparent]target[backcolor=transparent]=[backcolor=transparent]"10.1.6.57:12200?_TIMEOUT=1000"[backcolor=transparent] [backcolor=transparent]maxWaitTimeForCsAddress[backcolor=transparent]=[backcolor=transparent]"5000"[backcolor=transparent]>
[backcolor=transparent] [backcolor=transparent]<hsf:methodSpecials>
[backcolor=transparent] [backcolor=transparent]<hsf:methodSpecial[backcolor=transparent] [backcolor=transparent]name[backcolor=transparent]=[backcolor=transparent]"sum"[backcolor=transparent] [backcolor=transparent]timeout[backcolor=transparent]=[backcolor=transparent]"2000"[backcolor=transparent] [backcolor=transparent]></hsf:methodSpecial>
[backcolor=transparent] [backcolor=transparent]</hsf:methodSpecials>
[backcolor=transparent]</hsf:consumer>

pom 中添加 edas-sdk 依赖

[backcolor=transparent]<dependency>
[backcolor=transparent] [backcolor=transparent]<groupId>[backcolor=transparent]com.alibaba.edas[backcolor=transparent]</groupId>
[backcolor=transparent] [backcolor=transparent]<artifactId>[backcolor=transparent]edas-sdk[backcolor=transparent]</artifactId>
[backcolor=transparent] [backcolor=transparent]<version>[backcolor=transparent]1.6.1[backcolor=transparent]</version>
[backcolor=transparent]</dependency>