SpringBoot+Dubbo整合

Bertha 。 2021-09-19 07:28 536阅读 0赞

此demo是SpringBoot中整合使用Dubbo，以及Mybaits；以达到分布式服务项目。

项目结构如下图：
在这里插入图片描述
分为三个项目，将service接口、service实现、web层分开。

  • springboot-dubbo-api
    在这里插入图片描述
    此项目为service接口层，主要放service接口、实体类、dto、枚举类、异常类等其它两个module中通用类和相关方法。
  • springboot-dubbo-service
    在这里插入图片描述
    此项目为具体的业务实现，包括具体的业务代码、Mybatis的mapper接口和sql语句。既为服务提供者（provider），service会注册为dubbo服务，使用zookeeper进行管理。
  • springboot-dubbo-web
    -在这里插入图片描述
    此项目和前端打交道，为前端输出数据。服务的消费者，需要注册为服务消费者（consumer），从zookeeper中获取已注册的服务。

具体实现
project 中pom文件配置

  1. <groupId>com.shuyu</groupId>
  2.     <artifactId>springboot-dubbo</artifactId>
  3.     <packaging>pom</packaging>
  4.     <version>0.0.1-SNAPSHOT</version>
  6.     <modules>
  7.         <module>springboot-dubbo-api</module>
  8.         <module>springboot-dubbo-service</module>
  9.         <module>springboot-dubbo-web</module>
  10.     </modules>
  12.     <parent>
  13.         <groupId>org.springframework.boot</groupId>
  14.         <artifactId>spring-boot-starter-parent</artifactId>
  15.         <version>2.1.4.RELEASE</version>
  16.         <relativePath/> <!-- lookup parent from repository -->
  17.     </parent>
  20.     <properties>
  21.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  23.         <java.version>1.8</java.version>
  24.         <mysql-connector.version>6.0.6</mysql-connector.version>
  25.         <commons.collections.version>3.2.1</commons.collections.version>
  26.     </properties>
  29.     <dependencyManagement>
  30.         <dependencies>
  31.             <!-- 数据库驱动 -->
  32.             <dependency>
  33.                 <groupId>mysql</groupId>
  34.                 <artifactId>mysql-connector-java</artifactId>
  35.                 <version>5.1.25</version>
  36.             </dependency>
  37.             <dependency>
  38.                 <groupId>commons-collections</groupId>
  39.                 <artifactId>commons-collections</artifactId>
  40.                 <version>${commons.collections.version}</version>
  41.             </dependency>
  43.             <!--dubbo start-->
  44.             <dependency>
  45.                 <groupId>com.alibaba</groupId>
  46.                 <artifactId>dubbo</artifactId>
  47.                 <version>2.5.3</version>
  48.                 <exclusions>
  49.                     <exclusion>
  50.                         <groupId>org.springframework</groupId>
  51.                         <artifactId>spring</artifactId>
  52.                     </exclusion>
  53.                 </exclusions>
  54.             </dependency>
  55.             <dependency>
  56.                 <groupId>com.101tec</groupId>
  57.                 <artifactId>zkclient</artifactId>
  58.                 <version>0.8</version>
  59.                 <exclusions>
  60.                     <exclusion>
  61.                         <artifactId>activation</artifactId>
  62.                         <groupId>javax.activation</groupId>
  63.                     </exclusion>
  64.                     <exclusion>
  65.                         <artifactId>mail</artifactId>
  66.                         <groupId>javax.mail</groupId>
  67.                     </exclusion>
  68.                     <exclusion>
  69.                         <artifactId>slf4j-log4j12</artifactId>
  70.                         <groupId>org.slf4j</groupId>
  71.                     </exclusion>
  72.                 </exclusions>
  73.             </dependency>
  74.             <dependency>
  75.                 <groupId>org.apache.zookeeper</groupId>
  76.                 <artifactId>zookeeper</artifactId>
  77.                 <version>3.4.6</version>
  78.                 <exclusions>
  79.                     <exclusion>
  80.                         <artifactId>slf4j-log4j12</artifactId>
  81.                         <groupId>org.slf4j</groupId>
  82.                     </exclusion>
  83.                 </exclusions>
  84.             </dependency>
  85.             <!-- dubbo end -->
  88.         </dependencies>
  89.     </dependencyManagement>
  90. </project>

  • springboot-dubbo-api
    主要是service接口和实体对象，其中实体对象一定要实现Serializable接口，不然在注册dubbo服务时会报错。
    其次在pom.xml文件中，需要将此项目打包为jar文件，具体配置如下

    com.shuyu

    1. <artifactId>springboot-dubbo-api</artifactId>
    2. <version>0.0.1-SNAPSHOT</version>
    3. <name>springboot-dubbo-api</name>
    4. <description>Demo project for Spring Boot</description>
    5. <packaging>jar</packaging>
    7. <parent>
    8.     <groupId>com.shuyu</groupId>
    9.     <artifactId>springboot-dubbo</artifactId>
    10.     <version>0.0.1-SNAPSHOT</version>
    11. </parent>
  1.     <dependencies>
  2.         <dependency>
  3.             <groupId>org.projectlombok</groupId>
  4.             <artifactId>lombok</artifactId>
  5.             <version>1.16.20</version>
  6.             <scope>provided</scope>
  7.         </dependency>
  8.     </dependencies>
  11. </project>

