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>