5分钟实现SpringBoot整合Dubbo构建分布式服务

5分钟实现SpringBoot整合Dubbo构建分布式服务

作者：佚名 2020-05-18 14:00:01

开发

架构

分布式 Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合。

创新互联是一家专业提供石峰企业网站建设,专注与成都做网站、成都网站建设、HTML5建站、小程序制作等业务。10年已为石峰众多企业、政府机构等服务。创新互联专业网站设计公司优惠进行中。

概述：

Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。

我们来看一下Dubbo 的RPC 调用流程，这里主要涉及到4个模块：

  •  Registry：服务注册，我们一般会采取Zookeeper 作为我们的注册中心
  •  Provider：服务提供者（生产者），提供具体的服务实现
  •  Consumer：消费者，从注册中心中订阅服务
  •  Monitor：监控中心，RPC调用次数和调用时间监控

从上图中我们可以了解到整个RPC 服务调用的过程主要为：

  •  生产者发布服务到服务注册中心中
  •  消费者在服务注册中心中订阅服务
  •  消费者调用已经注册的服务

一、项目构建

开发环境主要涉及以下几个方面：

  •  Spring-boot
  •  JDK 8
  •  Dubbo
  •  Zookeeper

项目构建通过: http://start.spring.io/ 快速构建web 项目，具体操作可以参考

http://www.cnblogs.com/jaycekon/p/7562688.html

由于Dubbo 中需要使用到服务注册中心，我们这里将使用Zookeeper 作为服务注册中心，具体安装配置，可以参考

http://www.cnblogs.com/jaycekon/p/7553909.html

在基础环境确定好了之后，我们项目的目录结构如下：

上图所示，我们项目主要分为了两个模块，一部分是生产者：spring-boot-dubbo ，一部分是：spring-boot-consumer。

整个项目的结构非常简单，这很符合Spring-Boot 的特性，简单便捷，下面我们开始一步步的剖析整个项目的结构

二、Productor

2.1、Pom.xml

项目依赖这一块主要使用到了基本的Spring-Boot-Web 依赖，然后我们需要额外引入Dubbo 与Zookeeper的依赖（详细依赖可参考源码，博文底部会有项目Github 地址）： 

  
 
 
 
    
   
  
  
  
  1.   
    2. 
   
  
  
  
  2.             io.dubbo.springboot  
    3. 
   
  
  
  
  3.             spring-boot-starter-dubbo  
    4. 
   
  
  
  
  4.             1.0.0  
    5. 
   
  
  
  
  5.           
    6. 
   
  
  
  
  6.           
    7. 
   
  
  
  
  7.             org.apache.zookeeper  
    8. 
   
  
  
  
  8.             zookeeper  
    9. 
   
  
  
  
  9.             3.4.6  
    10. 
   
  
  
  
  10.               
    11. 
   
  
  
  
  11.                   
    12. 
   
  
  
  
  12.                     org.slf4j  
    13. 
   
  
  
  
  13.                     slf4j-log4j12  
    14. 
   
  
  
  
  14.                   
    15. 
   
  
  
  
  15.                   
    16. 
   
  
  
  
  16.                     log4j  
    17. 
   
  
  
  
  17.                     log4j  
    18. 
   
  
  
  
  18.                   
    19. 
   
  
  
  
  19.               
    20. 
   
  
  
  
  20.          
    21.

2.2、配置文件

由于我们底层使用的是Spring-Boot 进行开发，那么我们就应该善于利用Spring-Boot 给我们带来的优势，因此我们可以直接在Application.properties 文件中配置Dubbo 服务： 

  
 
 
 
    
   
  
  
  
  1. ## Dubbo 服务提供者配置  
    2. 
   
  
  
  
  2. spring.dubbo.application.name=provider    --服务名称  
    3. 
   
  
  
  
  3. spring.dubbo.registry.address=zookeeper://127.0.0.1:2181   -- 注册中心地址  
    4. 
   
  
  
  
  4. spring.dubbo.protocol.name=dubbo     -- dubbo 协议  
    5. 
   
  
  
  
  5. spring.dubbo.protocol.port=20880  
    6. 
   
  
  
  
  6. spring.dubbo.scan=com.jaycekon.dubbo.service     --声明需要暴露的服务接口 
    7.

