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();
    //    }
    
    }
    路在脚下
  • 相关阅读:
    基于Redis的短链接设计思路
    再谈对协变和逆变的理解(Updated)
    Java基础—ClassLoader的理解
    遇到个小问题,Java泛型真的是鸡肋吗?
    一次失败升级后的反思
    JVM是如何分配和回收内存?有实例!
    一个Java对象到底占用多大内存?
    《深入理解Java虚拟机》读书笔记:垃圾收集器与内存分配策略
    快速掌握RabbitMQ(二)——四种Exchange介绍及代码演示
    快速掌握RabbitMQ(一)——RabbitMQ的基本概念、安装和C#驱动
  • 原文地址:https://www.cnblogs.com/lgg20/p/15530432.html
Copyright © 2011-2022 走看看