dubbo+spring+springboot入门案例搭建

浅浅的花香味﹌ 2022-02-22 02:24 396阅读 0赞 
  1.     不同服务之间或者多服务之间调用接口的场景实际中会经常遇到，目前市面上解决该问题比较流行的两大框架为dubbo和springcloud。
  3.     今天简单的建一个dubbo入门的案例，分为两个小案例一个和spring和结合案例，另一个是和springboot结合的案例，这里需要知道一点，dubbo是依赖spring环境的，不可以单独使用。搭建dubbo案例，需要安装zookeeper，可以从网上下载一个，解压后运行zkServer.cmd即可，zookeeper默认端口2181

1、dubbo+spring 的方式搭建

**1) 首先如果一个服务对其他服务公开接口，那么我们需要将这些对外的公共接口单独拿出来。第一步就是新建一个单独的公共接口模块**

  1.  ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70][]
  3.  这里为了简单，只有一个用户接口
  5. public interface UserService {
  7.     /**
  8.      * 获取用户名称
  9.      */
  10.     String  userName();
  13.     /**
  14.      * 获取用户ID
  15.      */
  16.     String  userId();
  17. }

2）、新建一个dubbo集成spring的服务模块

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 1

  1.   dubbo的服务模块，这里以最简易的方式搭建，一个公共接口实现类，一个服务启动类，一个dubbo配置文件。
  3.   我们先看看pom需要引入的依赖，这里是父pom.xml
  5. <?xml version="1.0" encoding="UTF-8"?>
  6. <project xmlns="http://maven.apache.org/POM/4.0.0"
  7.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  8.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  9.     <modelVersion>4.0.0</modelVersion>
  11.     <groupId>com.zl.dubbo</groupId>
  12.     <artifactId>dubbo_demo</artifactId>
  13.     <packaging>pom</packaging>
  14.     <version>1.0-SNAPSHOT</version>
  15.     <modules>
  16.         <module>api</module>
  17.         <module>client</module>
  18.         <module>service</module>
  19.         <module>bootServer</module>
  20.         <module>bootClient</module>
  21.     </modules>
  25.     <properties>
  26.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  27.         <maven.compiler.source>1.7</maven.compiler.source>
  28.         <maven.compiler.target>1.7</maven.compiler.target>
  29.         <springframework.version>4.0.2.RELEASE</springframework.version>
  30.         <dubbo.version>2.5.7</dubbo.version>
  31.     </properties>
  34.     <dependencies>
  36.         <dependency>
  37.             <groupId>org.springframework</groupId>
  38.             <artifactId>spring-core</artifactId>
  39.             <version>${springframework.version}</version>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.springframework</groupId>
  43.             <artifactId>spring-context</artifactId>
  44.             <version>${springframework.version}</version>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.springframework</groupId>
  48.             <artifactId>spring-webmvc</artifactId>
  49.             <version>${springframework.version}</version>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>com.101tec</groupId>
  53.             <artifactId>zkclient</artifactId>
  54.             <version>0.3</version>
  55.         </dependency>
  56.         <dependency>
  57.             <groupId>org.apache.zookeeper</groupId>
  58.             <artifactId>zookeeper</artifactId>
  59.             <version>3.4.5</version>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>com.alibaba</groupId>
  63.             <artifactId>dubbo</artifactId>
  64.             <version>${dubbo.version}</version>
  65.             <scope>compile</scope>
  66.             <exclusions>
  67.                 <exclusion>
  68.                     <artifactId>spring</artifactId>
  69.                     <groupId>org.springframework</groupId>
  70.                 </exclusion>
  71.             </exclusions>
  72.         </dependency>
  73.     </dependencies>
  74. </project>
  76. 当前服务模块的pom.xml：只需要引下父模块即可
  78. <?xml version="1.0" encoding="UTF-8"?>
  79. <project xmlns="http://maven.apache.org/POM/4.0.0"
  80.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  81.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  82.     <parent>
  83.         <artifactId>dubbo_demo</artifactId>
  84.         <groupId>com.zl.dubbo</groupId>
  85.         <version>1.0-SNAPSHOT</version>
  86.     </parent>
  87.     <modelVersion>4.0.0</modelVersion>
  89.     <artifactId>service</artifactId>
  90.     <dependencies>
  91.         <dependency>
  92.             <groupId>com.zl.dubbo</groupId>
  93.             <artifactId>api</artifactId>
  94.             <version>1.0-SNAPSHOT</version>
  95.             <scope>compile</scope>
  96.         </dependency>
  97.     </dependencies>
  98. </project>
  100.  UserService公共接口实现类：    **注意：这里的@Service注解时dubbo提供的注解，不是spring的注解！**
  102. @Service
  103. public class UserServiceImpl implements UserService {
  105.     @Override
  106.     public String userName() {
  107.         return "张三";
  108.     }
  110.     @Override
  111.     public String userId() {
  112.         return "10001";
  113.     }
  114. }
  116.  dubbo集成spring配置文件：  这里的dubbo我们使用注解的方式  dubbo-annotation.xml
  118. <?xml version="1.0" encoding="UTF-8"?>
  120. <beans xmlns="http://www.springframework.org/schema/beans"
  121.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  122.        xmlns:context="http://www.springframework.org/schema/context"
  123.        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  124.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  125.      http://www.springframework.org/schema/beans/spring-beans.xsd
  126.           http://www.springframework.org/schema/context
  127.                         http://www.springframework.org/schema/context/spring-context-3.1.xsd
  128.      http://code.alibabatech.com/schema/dubbo
  129.      http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  131.     <!--<context:component-scan base-package="com.zl"/>-->
  133.     <!-- 提供方应用信息，用于计算依赖关系 -->
  134.     <dubbo:application name="storeServer_annotation"/>
  136.     <!-- 使用zookeeper注册中心暴露服务地址 -->
  137.     <dubbo:registry address="zookeeper://192.168.0.101:2181"/>
  139.     <!-- 用dubbo协议在20880端口暴露服务 -->
  140.     <dubbo:protocol name="rmi" port="20880"/>
  142.     <dubbo:annotation package="com.zl.service" />
  144. </beans>
  146.   以及最后一个启动类: Application.class
  148. public class Application {
  150.     public static void main(String[] args) throws IOException {
  151.         ClassPathXmlApplicationContext context =
  152.                 new ClassPathXmlApplicationContext("classpath:dubbo-annotation.xml");
  153.         //开启
  154.         context.start();
  155.         System.out.println("启动成功……");
  156.         System.in.read();   //避免程序结束，这里需要阻塞
  157.     }
  158. }

