Spring Cloud与Dubbo的完美融合之手「Spring Cloud Alibaba」_weixin_30340775的博客-程序员宅基地

技术标签: java  大数据  

很早以前,在刚开始搞Spring Cloud基础教程的时候,写过这样一篇文章:《微服务架构的基础框架选择:Spring Cloud还是Dubbo?》,可能不少读者也都看过。之后也就一直有关于这两个框架怎么选的问题出来,其实文中我有明确的提过,Spring Cloud与Dubbo的比较本身是不公平的,主要前者是一套较为完整的架构方案,而Dubbo只是服务治理与RPC实现方案。

由于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的依赖,比如:

    <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控制台的服务列表中看到上面定义的两个服务,比如:

接下来,我们就可以通过调用服务消费者中定义的/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-apialibaba-dubbo-serveralibaba-dubbo-client项目:

如果您对这些感兴趣,欢迎star、follow、收藏、转发给予支持!

欢迎关注我的公众号:程序猿DD,获得独家整理的学习资源和日常干货推送。如果您对我的专题内容感兴趣,也可以关注我的博客:didispace.com

转载于:https://juejin.im/post/5d5a0657f265da03f564e2c1

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_30340775/article/details/100092619

智能推荐

串口发送数据——字符串发送与十六进制发送的区别_追寻北极的博客-程序员宅基地_串口发送字符串

在使用串口发送数据时可以选择字符串发送或者十六进制发送,通常情况下我们习惯选用字符串发送数据。关于两者的区别,需要从计算机存储数据的格式说起。        在计算机中,数据是以二进制的形式存储的,例如十进制 1(10)在计算机中用 0000 0001(2)来表示。我们在用串口发送数据的时候首先将待数据转换为对应的ASCII码,然后再将这些ASCII码按照二进制的方式一位一位的发送出去。例

ViewPager 分析(章节一)_阿邹邹的博客-程序员宅基地

公司项目中有用到各种花里胡哨的滑动,什么左右滑动,上下滑动,惯性滚动回拉,滑动冲突。一言难尽,只能死磕viewpager。提出问题:viewpager怎样进行布局的viewpager怎样滚动的viewpager里面嵌套了scrollview怎样解决掉滑动冲突(效果要与网易云音乐的云村一样)viewpager里面的Adapger有什么用viewpager动画问题viewpager怎么...

c语言中s=1 2 100,题目:求1+2+3+……+98+99+100(1)用数学方法求解(2)编写C语言程序求解解:(1)数学方法S = 1+2+3+……+98+99+1..._weixin_39968861的博客-程序员宅基地

题目:求1+2+3+……+98+99+100(1)用数学方法求解(2)编写C语言程序求解解:(1)数学方法S = 1+2+3+……+98+99+100= (1+100) + (2+99) + (3+98) + …… + (49+52) + (50+51)= 101 * 50= 5050(2)C语言编程#include int main(){int sum = 0; // 赋初值for(int i ...

it论坛 计算机科学概论,(毕业论文) 计算机科学与技术专业 IT技术论坛.doc_曾颖卓的博客-程序员宅基地

您所在位置:网站首页 &gt; 海量文档&amp;nbsp&gt;&amp;nbsp学术论文&amp;nbsp&gt;&amp;nbsp毕业论文(毕业论文) 计算机科学与技术专业 IT技术论坛.doc39页本文档一共被下载:次,您可全文免费在线阅读后下载本文档。 下载提示1.本站不保证该用户上传的文档完整性,不预览、不比对内容而直接下载产生的反悔问题本站不予受理。2...

c语言最大数最小数交换,输入个10个整数,最小数跟第一个数交换,最大数跟最后一个数交换..._AS思远的博客-程序员宅基地

#includeint main(){void inputf(int*, int);void work(int*, int);void outputf(int*, int);int a[10];inputf(a, 10);work(a, 10);outputf(a, 10);return 0;}void inputf(int p[], int n){int i;for (i = 0; i &lt;...

随便推点

Java写L1-026 I Love GPLT (5 分)_淡灰灰灰的博客-程序员宅基地

这道超级简单的题目没有任何输入。你只需要把这句很重要的话 —— “I Love GPLT”——竖着输出就可以了。所谓“竖着输出”,是指每个字符占一行(包括空格),即每行只能有1个字符和回车。输入样例:无结尾无空行输出样例:ILoveGPLT结尾无空行注意:输出的两个空行中各有一个空格思路:String[]是创建字符串数组,Sring是创建字符串。str.charAt可以取字符串的字符public class Main{ pu

spark更改分区_如何只更新spark中的特定分区?_山和蓝枝的博客-程序员宅基地

我有一个分区数据帧保存到hdfs中。我应该定期从kafka主题加载新数据并更新hdfs数据。数据很简单:只是在一定时期内收到的推文数量。所以,分区Jan 18, 10 AM可能有价值2,我可能会收到来自卡夫卡的最新数据,由3条tweets组成,发送时间为1月18日上午10点. 所以,我需要更新1月18日上午10点价值2+3=5.我现在的解决方案不好,因为将hdfs中的所有内容加载到RAM中从hdf...

均方距离计算公式_均值、方差、均方值、均方差计算_weixin_39733948的博客-程序员宅基地

1、均值均值表示信号中直流分量的大小,用E(x)表示。对于高斯白噪声信号而言,它的均值为0,所以它只有交流分量。2、均值的平方均值的平方,用{E(x)}^2表示,它表示的是信号中直流分量的功率。3、均方值均方值表示信号平方后的均值,用E(x^2)表示。均方值表示信号的平均功率。信号的平均功率 = 信号交流分量功率 信号直流分量功率例如:x、y、z 3项求均方值。均方值=(x的平方 y的平方 z的平...

1. Two Sum的C++解法_缪斯赤贫的博客-程序员宅基地_c++ twosum

先排序,首位各有一个指针,根据加起来的值和target的大小作比较移动指针。输出索引的方法:排序前赋值一份,找到值之后从头到尾再找一遍。class Solution {public: vector&amp;lt;int&amp;gt; twoSum(vector&amp;lt;int&amp;gt; &amp;amp;numbers, int target) { sort(numbers.begin(), numbers....

安卓获取cpu多少核多少位_如何获取 Android 设备的CPU核数,时钟频率以及内存大小..._余博西的博客-程序员宅基地

展开全部获取 CPU 核数Linux 中的设备都是以文件62616964757a686964616fe78988e69d8331333363373061的形式存在,CPU 也不例外,因此 CPU 的文件个数就等价与核数。Android 的 CPU 设备文件位于/sys/devices/system/cpu/目录,文件名的的格式为cpu\d+。[email protected]_x86_64:/sys/dev...

html 响应式布局怎么实现,CSS实现响应式布局_简单心理的博客-程序员宅基地

用CSS实现响应式布局响应式布局感觉很高大上,很难,但实际上只用CSS也能实现响应式布局要用的就是CSS中的没接查询,下面就介绍一下怎么运用:使用@media 的三种方法1.直接在CSS文件中使用:@media 类型 and (条件1) and (条件二){css样式}@media screen and (max-width:1024px) {body{background-color: red;...

推荐文章

热门文章

相关标签