zoukankan      html  css  js  c++  java
  • 以API 配置的方式来配置你的 Dubbo 应用

    package com.aswatson.csc.member.conf;
    
    import com.aswatson.csc.member.service.MemberCardService;
    import java.util.HashMap;
    import java.util.Map;
    import javax.annotation.PostConstruct;
    import org.apache.dubbo.config.ConfigCenterConfig;
    import org.apache.dubbo.config.RegistryConfig;
    import org.apache.dubbo.config.ServiceConfig;
    import org.apache.dubbo.rpc.model.ApplicationModel;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.stereotype.Component;
    
    /**
     * @Author Tim
     * @Date 2021/11/5 14:22
     */
    @Component
    public class DubboConfig {
    
        //可以动态配置memberCardService
        public DubboConfig(@Autowired ApplicationContext applicationContext, @Value("${dubbo.registry.protocol}") String protocol, @Value("${dubbo.registry.address}") String address)
            throws ClassNotFoundException {
    
            Object serviceObj = applicationContext.getBean("memberCardService");
            Class clazz = Class.forName("com.aswatson.csc.member.service.MemberCardService");
    
            RegistryConfig registryConfig = new RegistryConfig();
            registryConfig.setAddress(protocol + "://" + address);
            ServiceConfig service = new ServiceConfig();
            service.setApplication(ApplicationModel.getConfigManager().getApplicationOrElseThrow());
            service.setRegistry(registryConfig);
            service.setInterface(clazz);
            service.setRef(serviceObj);
            service.setVersion("1.0");
            service.export();
        }
    
         //测试写死memberCardService
    //    public DubboConfig(@Autowired ApplicationContext applicationContext, @Value("${dubbo.registry.protocol}") String protocol, @Value("${dubbo.registry.address}") String address) {
    //        RegistryConfig registryConfig1 = new RegistryConfig();
    //        registryConfig1.setAddress(protocol + "://" + address);
    //        ServiceConfig<MemberCardService> service = new ServiceConfig<MemberCardService>();
    //        service.setApplication(ApplicationModel.getConfigManager().getApplicationOrElseThrow());
    //        service.setRegistry(registryConfig1);
    //        service.setInterface(MemberCardService.class);
    //        service.setRef((MemberCardService) applicationContext.getBean("memberCardService"));
    //        service.setVersion("1.0");
    //        service.export();
    //    }
    
    }
    路在脚下
  • 相关阅读:
    Windows API 第六篇 GetLocalTime
    _itoa _itow _itot atoi atof atol
    Window API 第五篇 WTSEnumerateProcesses
    获取计算机以及本机信息API
    Windows API 第四篇 文件操作
    [软工顶级理解组] 团队介绍和采访!
    2019 SDN上机第1次作业
    第01组 团队项目-需求分析报告
    团队项目-选题报告
    第二次结对编程作业
  • 原文地址:https://www.cnblogs.com/lgg20/p/15530432.html
Copyright © 2011-2022 走看看