在开发过程中，此项目代码有修改需要更新在maven仓库中，具体操作就是maven install

  • springboot-dubbo-service
    首先maven依赖，需要注意的时，要将springboot-dubbo-api项目依赖加进来。不然无法实现service接口和使用实体类。

    com.shuyu

    1. <artifactId>springboot-dubbo-service</artifactId>
    2. <version>0.0.1-SNAPSHOT</version>
    3. <name>springboot-dubbo-service</name>
    4. <description>Demo project for Spring Boot</description>
    6. <parent>
    7.     <groupId>com.shuyu</groupId>
    8.     <artifactId>springboot-dubbo</artifactId>
    9.     <version>0.0.1-SNAPSHOT</version>
    10. </parent>
    12. <dependencies>
    13.     <dependency>
    14.         <groupId>org.springframework.boot</groupId>
    15.         <artifactId>spring-boot-starter-web</artifactId>
    16.         <exclusions>
    17.             <exclusion>
    18.                 <groupId>org.slf4j</groupId>
    19.                 <artifactId>log4j-over-slf4j</artifactId>
    20.             </exclusion>
    21.         </exclusions>
    22.     </dependency>
    24.     <dependency>
    25.         <groupId>org.projectlombok</groupId>
    26.         <artifactId>lombok</artifactId>
    27.         <optional>true</optional>
    28.     </dependency>
    29.     <dependency>
    30.         <groupId>org.springframework.boot</groupId>
    31.         <artifactId>spring-boot-starter-test</artifactId>
    32.         <scope>test</scope>
    33.     </dependency>
    35.     <!-- log4j -->
    36.     <!-- https://mvnrepository.com/artifact/log4j/log4j -->
    37.     <dependency>
    38.         <groupId>log4j</groupId>
    39.         <artifactId>log4j</artifactId>
    40.         <version>1.2.17</version>
    41.     </dependency>
  1.         <!-- Spring Boot Dubbo 依赖 -->
  2.         <dependency>
  3.             <groupId>io.dubbo.springboot</groupId>
  4.             <artifactId>spring-boot-starter-dubbo</artifactId>
  5.             <version>1.0.0</version>
  6.             <exclusions>
  7.                 <exclusion>
  8.                     <artifactId>javassist</artifactId>
  9.                     <groupId>org.javassist</groupId>
  10.                 </exclusion>
  11.             </exclusions>
  12.         </dependency>
  15.         <!--服务接口-->
  16.         <dependency>
  17.             <groupId>com.shuyu</groupId>
  18.             <artifactId>springboot-dubbo-api</artifactId>
  19.             <version>0.0.1-SNAPSHOT</version>
  20.         </dependency>
  22.         <!--mybaits -->
  23.         <dependency>
  24.             <groupId>org.mybatis.spring.boot</groupId>
  25.             <artifactId>mybatis-spring-boot-starter</artifactId>
  26.             <version>1.3.0</version>
  27.         </dependency>
  29.         <!--ali druid-->
  30.         <dependency>
  31.             <groupId>com.alibaba</groupId>
  32.             <artifactId>druid</artifactId>
  33.             <version>1.0.18</version>
  34.         </dependency>
  36.         <dependency>
  37.             <groupId>org.javassist</groupId>
  38.             <artifactId>javassist</artifactId>
  39.             <version>3.25.0-GA</version>
  40.         </dependency>
  42.         <dependency>
  43.             <groupId>mysql</groupId>
  44.             <artifactId>mysql-connector-java</artifactId>
  45.         </dependency>
  47.         <dependency>
  48.         <groupId>commons-collections</groupId>
  49.         <artifactId>commons-collections</artifactId>
  50.         </dependency>
  52.     </dependencies>
  54.     <build>
  55.         <plugins>
  56.             <plugin>
  57.                 <groupId>org.springframework.boot</groupId>
  58.                 <artifactId>spring-boot-maven-plugin</artifactId>
  59.             </plugin>
  60.         </plugins>
  61.     </build>
  63. </project>

