>>分享流行的Java框架以及开源软件,对孙卫琴的《精通Spring:Java Web开发技术详解》提供技术支持 书籍支持  卫琴直播  品书摘要  在线测试  资源下载  联系我们
发表一个新主题 开启一个新投票 回复文章 您是本文章第 19035 个阅读者 刷新本主题
 * 贴子主题:  Spring Cloud与Dubbo的完美融合之手「Spring Cloud Alibaba 回复文章 点赞(0)  收藏  
作者:flybird    发表时间:2020-06-16 07:17:56     消息  查看  搜索  好友  邮件  复制  引用

     由于Dubbo在国内有着非常大的用户群体,但是其周边设施与组件相对来说并不那么完善。很多开发者用户又很希望享受Spring Cloud的生态,因此也会有一些Spring Cloud与Dubbo一起使用的案例与方法出现,但是一直以来大部分Spring Cloud整合Dubbo的使用方案都比较别扭。这主要是由于Dubbod的注册中心采用了ZooKeeper,而开始时Spring Cloud体系中的注册中心并不支持ZooKeeper,所以很多方案是存在两个不同注册中心的,之后即使Spring Cloud支持了ZooKeeper,但是由于服务信息的粒度与存储也不一致。所以,长期以来,在服务治理层面上,这两者一直都一套完美的融合方案。

     直到Spring Cloud Alibaba的出现,才得以解决这样的问题。在之前的教程中,我们已经介绍过使用Spring Cloud Alibaba中的Nacos来作为服务注册中心,并且在此之下可以如传统的Spring Cloud应用一样地使用Ribbon或Feign来实现服务消费。这篇,我们就来继续说说Spring Cloud Alibaba下额外支持的RPC方案:Dubbo。

入门案例

我们先通过一个简单的例子,来直观地感受Nacos服务注册中心之下,利用Dubbo来实现服务提供方与服务消费方。这里省略Nacos的安装与使用,如果对Nacos还不了解,可以查看本系列的使用Nacos实现服务注册与发现,下面就直接进入Dubbo的使用步骤。

构建服务接口

创建一个简单的Java项目,并在下面定义一个抽象接口,比如:    

public interface HelloService {

    String hello(String name);

}
  

构建服务接口提供方

第一步:创建一个Spring Boot项目,在  pom.xml 中引入第一步中构建的API包以及Spring Cloud Alibaba对Nacos和Dubbo的依赖,比如:    

[code]     <dependencies>
        <!-- 第一步中构建的API包 -->
        <dependency>
            <groupId>com.didispace</groupId>
            <artifactId>alibaba-dubbo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>        
            <!--<groupId>com.alibaba.cloud</groupId>-->
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        //...
    </dependencies>

  这里需要注意两点:
  1. 必须包含  spring-boot-starter-actuator 包,不然启动会报错。
  2.    spring-cloud-starter-dubbo 包需要注意  groupId ,根据具体使用的spring cloud alibaba版本依赖来确定。
    • 项目孵化期间,使用的  groupId 为:  org.springframework.cloud ;
    • 项目孵化之后,使用的  groupId 修改为了  com.alibaba.cloud ,所以用户需要注意是否使用正确。避免加载不到对应JAR包的问题。
第二步:实现Dubbo接口    

@Service
public class HelloServiceImpl implements HelloService {

    @Override
    public String hello(String name) {
        return "hello " + name;
    }

}

  注意:这里的  @Service 注解不是Spring的,而是  org.apache.dubbo.config.annotation.Service 注解。

     第三步:配置Dubbo服务相关的信息,比如:    

spring.application.name=alibaba-dubbo-server
server.port=8001

spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

# 指定 Dubbo 服务实现类的扫描基准包
dubbo.scan.base-packages=com.didispace.alibaba.dubbo.server
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.registry.address=spring-cloud://localhost

  配置说明如下:
  •    dubbo.scan.base-packages : 指定 Dubbo 服务实现类的扫描基准包
  •    dubbo.protocol : Dubbo 服务暴露的协议配置,其中子属性 name 为协议名称,port 为协议端口( -1 表示自增端口,从 20880 开始)
  •    dubbo.registry : Dubbo 服务注册中心配置,其中子属性 address 的值 "spring-cloud://localhost",说明挂载到 Spring Cloud 注册中心
注意:如果使用Spring Boot 2.1及更高版本时候,需要增加配置  spring.main.allow-bean-definition-overriding=true

     第四步:创建应用主类,比如:    

@EnableDiscoveryClient
@SpringBootApplication
public class DubboServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboServerApplication.class, args);
    }

}

构建服务接口消费方