如果不采用Spring-Boot 进行自动配置，大家可以参考一下的配置xml 配置： 

  
 
 
 
    
   
  
  
  
  1.   
    2. 
   
  
  
  
  2. 
   
  
  
  
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
    4. 
   
  
  
  
  4.        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
    5. 
   
  
  
  
  5.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd  
    6. 
   
  
  
  
  6.        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  
    7. 
   
  
  
  
  7.       
    8. 
   
  
  
  
  8.       
    9. 
   
  
  
  
  9.       
    10. 
   
  
  
  
  10.       
    11. 
   
  
  
  
  11.       
    12. 
   
  
  
  
  12.       
    13. 
   
  
  
  
  13.       
    14. 
   
  
  
  
  14.       
    15. 
   
  
  
  
  15.       
    16.

2.3、服务提供

在服务提供主要包括两部分，一个是暴露服务，一个是服务实现

暴露服务：即我们平常开发中所使用的的接口，这里我们创建一个 UserService 的接口，主要包括一个保存用户的方法。 

  
 
 
 
    
   
  
  
  
  1. import com.jaycekon.dubbo.domain.User;  
    2. 
   
  
  
  
  2. /**  
    3. 
   
  
  
  
  3.  * Created by Jaycekon on 2017/9/19.  
    4. 
   
  
  
  
  4.  */  
    5. 
   
  
  
  
  5. public interface UserService {  
    6. 
   
  
  
  
  6.     User saveUser(User user);  
    7. 
   
  
  
  
  7. } 
    8.

服务实现：服务实现，与我们平常的服务一样，对接口进行实现，比较特别的是，我们这里需要使用到Dubbo 的 @Service 注解。更多springboot实战内容，Java知音公众号内回复“springboot聚合” 

  
 
 
 
    
   
  
  
  
  1. import com.alibaba.dubbo.config.annotation.Service;  
    2. 
   
  
  
  
  2. import com.jaycekon.dubbo.domain.User;  
    3. 
   
  
  
  
  3. import com.jaycekon.dubbo.service.UserService;  
    4. 
   
  
  
  
  4. /**  
    5. 
   
  
  
  
  5.  * Created by Jaycekon on 2017/9/19.  
    6. 
   
  
  
  
  6.  */  
    7. 
   
  
  
  
  7. @Service  
    8. 
   
  
  
  
  8. public class UserServiceImpl implements UserService {  
    9. 
   
  
  
  
  9.     @Override  
    10. 
   
  
  
  
  10.     public User saveUser(User user) {  
    11. 
   
  
  
  
  11.         user.setId(1);  
    12. 
   
  
  
  
  12.         System.out.println(user.toString());  
    13. 
   
  
  
  
  13.         return user;  
    14. 
   
  
  
  
  14.     }  
    15. 
   
  
  
  
  15. } 
    16.

2.4、总体结构

Dubbo 的服务提供端，已经总体开发完成，非常简单，总体的目录结构如下：

三、Consumer

3.1、pom.xml