关键java代码

  1. @Service(version = "1.0.0")
  2. @org.springframework.stereotype.Service
  3. @Slf4j
  4. public class UserServiceImpl implements UserService { 
  5.     @Autowired
  6.     private UserMapper userMapper;
  8.     @Override
  9.     public List<UserDTO> listUser() { 
  10.         List<User> users = userMapper.listUser();
  11.         log.info("users.size" + users.size());
  12.         List<UserDTO> userDTOList = new ArrayList<>();
  13.         userDTOList = users.stream().map(user -> { 
  14.             return new UserDTO(user.getUserName(), user.getUserCode());
  15.         }).collect(Collectors.toList());
  16.         return userDTOList;
  17.     }
  18. }

  • springboot-dubbo-web
    pom配置


    com.shuyu
    springboot-dubbo
    0.0.1-SNAPSHOT
     
    1. <dependencies>
    2.     <dependency>
    3.         <groupId>org.springframework.boot</groupId>
    4.         <artifactId>spring-boot-starter-web</artifactId>
    5.     </dependency>
    7.     <dependency>
    8.         <groupId>org.projectlombok</groupId>
    9.         <artifactId>lombok</artifactId>
    10.         <optional>true</optional>
    11.     </dependency>
    12.     <dependency>
    13.         <groupId>org.springframework.boot</groupId>
    14.         <artifactId>spring-boot-starter-test</artifactId>
    15.         <scope>test</scope>
    16.     </dependency>
  1.         <!-- log4j -->
  2.         <!-- https://mvnrepository.com/artifact/log4j/log4j -->
  3.         <dependency>
  4.             <groupId>log4j</groupId>
  5.             <artifactId>log4j</artifactId>
  6.             <version>1.2.17</version>
  7.         </dependency>
  9.         <!-- Spring Boot Dubbo 依赖 -->
  10.         <dependency>
  11.             <groupId>io.dubbo.springboot</groupId>
  12.             <artifactId>spring-boot-starter-dubbo</artifactId>
  13.             <version>1.0.0</version>
  14.         </dependency>
  16.         <!--服务接口-->
  17.         <dependency>
  18.             <groupId>com.shuyu</groupId>
  19.             <artifactId>springboot-dubbo-api</artifactId>
  20.             <version>0.0.1-SNAPSHOT</version>
  21.         </dependency>
  24.         <dependency>
  25.             <groupId>org.javassist</groupId>
  26.             <artifactId>javassist</artifactId>
  27.             <version>3.25.0-GA</version>
  28.         </dependency>
  30.         <dependency>
  31.             <groupId>mysql</groupId>
  32.             <artifactId>mysql-connector-java</artifactId>
  33.         </dependency>
  35.     </dependencies>
  37.     <build>
  38.         <plugins>
  39.             <plugin>
  40.                 <groupId>org.springframework.boot</groupId>
  41.                 <artifactId>spring-boot-maven-plugin</artifactId>
  42.             </plugin>
  43.         </plugins>
  44.     </build>

java核心代码

  1. RestController
  2. @RequestMapping("user")
  3. public class UserController { 
  5.     @Reference(version = "1.0.0")
  6.     private UserService userService;
  8.     @RequestMapping("hello")
  9.     public List<UserDTO> hello() { 
  10.         List<UserDTO> userDTOList = userService.listUser();
  11.         return userDTOList;
  12.     }
  13. }

dubbo配置，由于加入的依赖是spring-boot-starter-dubbo，已经和springboot集成了，所以只需要在application.properties(或者appl.yml)文件中加入配置，如下：

Dubbo 服务提供者配置

spring.dubbo.application.name=provider
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=com.llf.springboot.dubbo
在上面配置中，zookeeper为本地启动的，需要事先安装启动，具体流程不再讲解。scan的包为接口实现的所在的包目录。

注意：在service实现类中加入是@Service注解要是dubbo的Service注解，com.alibaba.dubbo.config.annotation.Service;

dubbo服务配置，项目要对service服务进行消费，需要进行消费者配置。

Dubbo 服务消费者配置

spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=com.llf.springboot.dubbo
注意：在controller进行service注入时需要使用@Reference
com.alibaba.dubbo.config.annotation.Reference

使用
启动本地zookeeper
先启动springboot-dubbo-service项目，再启动springboot-dubbo-web，然后调用接口即可

项目源码：https://github.com/iot-wangshuyu/springboot-dubbo

发表评论

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

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

相关阅读

    相关 ssm整合

    在mybatis和spring整合后 , 在把springmvc整合进来 在maven里创建web工程 然后进行mybatis和spring的整合步骤(写在其他博客里)

    超、凢脫俗超、凢脫俗/ 0 赞/ 518 阅读