标签：dubbo return String flowable 接口 version private new referenceConfig

我们的系统采用是dubbo作为soa，但是如何动态调用dubbo接口呢？

1：MyReferenceUtils 类

@Component
public class MyReferenceUtils {

    @Value("${dubbo.registry.address}")
    private String registryAddress;
    @Value("${dubbo.application.name}")
    private String appllicationName;
    /**
     * 协议
     */
    private static final String protocol = "zookeeper";
    /**
     * 不需要检测提供者
     */
    private static final Boolean check = false;
    /**
     * 调用超时时间 毫秒
     */
    private static final Integer timeout = 300000;

    /**
     * 获取缓存的MyReferenceConfig
     *
     * @param insterfaceName 接口全名
     * @param version        版本号
     * @return
     */
    public GenericService getCacheGenericServiceByKey(String insterfaceName, String version) {
        ReferenceConfigCache cache = ReferenceConfigCache.getCache();
        ReferenceConfig<GenericService> referenceConfig = this.createReferenceConfig(appllicationName, registryAddress, protocol, check, timeout);
        referenceConfig.setId(insterfaceName);
        // 弱类型接口名
        referenceConfig.setInterface(insterfaceName);
        // 设置版本
        referenceConfig.setVersion(version);
        // 声明为泛化接口
        referenceConfig.setGeneric(true);
        return cache.get(referenceConfig);
    }

    /**
     * 创建ReferenceConfig 对象
     *
     * @param applicationName 应用名
     * @param address         地址
     * @param protocol        协议
     * @param check           是否检测提供者
     * @param timeout         超时时间
     * @return
     */
    private ReferenceConfig<GenericService> createReferenceConfig(String applicationName, String address, String protocol, Boolean check, Integer timeout) {
        ReferenceConfig<GenericService> referenceConfig = new ReferenceConfig<GenericService>();
        ApplicationConfig application = new ApplicationConfig();
        application.setName(applicationName);
        referenceConfig.setApplication(application);
        RegistryConfig registryConfig = new RegistryConfig(address);
        registryConfig.setProtocol(protocol);
        ConsumerConfig consumerConfig = new ConsumerConfig();
        consumerConfig.setCheck(check);
        consumerConfig.setTimeout(timeout);
        referenceConfig.setRegistry(registryConfig);
        referenceConfig.setConsumer(consumerConfig);
        return referenceConfig;
    }

2：动态调用

public class DynamDubboImpl implements IDynamDubbo {

    private static final String VARCHAR = "java.lang.String";

    @Autowired
    private MyReferenceUtils myReferenceUtils;

    @SuppressWarnings("unchecked")
    @Override
    public Object invoke(String clazzName, String method, String version, String parameter) {
        GenericService genericService = myReferenceUtils.getCacheGenericServiceByKey(clazzName, version);
        return genericService.$invoke(method, new String[]{VARCHAR}, new Object[]{parameter});
    }

    @Override
    public Object invoke(String clazzName, String method, String version, Map<String, String> parameter) {
        List<String> types = new ArrayList<String>();
        List<Object> values = new ArrayList<>();
        parameter.forEach((key, value) -> {
            if(String.class.getName().equals(key)){
                types.add(key);
                values.add(value.toString());
            }else {
                types.add(key);
                JSONObject jsonObject = JSONObject.parseObject(value);
                Map<String, Object> map = (Map<String, Object>) jsonObject;
                values.add(map);
            }
        });
        GenericService genericService  = myReferenceUtils.getCacheGenericServiceByKey(clazzName, version);
        String[] dtypes = types.toArray(new String[types.size()]);
        Object result = genericService.$invoke(method, dtypes, values.toArray());
        try {
            String resultJsonStr = JSONObject.toJSONString(result, WriteNullStringAsEmpty);
            resultJsonStr = resultJsonStr.replaceAll("[,]*\"class\":\"(.+?)\"", "");
            result = JSONObject.parse(resultJsonStr);
        } catch (JSONException ignored) {
        }
        return result;
    }

    @Override
    public Object invoke(String clazzName, String method, String version, String[] parameters) {
        GenericService genericService = myReferenceUtils.getCacheGenericServiceByKey(clazzName, version);
        List<String> types = new ArrayList<String>();
        if (parameters != null && parameters.length > 0) {
            int count = parameters.length;
            for (int i = 0; i < count; i++) {
                types.add(VARCHAR);
            }
            return genericService.$invoke(method, (String[]) types.toArray(), parameters);
        }
        return null;
    }

标签：dubbo,return,String,flowable,接口,version,private,new,referenceConfig
来源： https://www.cnblogs.com/liuwenjun/p/10462416.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。