消费者的相关依赖，与生产者的依赖一致。 

  
 
 
 
    
   
  
  
  
  1.   
    2. 
   
  
  
  
  2. 
   
  
  
  
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
    4. 
   
  
  
  
  4.     4.0.0  
    5. 
   
  
  
  
  5.     com.jaycekon  
    6. 
   
  
  
  
  6.     spring-boot-consumer  
    7. 
   
  
  
  
  7.     0.0.1-SNAPSHOT  
    8. 
   
  
  
  
  8.     jar  
    9. 
   
  
  
  
  9.     spring-boot-consumer  
    10. 
   
  
  
  
  10.     Demo project for Spring Boot  
    11. 
   
  
  
  
  11.       
    12. 
   
  
  
  
  12.         org.springframework.boot  
    13. 
   
  
  
  
  13.         spring-boot-starter-parent  
    14. 
   
  
  
  
  14.         1.5.7.RELEASE  
    15. 
   
  
  
  
  15.            
    16. 
   
  
  
  
  16.       
    17. 
   
  
  
  
  17.       
    18. 
   
  
  
  
  18.         UTF-8  
    19. 
   
  
  
  
  19.         UTF-8  
    20. 
   
  
  
  
  20.         1.8  
    21. 
   
  
  
  
  21.       
    22. 
   
  
  
  
  22.       
    23. 
   
  
  
  
  23.           
    24. 
   
  
  
  
  24.             org.springframework.boot  
    25. 
   
  
  
  
  25.             spring-boot-starter-web  
    26. 
   
  
  
  
  26.           
    27. 
   
  
  
  
  27.           
    28. 
   
  
  
  
  28.             org.springframework.boot  
    29. 
   
  
  
  
  29.             spring-boot-starter-test  
    30. 
   
  
  
  
  30.             test  
    31. 
   
  
  
  
  31.           
    32. 
   
  
  
  
  32.           
    33. 
   
  
  
  
  33.           
    34. 
   
  
  
  
  34.             io.dubbo.springboot  
    35. 
   
  
  
  
  35.             spring-boot-starter-dubbo  
    36. 
   
  
  
  
  36.             1.0.0  
    37. 
   
  
  
  
  37.           
    38. 
   
  
  
  
  38.           
    39. 
   
  
  
  
  39.             org.apache.zookeeper  
    40. 
   
  
  
  
  40.             zookeeper  
    41. 
   
  
  
  
  41.             3.4.6  
    42. 
   
  
  
  
  42.               
    43. 
   
  
  
  
  43.                   
    44. 
   
  
  
  
  44.                     org.slf4j  
    45. 
   
  
  
  
  45.                     slf4j-log4j12  
    46. 
   
  
  
  
  46.                   
    47. 
   
  
  
  
  47.                   
    48. 
   
  
  
  
  48.                     log4j  
    49. 
   
  
  
  
  49.                     log4j  
    50. 
   
  
  
  
  50.                   
    51. 
   
  
  
  
  51.               
    52. 
   
  
  
  
  52.           
    53. 
   
  
  
  
  53.           
    54. 
   
  
  
  
  54.           
    55. 
   
  
  
  
  55.             org.springframework  
    56. 
   
  
  
  
  56.             springloaded  
    57. 
   
  
  
  
  57.             1.2.3.RELEASE  
    58. 
   
  
  
  
  58.           
    59. 
   
  
  
  
  59.           
    60. 
   
  
  
  
  60.             org.projectlombok  
    61. 
   
  
  
  
  61.             lombok  
    62. 
   
  
  
  
  62.             1.16.18  
    63. 
   
  
  
  
  63.             provided  
    64. 
   
  
  
  
  64.           
    65. 
   
  
  
  
  65.       
    66. 
   
  
  
  
  66.       
    67. 
   
  
  
  
  67.           
    68. 
   
  
  
  
  68.               
    69. 
   
  
  
  
  69.                 org.springframework.boot  
    70. 
   
  
  
  
  70.                 spring-boot-maven-plugin  
    71. 
   
  
  
  
  71.               
    72. 
   
  
  
  
  72.           
    73. 
   
  
  
  
  73.       
    74. 
   
  
  
  
  74.  
    75.

3.2、配置文件

配置文件与生产者稍有区别： 

  
 
 
 
    
   
  
  
  
  1. ## 避免和 server 工程端口冲突  
    2. 
   
  
  
  
  2. server.port=8081 
    3. 
   
  
  
  
  3. ## Dubbo 服务消费者配置  
    4. 
   
  
  
  
  4. spring.dubbo.application.name=consumer  
    5. 
   
  
  
  
  5. spring.dubbo.registry.address=zookeeper://127.0.0.1:2181  
    6. 
   
  
  
  
  6. spring.dubbo.scan=com.jaycekon.dubbo.service 
    7.

基于Xml 的配置： 

  
 
 
 
    
   
  
  
  
  1.   
    2. 
   
  
  
  
  2. 
   
  
  
  
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
    4. 
   
  
  
  
  4.        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
    5. 
   
  
  
  
  5.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd  
    6. 
   
  
  
  
  6.        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  
    7. 
   
  
  
  
  7.       
    8. 
   
  
  
  
  8.       
    9. 
   
  
  
  
  9.       
    10. 
   
  
  
  
  10.       
    11. 
   
  
  
  
  11.       
    12. 
   
  
  
  
  12.       
    13. 
   
  
  
  
  13.       
    14. 
   
  
  
  
  14.       
    15. 
   
  
  
  
  15.       
    16. 
   
  
  
  
  16.  
    17.

3.3、服务实现

在这里，如果我们需要调用注册服务中的相关服务，则需要实现相关的接口。 

  
 
 
 
    
   
  
  
  
  1. import com.jaycekon.dubbo.domain.User;  
    2. 
   
  
  
  
  2. /**  
    3. 
   
  
  
  
  3.  * Created by Jaycekon on 2017/9/19.  
    4. 
   
  
  
  
  4.  */  
    5. 
   
  
  
  
  5. public interface UserService {  
    6. 
   
  
  
  
  6.     User saveUser(User user);  
    7. 
   
  
  
  
  7. } 
    8.

