一般情况我们使用dubbo)通过rpc调用dubbo提供方的服务,首先要在消费者的项目中引入接口提供者的jar包(provider端暴露的接口和方法),然后使用jar包里面的类和方法,两端才能正常通信调用。但是如果要调N个不同服务提供者的接口,就要引入N个jar包,这时候消费者项目有N多个dubbo提供者的jar,项目就会耦合。我们可以用dubbo的泛化实现调用dubbo服务,泛化调用不需要引入provider提供的jar即可实现远程调用,降低耦合。
但是一般提供好的jar是不会再修改里面的接口方法的,即使修改,也要尽量向下兼容,兼容之前版本的接口(不然这个jar被很多客户端引入的话,那么他们都要修改),在jar里面提供好了dubbo接口的方法和参数,其他客户端引入就可以调用,所以还是引jar的方式调dubbo接口比较方便,不过我这里记录一下不引入jar的调用dubbo接口的笔记
注:
底层原理跟普通的RPC调用是一致的,网络、序列化、反射这些底层技术一致。区别就在于参数和返回值中所有的POJO都用Map表示。通过GenericService来调用所有的服务实现。
GenericService 这个接口只有一个方法,名为 $invoke,它接受三个参数,分别为方法名、方法参数类型数组和参数值数组;
对于方法参数类型数组如果是基本类型,如 int 或 long,可以使用 int.class.getName()获取其类型;
如果是基本类型数组,如 int[],则可以使用 int[].class.getName();
如果是 POJO,则直接使用全类名,如 com.xinlin.model.xxxPOJO
注:这个全类名是指dubbo服务提供方provider的接口的参数的POJO的全类名
1.在dubbo的服务提供方写一个查询用户信息的服务
@Service
public class DubboUserService implements IDubboUserService {
@Override
public UserVO getUser( UserDTO userDTO) {
UserVO user = new UserVO();
user.setName("xinlin");
user.setId(1);
return user;
}
}
2.在dubbo的消费者中配置获取这个用户信息的泛化的服务
@Configuration
public class DubboUserServiceConfig {
@Bean
public GenericService dubboUserService(ApplicationConfig applicationConfig, RegistryConfig registryConfig){
ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>();
reference.setApplication(applicationConfig);
reference.setRegistry(registryConfig);
// 设置调用的reference属性,下面只设置了协议、接口名、版本、超时时间
reference.setProtocol("dubbo");
reference.setInterface("cn.com.xinlin.service.IDubboUserService");
// reference.setVersion("1.0.0");
reference.setTimeout(2000);
// 声明为泛化接口
reference.setGeneric(true);
// GenericService可以接住所有的实现
GenericService genericService = reference.get();
return genericService;
}
}
3.在dubbo消费者的controller中注入这个泛化的dubbo服务
@Controller
@RequestMapping("/demo")
public class DemoController {
// generic = true 声明为泛化接口
@Autowired
GenericService dubboUserService;
/**
* 泛化调用
* @return
*/
@ResponseBody
@RequestMapping(value = "/getUser")
public Map getUser(){
//构造参数,用Map表示POJO参数,如果返回值为POJO也将自动转成Map
Map<String, Object> userDTO = new HashMap<>();
userDTO.put("age", "25");
userDTO.put("name", "b");
Object result = dubboUserService.$invoke("getUser",new String[]{"cn.com.xinlin.model.dto.UserDTO"},new Object[]{userDTO});
return (Map)result;
}
}
4.在浏览器测试调用,调试可以看到成功调用了dubbo服务,这个过程并没有引入一个dubbo提供方的jar包即可实现远程调用dubbo的服务
注:
优点降低耦合
缺点也明显,参数传递麻烦,需要显示指定方法名称、参数。
(dubbo不需要注册中心也可以指定点对点调用服务)
有时候本地开发测试的时候,总不能每次都放到测试环境才去测,在@Reference注解的url写本地的dubbo服务的localhost+端口即可连上,例:url=“dubbo://localhost:20880”,先启动本地的dubbo服务,如果本地的dubbo服务提供者连不上注册中心的话,在application.propertites加上这行配置禁止向注册中心注册就可以了
dubbo.registry.register=false
@Reference(timeout = 3000,url="dubbo://localhost:20880")
IDubboDemoService dubboDemoService;
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://lebron.blog.csdn.net/article/details/125056067
内容来源于网络,如有侵权,请联系作者删除!