到此位置 ，dubbo服务端编写完毕

3）、编写客户端模块

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 2

客户端模块，这里主要作用是调用服务端接口，返回接口测试。为了简单java代码只有一个controller

  1. 这里是使用spring，所以我们为了测试需要集成tomcat,使用web.xml进行启动客户端服务进行测试。
  3. 首先需要新建客户端controller  ， @Reference是Dubbo提供的注解。这里的UserService是Dubbo通过zookeeper反射生成的一个代理对象，具体原理后面自行百度。
  5. @Controller
  6. public class UserController {
  8.     @Reference
  9.     private UserService userService;
  11.     @GetMapping("/index")
  12.     public String user(HttpServletRequest request){
  13.         String userId = userService.userId();
  14.         String userName = userService.userName();
  15.         request.setAttribute("userId",userId);
  16.         request.setAttribute("userName",userName);
  17.         return "index";
  18.     }
  19. }

新建dubbo配置文件以及springMvc配置文件。 dubbo-annotation.xml ; spring-mvc.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <beans xmlns="http://www.springframework.org/schema/beans"
  4.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5.        xmlns:context="http://www.springframework.org/schema/context"
  6.        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  7.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  8.      http://www.springframework.org/schema/beans/spring-beans.xsd
  9.           http://www.springframework.org/schema/context
  10.                         http://www.springframework.org/schema/context/spring-context-3.1.xsd
  11.      http://code.alibabatech.com/schema/dubbo
  12.      http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  14.     <!-- 提供方应用信息，用于计算依赖关系 -->
  15.     <dubbo:application name="enjoyStore_annotation"/>
  17.     <!-- 使用zookeeper注册中心暴露服务地址 -->
  18.     <dubbo:registry address="zookeeper://192.168.0.101:2181" check="false"/>
  20.     <dubbo:annotation package="com.zl.client.controller" />
  22. </beans>
  24. <?xml version="1.0" encoding="UTF-8"?>
  25. <beans xmlns="http://www.springframework.org/schema/beans"
  26.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
  27.        xmlns:context="http://www.springframework.org/schema/context"
  28.        xmlns:mvc="http://www.springframework.org/schema/mvc"
  29.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  30.                         http://www.springframework.org/schema/beans/spring-beans-3.1.xsd    
  31.                         http://www.springframework.org/schema/context    
  32.                         http://www.springframework.org/schema/context/spring-context-3.1.xsd    
  33.                         http://www.springframework.org/schema/mvc    
  34.                         http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
  36.     <context:component-scan base-package="com.zl.client.controller"></context:component-scan>
  38.     <mvc:annotation-driven/>
  40.     <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
  41.         <property name="prefix" value="/"></property>
  42.         <property name="suffix" value=".jsp"></property>
  44.     </bean>
  45.     <import resource="dubbo_annotation.xml"/>
  46. </beans>
  48.  后面是web.xml
  50. <?xml version="1.0" encoding="UTF-8"?>
  51. <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  52.          xmlns="http://java.sun.com/xml/ns/javaee"
  53.          xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
  54.          version="3.0">
  56.     <display-name>Archetype Created Web Application</display-name>
  58.     <!-- Spring MVC servlet -->
  59.     <servlet>
  60.         <servlet-name>SpringMVC</servlet-name>
  61.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  62.         <init-param>
  63.             <param-name>contextConfigLocation</param-name>
  64.             <param-value>classpath:spring-mvc.xml</param-value>
  65.         </init-param>
  66.         <load-on-startup>1</load-on-startup>
  67.         <async-supported>true</async-supported>
  68.     </servlet>
  69.     <servlet-mapping>
  70.         <servlet-name>SpringMVC</servlet-name>
  71.         <!-- 此处可以可以配置成*.do，对应struts的后缀习惯 -->
  72.         <url-pattern>/</url-pattern>
  73.     </servlet-mapping>
  74.     <welcome-file-list>
  75.         <welcome-file>/index.jsp</welcome-file>
  76.     </welcome-file-list>
  78. </web-app>
  80. 以及一个简单的jsp页面，显示用户名和名称
  82. <%@ page language="java"   contentType="text/html;charset=utf-8" pageEncoding="UTF-8"%>
  83. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
  84. <html>
  85. <body>
  86. <h2>Hello World!666</h2>
  87. <h2>用户ID: ${userId}</h2>
  88. <h2>用户名: ${userName}</h2>
  89. </body>
  90. </html>

