flowable中动态调用dubbo接口

Posted 2021-12-22 小学生05101

我们的系统采用是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;