例如，在这里我们需要使用到生产者中的 saveUser（User user） 方法，则需要创建一个接口，然后再调用时，使用 @Reference 注解进行引用： 

  
 
 
 
    
   
  
  
  
  1. import com.alibaba.dubbo.config.annotation.Reference;  
    2. 
   
  
  
  
  2. import com.jaycekon.dubbo.domain.City;  
    3. 
   
  
  
  
  3. import com.jaycekon.dubbo.domain.User; 
    4. 
   
  
  
  
  4. import org.springframework.stereotype.Component;  
    5. 
   
  
  
  
  5. /**  
    6. 
   
  
  
  
  6.  * 城市 Dubbo 服务消费者  
    7. 
   
  
  
  
  7.  * 
      
    8. 
   
  
  
  
  8.  * Created by Jaycekon on 20/09/2017.  
    9. 
   
  
  
  
  9.  */  
    10. 
   
  
  
  
  10. @Component  
    11. 
   
  
  
  
  11. public class CityDubboConsumerService {  
    12. 
   
  
  
  
  12.     @Reference  
    13. 
   
  
  
  
  13.     CityDubboService cityDubboService;  
    14. 
   
  
  
  
  14.     @Reference  
    15. 
   
  
  
  
  15.     UserService userService;  
    16. 
   
  
  
  
  16.     public void printCity() {  
    17. 
   
  
  
  
  17.         String cityName = "广州";  
    18. 
   
  
  
  
  18.         City city = cityDubboService.findCityByName(cityName);  
    19. 
   
  
  
  
  19.         System.out.println(city.toString());  
    20. 
   
  
  
  
  20.     }  
    21. 
   
  
  
  
  21.     public User saveUser() {  
    22. 
   
  
  
  
  22.         User user = new User();  
    23. 
   
  
  
  
  23.         user.setUsername("jaycekon")  
    24. 
   
  
  
  
  24.                 .setPassword("jaycekong824");  
    25. 
   
  
  
  
  25.         return userService.saveUser(user);  
    26. 
   
  
  
  
  26.     }  
    27. 
   
  
  
  
  27. } 
    28.

3.4、服务调用

最后，我们需要实现一个RESTful 接口，提供给用户调用： 

  
 
 
 
    
   
  
  
  
  1. import com.jaycekon.dubbo.service.CityDubboConsumerService;  
    2. 
   
  
  
  
  2. import org.springframework.beans.factory.annotation.Autowired;  
    3. 
   
  
  
  
  3. import org.springframework.web.bind.annotation.RequestMapping;  
    4. 
   
  
  
  
  4. import org.springframework.web.bind.annotation.RestController;  
    5. 
   
  
  
  
  5. /**  
    6. 
   
  
  
  
  6.  * Created by Jaycekon on 2017/9/19.  
    7. 
   
  
  
  
  7.  */  
    8. 
   
  
  
  
  8. @RestController  
    9. 
   
  
  
  
  9. public class UserController {  
    10. 
   
  
  
  
  10.     @Autowired  
    11. 
   
  
  
  
  11.     private CityDubboConsumerService service;  
    12. 
   
  
  
  
  12.     @RequestMapping("/save")  
    13. 
   
  
  
  
  13.     public Object saveUser() { 
    14. 
   
  
  
  
  14.         return service.saveUser();  
    15. 
   
  
  
  
  15.     }  
    16. 
   
  
  
  
  16. } 
    17.

3.5、目录结构

四、总结

本篇博客主要是博主在学习Spring-boot 的时候，总结下来的。在经过一些列的对比后，感觉Dubbo 与Spring-Cloud 还是有点差距的，不管是从服务提供，还是社区活跃来说，Spring-Cloud 还是会强一点。但是由于公司内部使用的是Dubbo，因此还是需要学习一下，后续的话，会对Spring-Cloud 进行学习以及分项。

GitHub地址

https://github.com/jaycekon/SpringBoot 

新闻标题：5分钟实现SpringBoot整合Dubbo构建分布式服务
当前URL：http://www.gawzjz.com/qtweb2/news42/20992.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

网站制作知识

同城分类信息

微信小程序　　 　h5响应式网站　　 　南充网站制作　　 　公司网站建设　　 　网页设计　　 　成都展柜定制　　 　微信小程序开发　　 　成都SEO优化公司　　 　微信小程序　　 　营销网站定位　　 　成都网站建设　　 　主机托管　　 　成都企业网站设计　　 　营销型网站建设　　 　宜宾网站建设　　 　电信服务器托管　　 　解决方案　　 　四川搅拌罐车　　 　成都SEO优化　　 　成都广告设计公司