到此位置，客户端服务搭建完毕。好了，我们启动开始测试吧。

先启动服务端：即运行Application类的main方法。

  1. 然后为客户端client添加一个tomcat容器，启动。
  3. 访问: http://localhost:8080/index

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 3

发现数据获取完毕，我们在打个断点看看。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 4

发现这个userService对象的确是一个代理对象。 结束！

2、使用dubbo+springboot搭建案例

搭建完spring的案例，springboot就更简单了。

1）、首先一样的道理，公共接口模块已经定义好了，这里不需要定义了。我们从服务端模块开始

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 5

application.yml配置 ： 端口、dubbo.name随便设置

  1. server:
  2.   port: 8090
  4. dubbo:
  5.   name: serverBoot
  6.   zookeeper: zookeeper://192.168.0.101:2181

UserService实现类： UserServiceImpl.class

  1. @Service
  2. public class UserServiceImpl  implements UserService{
  3.     @Override
  4.     public String userName() {
  5.         return "李四";
  6.     }
  8.     @Override
  9.     public String userId() {
  10.         return "10003";
  11.     }
  12. }
  14.  springboot这里就用@Bean注解来进行配置了：DubboBean.class
  16. @Configuration
  17. public class DubboBean {
  19.     @Value("${dubbo.zookeeper}")
  20.     private String zkAddr;
  21.     @Value("${dubbo.name}")
  22.     private String appName;
  24.     @Bean
  25.     public ApplicationConfig applicationConfig() {
  26.         ApplicationConfig applicationConfig = new ApplicationConfig();
  27.         applicationConfig.setName(appName);
  28.         return applicationConfig;
  29.     }
  31.     @Bean
  32.     public RegistryConfig registryConfig() {
  33.         RegistryConfig registryConfig = new RegistryConfig();
  34.         registryConfig.setAddress(zkAddr);
  35.         return registryConfig;
  36.     }
  38.     @Bean
  39.     public ProtocolConfig protocolConfig() {
  40.         ProtocolConfig protocolConfig = new ProtocolConfig();
  41.         protocolConfig.setName("dubbo");
  42.         protocolConfig.setPort(20881);
  43.         return protocolConfig;
  44.     }
  45. }
  47.  最后一个启动类
  51. @SpringBootApplication
  52. @DubboComponentScan(basePackages = "com.zl.service")
  53. public class Application {
  55.     public static void main(String[] args) {
  56.         SpringApplication.run(Application.class,args);
  57.     }
  58. }

