多租户微服务中使用Java Config注册HSF服务

有了速卖通中间件的spring-boot-starter-hsf,在基于Spring Boot微服务中使用HSF,是件简单而惬意的事情。

我们首先来看最简单的服务注册

@HSFProvider(serviceInterface = QasHsfService.class, serviceVersion = "1.0.0.qas", serviceGroup = "HSF")
public class QasHsfServiceImpl implements QasHsfService {
...
}

再附上最简单的服务调用

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(QasHsfApplication.class)
public class QasHsfServiceConsumer {
    @HSFConsumer(serviceVersion = "1.0.0.qas", serviceGroup = "HSF")
    private QasHsfService qasHsfService;

    @Test
    public void testQuestion() {
        qasHsfService.question(new QasRequest());
    }
}

然后是入口类

@SpringBootApplication
@EnableHSF
@PropertySource("file:/opt/qas/qas.properties")
public class QasHsfApplication {
    public static void main(String[] args) {
        SpringApplication.run(QasHsfApplication.class, args);
    }
}

然后是……,没有了,就这么愉快地结束了。

以上代码实现,对于通用的微服务来说已经足够。但对于我们iDST的智能语音交互服务来说,还差点东西要填。

我们的每一种服务(确切地说,是由一份Java代码+一份C++代码编译后,容器化的一个镜像)会因为启动时引导的租户配置不同,而加载不同的算法模型。容器启动后,不同租户的服务,只在流程上是一致的。也就是说,镜像是一个,容器按租户分组。

那么,使用@HSFProvider这种静态注册服务的方式就不够用了,服务启动时,要从运维系统获取租户的分组信息,然后将其作为服务名称的一部分,注册为HSF服务。

这时,最理想、最优雅的方式就是使用Java Config来编程实现了:

@Configuration
public class QasHsfProviderConfig {
    @Bean(initMethod = "init")
    public HSFSpringProviderBean qasHsfProviderService() {
        HSFSpringProviderBean providerBean = new HSFSpringProviderBean();
        providerBean.setServiceInterface("com.aliyun.nls.hsf.QasHsfService");
        providerBean.setTarget(qasHsfServiceImpl());
        providerBean.setServiceVersion("1.0.0." + whoAmI());
        providerBean.setServiceGroup(HSFGroup.HSF.toString());
        return providerBean;
    }

    @Bean
    public QasHsfServiceImpl qasHsfServiceImpl() {
        return new QasHsfServiceImpl();
    }

    private String whoAmI() {
        //mock
        return "aliyun";
    }
}

相应地,服务调用可以是这样(调用端使用上述方式也是可以的,这里只为了保持风格一致,别怪我强迫症):

@Configuration
public class QasHsfConsumerConfig {

    @Bean(initMethod = "init",name="qasHsfConsumerService")
    public HSFSpringConsumerBean qasHsfConsumerService() {
        HSFSpringConsumerBean consumerBean = new HSFSpringConsumerBean();
        consumerBean.setInterfaceName("com.aliyun.nls.hsf.QasHsfService");
        consumerBean.setVersion("1.0.0.aliyun");
        consumerBean.setGroup(HSFGroup.HSF.toString());
        return consumerBean;
    }
}

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(QasHsfApplication.class)
public class QasHsfServiceConsumer {

    @Autowired
    @Qualifier("qasHsfConsumerService")
    private QasHsfService qasHsfService;

    @Test
    public void testQuestion() {
        qasHsfService.question(new QasRequest());
    }
}
上一篇:JAVA ssm b2b2c多用户商城系统源码-hystrix工作原理


下一篇:Java项目中调用bat批处理进行多用户数据库备份