个人中心
gpt4 book ai didi

Dubbo SpringBoot+Dubbo泛化的使用，以及开发时直连本地的Dubbo服务（Dubbo指定点对点调用服务）

转载 作者：知者 更新时间：2024-03-12 23:36:19 27 4
gpt4 key购买 nike

​ 一般情况我们使用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;

27 4 0
文章推荐： C++模板详解：泛型编程、模板原理、非类型模板参数、模板特化、分离编译
文章推荐： Java EE --- Bean 作用域和生命周期
文章推荐： SpringBoot读取resource或template中的文件
文章推荐： 本科课程【数据结构与算法】实验汇总
知者
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com