代码技巧——dubbo泛化调用

现在有一种业务场景：

（1）业务方B调用任务系统A，提交一个任务，由A保证任务尽可能的被执行成功（系统A自带幂等、重试），在A完成任务的执行后将执行情况同步回调通知B应用；

（2）因此，B应用在提交任务时需要把自己的回调地址作为参数传递给A，这个参数被定义为dubbo接口的全路径+方法名+分组+版本号；

（3）系统A不可能提前知晓这个dubbo接口并注册对应的consumer，因此只能通过dubbo的「泛化调用」方式调用业务方B的dubbo接口，即Dubbo的调用方，在不引入服务接口类的情况下，远程调用其他Dubbo服务；

"泛化接口调用方式主要用于客户端没有API接口及模型类元的情况，参数及返回值中的所有POJO均用Map表示，通常用于框架集成，比如：实现一个通用的服务测试框架，可通过GenericService调用所有服务实现。"——使用泛化调用 | Apache Dubbo

下面给出代码示例；

（1）核心方法

import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
import com.internet.bocfg.audit.client.model.AuditFlowCallbackRequest;
import com.internet.bocfg.audit.client.model.AuditFlowCallbackResponse;
import com.internet.bocfg.audit.constant.AuditConstants;
import com.internet.bocfg.audit.exception.AuditBusinessException;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.dubbo.config.ApplicationConfig;
import org.apache.dubbo.config.ReferenceConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.utils.ReferenceConfigCache;
import org.apache.dubbo.rpc.service.GenericService;
import org.springframework.stereotype.Service;import javax.annotation.Resource;
import java.util.Map;/*** @author Akira* @description dubbo泛化调用服务* @date 2022/8/28*/
@Slf4j
@Service
public class DubboGenericService {/*** 缓存已经注册过的GenericService*/private static final Map<String, GenericService> stubCache = Maps.newConcurrentMap();private final ApplicationConfig applicationConfig = new ApplicationConfig("bocfg-audit");@Resource(name = "myRegistryConfig")private RegistryConfig registryConfig;/*** (泛化)远程调用** @param serviceName 接口路径* @param methodName  方法名* @param group       分组* @param version     版本* @param request     自定义的dubbo接口参数*/private void remoteInvoke(String serviceName, String methodName, String group, String version,AuditFlowCallbackRequest request) {try {// 先尝试从缓存中拿GenericService 设置缓存的原因：ReferenceConfig实例很重，封装了与注册中心的连接以及与provider的连接，需要缓存，否则重复生成ReferenceConfig可能造成性能问题并且会有内存和连接泄漏String stubKey = stubKey(serviceName, methodName, version);GenericService genericService = stubCache.get(stubKey);// 未取到则准备初始化当前GenericServiceif (genericService == null) {ReferenceConfig<GenericService> reference = new ReferenceConfig<>();// 连接相关的配置，包括：zk地址、应用名、协议等reference.setApplication(applicationConfig);reference.setRegistry(registryConfig);// 调用相关的配置，包括：声明为泛化接口、不检查状态、负载均衡方式、超时时间等reference.setGeneric(true);reference.setLoadbalance("roundrobin");reference.setCheck(false);reference.setTimeout(AuditConstants.AUDIT_CALLBACK_DEFALUT_TIMEOUT);// 调用目标provider相关的配置，包括：接口、group、version、reference.setInterface(serviceName);reference.setGroup(StringUtils.isBlank(group) ? AuditConstants.AUDIT_CALLBACK_DEFALUT_GROUP : group);reference.setVersion(StringUtils.isBlank(version) ? AuditConstants.AUDIT_CALLBACK_DEFALUT_VERSION : version);// 这里优先使用dubbo内置的简单缓存工具类进行缓存，若没有则放入自己定义的缓存stubCache中ReferenceConfigCache cache = ReferenceConfigCache.getCache();genericService = cache.get(reference);if (genericService != null) {stubCache.putIfAbsent(stubKey, genericService);}genericService = stubCache.get(stubKey);}// 至此，拿到了dubbo接口的genericServiceif (genericService == null) {throw new IllegalStateException("No provider available: " + stubKey);}// 泛化调用的参数：方法名、方法参数类型全路径、方法参数String[] parameterTypes = new String[]{AuditConstants.AUDIT_CALLBACK_REQUEST_CLASSNAME};Object[] args = new Object[]{request};Object result = genericService.$invoke(methodName, parameterTypes, args);if (result != null) {// 泛化调用返参为Object类型，这里做一个参数转换AuditFlowCallbackResponse callbackResponse = JSON.parseObject(JSON.toJSONString(result), AuditFlowCallbackResponse.class);if (!callbackResponse.isSuccess()) {log.warn("callbackResponse fail. serviceName={} methodName={} version={} request={} return={}", serviceName, methodName, version, JSON.toJSONString(request), JSON.toJSONString(callbackResponse));throw new AuditBusinessException("auditCallback fail:" + callbackResponse.getMsg());}}} catch (Throwable e) {log.error("dubbo remoteInvoke fail. serviceName={} methodName={} version={} auditFlowCallbackRequest={}", serviceName, methodName, version, JSON.toJSONString(request));throw e;}}/*** 拼接dubbo的GenericService缓存stubCache(map)中的存根key*/private String stubKey(String serviceName, String method, String version) {return serviceName + "$" + method + "$" +(StringUtils.isBlank(version) ? AuditConstants.AUDIT_CALLBACK_DEFALUT_VERSION : version);}}

（2）RegistryConfig配置

import com.internet.vivocfg.client.ConfigManager;
import org.apache.dubbo.config.RegistryConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class PropertyConfig {@Bean("myRegistryConfig")public RegistryConfig imExchangeConfig() {RegistryConfig registryConfig = null;registryConfig = new RegistryConfig(ConfigManager.get("dubbo.zk.registry.address"));registryConfig.setProtocol("zookeeper");registryConfig.setClient("curator");return registryConfig;}
}

参考：

使用泛化调用 | Apache Dubbo

dubbo实战之“泛化调用”探索 - 博客园

代码技巧——dubbo泛化调用相关推荐

接口测试-dubbo泛化调用
一.为什么要用dubbo泛化调用泛化接口调用方式主要用于客户端没有 API 接口及模型类元的情况,参数及返回值中的所有 POJO 均用 Map 表示,通常用于框架集成,比如:实现一个通用的服务测试框 ...
Dubbo泛化调用处理序列化问题
知其然要知其所以然,刚好趁这个机会把博客重新捡起来. 之前项目的目的是处理dubbo泛化调用的返回值,处理LocalDateTim,LocalDate,LocalTime.转换为时间戳. 一.如何泛化 ...
Dubbo 泛化调用
dubbo 泛化调用含义使用含义官方说的文邹邹的,不太懂.按我的理解,就是可以通过指定某个接口的全限定名和方法名,调用远程有提供该方法的服务. 通过上篇文章Dubbo入门,我们可以知道作为服务 ...
dubbo泛化调用原理
泛接口调用方式主要用于客户端没有API接口及模型类元的情况,参数及返回值中的所有POJO均用Map表示,通常用于框架集成,比如:实现一个通用的服务测试框架,可通过GenericService调用所有服 ...
Dubbo笔记 ⑱ ：泛化调用泛化实现
文章目录一.前言二.泛化调用与泛化实现 1. 泛化调用 2. 泛化实现三.源码实现 1. GenericImplFilter 2. GenericFilter 四.总结一.前言本系列为个人D ...
dubbo的调用原理及泛化调用
简单介绍 dubbo是阿里开源出来的一个rpc框架,主要是用于微服务分布式项目的远程调用,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现,下面是调用的原理图: ...
Dubbo泛化引用和泛化实现
开篇在Dubbo官方文档中关于泛化调用和泛化实现的说明,这里针对文档的案例做一些简单的说明和解释. 例子 // 引用远程服务 // 该实例很重量,里面封装了所有与注册中心及服务提供方连接,请缓存 R ...
Dubbo 泛化引用
前言大家好,今天开始给大家分享 - Dubbo 专题之 Dubbo 泛化引用.在前一个章节中我们介绍了 Dubbo 中的参数验证以及使用场景.我们在这个章节会继续介绍 Dubbo 泛化引用.那么什么 ...
Apache Dubbo系列：泛化调用
上一章,我们讲到了Dubbo的线程池策略,本章我们一起探讨,Dubbo如何实现泛化调用的.主要内容包括: 1.什么是泛化调用 2.泛化调用的三种方式 3.如何使用 4.源码分析推荐阅读: Apach ...

代码技巧——dubbo泛化调用

代码技巧——dubbo泛化调用相关推荐

最新文章

热门文章