不使用他人jar包情况下优雅的进行dubbo调用详解
作者:spider集控团队 时间:2022-04-20 11:43:46
1、正常dubbo调用流程
引入dubbo依赖
引入他人提供的clinet依赖包;
配置相同的注册中心,使用@Reference注解注入对应的service接口(注意是Reference是dubbo包下的,不是spring那个)
2、如果想在不引用他人jar包的情况下如何调用呢?
dubbo泛化调用-dubbo原生支持的优雅方法
使用场景:
消费者不希望引入生产者提供的clinet依赖; 例如:消费者是一个基础服务,需要调用很多生产者的dubbo方法,那他就要引入很多的jar包;
消费者不使用java语言,而是使用其他的语言(例如:Python);
如何使用:
1.需要知道对方方法的全路径名称(interfaceName)
2.如果对方的dubbo有指定的版本号(version)和组(group)要指定一下,不然有很大可能会调用不通
3.要知道对方的注册中心地址和连接方式(如果是在同一个zk注册中心就更好了)
//1.获取泛化对象
private GenericService getGenericService(String interfaceName, String version, String group) {
ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>();
// set application
ApplicationConfig applicationConfig = new ApplicationConfig();
applicationConfig.setId(APPLICATION_ID);
applicationConfig.setName(APPLICATION_ID);
reference.setApplication(applicationConfig);
// 通过zookeeper连接
RegistryConfig registryConfig = new RegistryConfig();
registryConfig.setAddress(zkAddress);
registryConfig.setProtocol(ZOOKEEPER);
registryConfig.setCheck(false);
reference.setRegistry(registryConfig);
// set timeout
reference.setTimeout(syncForwardTimeout);
// set retry times
reference.setRetries(syncRetries);
// set check
reference.setCheck(false);
// set generic
reference.setGeneric(true);
// set interface version
if (version != null && version.length() != 0) {
reference.setVersion(version);
}
// set interface name
reference.setInterface(interfaceName);
// set service id
reference.setId(interfaceName);
// set dubbo protocol
reference.setProtocol(DUBBO);
//
if (group != null && group.length() != 0) {
reference.setGroup(group);
}
// 从zookeeper获取缓存,从缓存中获取泛化
return ReferenceConfigCache.getCache().get(reference);
}
//2.泛化调用入参处理
```
private ResponseDataDto<R> invoke(GenericService genericService, UpDataReqDto upDataReqDto, String method) {
String[] paramTypes = new String[1];
Object[] paramValues = new Object[1];
int i = 0;
paramTypes[i] = upDataReqDto.getClass().getTypeName();
paramValues[i] = upDataReqDto;
Object object = genericService.$invoke(method, paramTypes, paramValues);
return JSON.parseObject(JSON.toJSONString(object), new TypeReference<ResponseDataDto<R>>(){});
}
```
实现原理:
泛化调用的实现主要涉及两个filter
1. com.alibaba.dubbo.rpc.filter.GenericFilter
2. com.alibaba.dubbo.rpc.filter.GenericImplFilter
泛化调用的流程:
调用 <-> GenericImplFilter <-> 网络(RPC) <-> GenericFilter <-> 服务实现
泛化调用的核心源码:
GenericImplFilter:
```
//判断是不是泛化调用
if (isCallingGenericImpl(generic, invocation)) {
RpcInvocation invocation2 = new RpcInvocation(invocation);
/**
* Mark this invocation as a generic impl call, this value will be removed automatically before passing on the wire.
* See {@link RpcUtils#sieveUnnecessaryAttachments(Invocation)}
*/
invocation2.put(GENERIC_IMPL_MARKER, true);
String methodName = invocation2.getMethodName();
Class<?>[] parameterTypes = invocation2.getParameterTypes();
Object[] arguments = invocation2.getArguments();
String[] types = new String[parameterTypes.length];
for (int i = 0; i < parameterTypes.length; i++) {
types[i] = ReflectUtils.getName(parameterTypes[i]);
}
Object[] args;
if (ProtocolUtils.isBeanGenericSerialization(generic)) {
args = new Object[arguments.length];
for (int i = 0; i < arguments.length; i++) {
args[i] = JavaBeanSerializeUtil.serialize(arguments[i], JavaBeanAccessor.METHOD);
}
} else {
args = PojoUtils.generalize(arguments);
}
if (RpcUtils.isReturnTypeFuture(invocation)) {
invocation2.setMethodName($INVOKE_ASYNC);
} else {
invocation2.setMethodName($INVOKE);
}
invocation2.setParameterTypes(GENERIC_PARAMETER_TYPES);
invocation2.setParameterTypesDesc(GENERIC_PARAMETER_DESC);
invocation2.setArguments(new Object[]{methodName, types, args});
return invoker.invoke(invocation2);
}
// 普通服务进行通用调用
else if (isMakingGenericCall(generic, invocation)) {
Object[] args = (Object[]) invocation.getArguments()[2];
if (ProtocolUtils.isJavaGenericSerialization(generic)) {
for (Object arg : args) {
if (byte[].class != arg.getClass()) {
error(generic, byte[].class.getName(), arg.getClass().getName());
}
}
} else if (ProtocolUtils.isBeanGenericSerialization(generic)) {
for (Object arg : args) {
if (!(arg instanceof JavaBeanDescriptor)) {
error(generic, JavaBeanDescriptor.class.getName(), arg.getClass().getName());
}
}
}
invocation.setAttachment(
GENERIC_KEY, invoker.getUrl().getParameter(GENERIC_KEY));
}
GenericFilter:
if ((inv.getMethodName().equals($INVOKE) || inv.getMethodName().equals($INVOKE_ASYNC))
&& inv.getArguments() != null
&& inv.getArguments().length == 3
&& !GenericService.class.isAssignableFrom(invoker.getInterface())){
.......泛化调用处理逻辑......
}
3、总结
从源码设计来看泛化调用提供了在没有接口依赖的情况下进行调用的解决方案;
从扩展上来看泛化调用的侵入性不强,可以很好的用于框架扩展;
来源:https://juejin.cn/post/7148277888259719199
标签:jar,包,调用,dubbo
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
解决Spring Batch框架job任务只跑一次的问题
2023-01-07 00:13:53
maven的pom文件与打包详解
2023-12-24 00:23:51
![](https://img.aspxhome.com/file/2023/8/64538_0s.png)
Java 1.8使用数组实现循环队列
2022-02-11 04:00:10
mybatis-plus 使用Condition拼接Sql语句各方法的用法
2022-07-06 03:51:12
eclipse报错 eclipse启动报错解决方法
2023-04-28 08:43:49
C#中抽象方法与虚拟方法的区别
2021-10-30 07:30:15
浅谈一下Java中的悲观锁和乐观锁
2023-08-12 05:54:27
解决Maven多模块编译慢的问题
2022-10-09 23:58:02
![](https://img.aspxhome.com/file/2023/0/99880_0s.png)
Java实现年兽大作战游戏详解
2023-11-08 04:28:05
![](https://img.aspxhome.com/file/2023/5/58875_0s.jpg)
Java语言实现简单FTP软件 FTP软件效果图预览之上传功能(3)
2022-03-28 10:16:21
![](https://img.aspxhome.com/file/2023/3/72383_0s.png)
基于Java代码实现支付充值的通用流程
2021-09-04 00:48:45
详解升级Android Studio3.0时遇到的几个问题
2021-11-19 08:13:52
从C#程序中调用非受管DLLs的方法
2023-03-23 08:43:41
java实现轻量型http代理服务器示例
2021-10-05 18:14:20
Spring MVC URL地址映射的示例代码
2022-12-09 19:53:33
![](https://img.aspxhome.com/file/2023/3/72903_0s.jpg)
Java加载property文件配置过程解析
2023-10-07 07:53:03
spring循环依赖策略解析
2022-09-13 13:49:10
![](https://img.aspxhome.com/file/2023/4/72304_0s.jpg)
你知道jdk竟有4个random吗
2022-06-14 23:37:08
浅谈基于SpringBoot实现一个简单的权限控制注解
2022-01-23 16:42:47
Maven的几个常用plugin
2021-12-05 13:36:28