第一步:创建一个Spring Boot项目,在  pom.xml 中引入第一步中构建的API包以及Spring Cloud Alibaba对Nacos和Dubbo的依赖,具体内容与服务提供方一致:    

     <dependencies>
        <!-- 第一步中构建的API包 -->
        <dependency>
            <groupId>com.didispace</groupId>
            <artifactId>alibaba-dubbo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>        
            <!--<groupId>com.alibaba.cloud</groupId>-->
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        //...
    </dependencies>

   第二步:配置Dubbo服务相关的信息,比如:

       spring.application.name=alibaba-dubbo-client
server.port=8002

spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.registry.address=spring-cloud://localhost
dubbo.cloud.subscribed-services=alibaba-dubbo-server
  

注意:
  1. 这里多增加了  dubbo.cloud.subscribed-services 参数,表示要订阅服务的服务名,这里配置的  alibaba-dubbo-server 对应的就是上一节服务提供方的  spring.application.name 的值,也就是服务提供方的应用名。
  2. 如果使用Spring Boot 2.1及更高版本时候,需要增加配置  spring.main.allow-bean-definition-overriding=true 。
第三步:创建应用主类,并实现一个接口,在这个接口中调用Dubbo服务,比如:    

@EnableDiscoveryClient
@SpringBootApplication
public class DubboClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboClientApplication.class, args);
    }

    @Slf4j
    @RestController
    static class TestController {

        @Reference
        HelloService helloService;

        @GetMapping("/test")
        public String test() {
            return helloService.hello("didispace.com");
        }
    }

}

  注意:这里的  @Reference 注解是  org.apache.dubbo.config.annotation.Reference

测试验证

完成了上面的所有开发之后,我们可以将Nacos、服务提供者、服务消费者依次启动起来。在完成启动之后,我们可以在Nacos控制台的服务列表中看到上面定义的两个服务,比如:

                点击在新窗口中浏览原图
CTRL+鼠标滚轮放大或缩小

file

     接下来,我们就可以通过调用服务消费者中定义的  /test 接口来触发dubbo服务的消费了。如果一切顺畅,应该可以得到如下结果:    

$ curl localhost:8002/test
hello didispace.com

小结

通过上面的例子,如果你曾经同时玩过Spring Cloud和Dubbo,一定会深有感触。你不用再同时顾虑Eureka和Zookeeper的配置,也不同同时关注这两个中间件的健康,只需要关注和维护好Nacos一个即可。而对于Dubbo的配置和使用来说,配置还是相当简单的,而代码编写上与以往的Dubbo没什么大的不同。在Spring Cloud Alibaba的整合之下,Dubbo用户既可以享受到原本RPC带来性能优势,又可以更好的享受Spring Cloud的各种福利;而对于Spring Cloud用户来说,在服务治理层面,又对了一个不错的可选项。可以说这块的整合是真正的让这两大用户群体得到了很好的融合,起到了互相成就的作用。更多关于Spring Cloud与Spring Cloud Alibaba教程内容可点击查看

     参考资料官方文档

代码示例

本文介绍内容的客户端代码,示例读者可以通过查看下面仓库中的  alibaba-dubbo-api 、  alibaba-dubbo-server 、  alibaba-dubbo-client 项目:
如果您对这些感兴趣,欢迎star、follow、收藏、转发给予支持!> 欢迎关注我的公众号:程序猿DD,获得独家整理的学习资源和日常干货推送。如果您对我的专题内容感兴趣,也可以关注我的博客:didispace.com


----------------------------
原文链接:https://www.jianshu.com/p/407b9962e775

程序猿的技术大观园:www.javathinker.net



[这个贴子最后由 flybird 在 2020-10-23 10:00:45 重新编辑]
  Java面向对象编程-->数组
  JavaWeb开发-->自定义JSP标签(Ⅰ)
  JSP与Hibernate开发-->立即检索和延迟检索策略
  Java网络编程-->Java网络编程入门
  精通Spring-->虚拟DOM和render()函数
  Vue3开发-->CSS过渡和动画
  10分钟认识RocketMQ!想进阿里连这个都不会?
  超全Redis命令总结,墙裂建议收藏,说不定就用上了呢
  git 常用指令总结
  Mybatis常见注解有哪些?
  Mybatis-plus大数据量流式查询
  使用Spring MVC多次读取请求Request Body的内容
  重新理解响应式编程
  vue父、子组件相关的传递
  Spring Boot JPA @OneToOne
  Spring Boot 基于 JUnit 5 实现单元测试
  Spring Data JPA详解
  Spring MVC数据验证
  Dubbo源码解析之SPI:扩展类的加载过程
  Spring5新特性之日志体系
  使用idea和gradle编译spring5源码
  更多...
 IPIP: 已设置保密
树形列表:   
1页 0条记录 当前第1
发表一个新主题 开启一个新投票 回复文章


中文版权所有: JavaThinker技术网站 Copyright 2016-2026 沪ICP备16029593号-2
荟萃Java程序员智慧的结晶,分享交流Java前沿技术。  联系我们
如有技术文章涉及侵权,请与本站管理员联系。