677      阿里云  技术社区[云栖]

消费者订阅服务__服务开发_开发者指南_企业级分布式应用服务 EDAS-阿里云

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

消费者配置

与生产者一样消费者的配置文件分为 Maven 依赖配置与 Spring 的配置，且 Maven 的依赖与生产者依赖一样，详情请参考文档生产者实现服务的服务配置小节。

除了必要的 Spring 所定义的配置之外，还需要在 Spring 的配置文件中增加消费者的定义，HSF 框架将根据该配置文件去服务中心订阅所需的服务，配置文件 /resource/hsf-consumer-beans.xml 内容与释义如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance"
        xmlns:hsf="https://www.taobao.com/hsf"
        xmlns="https://www.springframework.org/schema/beans"
        xsi:schemaLocation="https://www.springframework.org/schema/beans
        https://www.springframework.org/schema/beans/spring-beans-2.5.xsd
        https://www.taobao.com/hsf
        https://www.taobao.com/hsf/hsf.xsd" default-autowire="byName">
        <!-- 消费一个服务示例 -->
        <hsf:consumer
            <!-- Bean ID，在代码中可根据此ID进行注入并使用  -->
            id=“item"
            <!-- 服务名，与服务提供者的相应配置对应，HSF 将根据 interface + version + group 查询并订阅所需服务  -->
            interface="com.alibaba.edas.carshop.itemcenter.ItemService"
            <!-- 版本号，与服务提供者的相应配置对应，HSF 将根据 interface + version + group 查询并订阅所需服务  -->
            version="1.0.0"
            <!-- 分组名，与服务提供者的相应配置对应，HSF 将根据 interface + version + group 查询并订阅所需服务  -->
            group="testHSFGroup">
        </hsf:consumer>
</beans>

消费者使用服务

Demo 中的示例代码如下：

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

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