2）、客户端

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 6

  1.  application.yml配置：
  3. server:
  4.   port: 8082
  6. dubbo:
  7.   name: serverBoot
  8.   zookeeper: zookeeper://192.168.0.101:2181
  10.  UserController.class     
  12. @RestController
  13. public class UserController {
  15.     @Reference
  16.     private UserService userService;
  18.     @GetMapping("/user")
  19.     public String user(){
  20.         String userId = userService.userId();
  21.         String userName = userService.userName();
  22.         return "用户ID: "+userId+", 用户名称:"+userName;
  23.     }
  24. }
  26. DubboInit.class 配置类
  28. @Configuration
  29. public class DubboInit {
  31.     @Value("${dubbo.zookeeper}")
  32.     private String zkAddr;
  33.     @Value("${dubbo.name}")
  34.     private String appName;
  36.     @Bean
  37.     public ApplicationConfig applicationConfig() {
  38.         ApplicationConfig applicationConfig = new ApplicationConfig();
  39.         applicationConfig.setName(appName);
  40.         return applicationConfig;
  41.     }
  43.     @Bean
  44.     public RegistryConfig registryConfig() {
  45.         RegistryConfig registryConfig = new RegistryConfig();
  46.         registryConfig.setAddress(zkAddr);
  47.         return registryConfig;
  48.     }
  50. }

最后一个启动类：

  1. @SpringBootApplication
  2. @DubboComponentScan("com.zl.client")
  3. public class Application {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(Application.class,args);
  7.     }
  8. }

大功告成，老套路，先启动服务模块，然后启动客户端模块

访问：http://localhost:8082/user

20190408211623435.png

  1. 我们在打个断点卡看看：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 7

到此位置，dubbo案例搭建+测试完毕，我们再来看看整个案例的总体模块划分

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbGVpMDgyMzE5_size_16_color_FFFFFF_t_70 8

以上，有帮助的点个赞啊！

发表评论

表情：
评论列表 （有 0 条评论，396人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Dubbo 入门搭建

    一、背景与架构(摘自官网) 随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不

    青旅半醒青旅半醒/ 0 赞/ 121 阅读