概述

使用 SpringBoot 整合 Dubbo 时，我们需要有一个服务的注册中心，这里的注册中心我们选用Zookeeper，然后要编写服务的提供者、服务的消费者。在提供者工程中使用@Service注解暴露服务，在消费者工程中使用@Reference引用服务。

由于我们使用 Zookeeper 作为注册中心，所以需要操作 Zookeeper 。Dubbo 2.6以前的版本引入zkclient操作 Zookeeper ，Dubbo 2.6及以后的版本引入curator操作 Zookeeper。

项目的整体结构：

user-parent：父工程、打包方式为pom，Maven形式。
user-provider：服务提供者工程，SpringBoot的Web工程。
user-consumer：服务的消费者工程，SpringBoot的Web工程。
user-model：模型层工程，用于封装实体类等，Maven的Jar工程。
user-mapper：数据访问层工程，用于操作数据库，Maven的Jar工程。
user-interface：公共接口工程，用于将provider和consumer的公共接口抽取。Maven的Jar工程。

我们可以只有两个子工程，在provider中编写entity、mapper、service的代码，将服务暴露，在consumer中编写controller，引用服务。

编写代码

导入依赖

父工程就是一个Maven项目，没有具体的代码，相当于一个目录，将子工程放在一起，可以用来管理Jar包的依赖。注意在pom文件中将打包方式改为pom即可。其它的子项目都相当于它的一个个模块。

<packaging>pom</packaging>

模型层工程：正常编写数据库对应的实体类即可。
数据访问层在pom文件中需要引用Mybayis相关的依赖，还要将模型层工程引入pom文件中。将mapper.xml文件存放在resources目录下。

<dependency>
    <groupId>com.coydone</groupId>
    <artifactId>user-model</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

公共接口本质是将service的接口抽取出来，在这里需要引入模型层依赖。

<dependency>
    <groupId>com.coydone</groupId>
    <artifactId>user-model</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

服务提供者

1、在pom文件中需要引入接口，Dubbo相关依赖、Zookeeper相关依赖、我们在这里配置数据库相关信息，需要引入数据库相关依赖。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>user-parent</artifactId>
        <groupId>com.coydone</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>user-provider</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.coydone</groupId>
            <artifactId>user-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.coydone</groupId>
            <artifactId>user-mapper</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
        </dependency>

        <!--这是一个springboot项目-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!--这是一个springboot-jdbc项目-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>

        <!--dubbo相关的-->
        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <!-- 使用zk 做注册中心，Dubbo 需要的依赖 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
    </dependencies>

    <build>
        <!-- 当项目编译时，会把其它所有依赖的包全部打入jar包-->
        <finalName>user-provider</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

2、在配置文件中配置数据库、Zookeeper、Dubbo相关配置。

#数据源的配置
spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/user?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
    username: root
    password: root123
    #注入数据源的类型   默认的为HikariDataSource
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      max-active: 20
      min-idle: 5
      validation-query: select x
      initial-size: 3
      max-wait: 5000
      stat-view-servlet:
        #        login-username: root
        #        login-password: 123456
        allow:
        deny:
        url-pattern: /api/druid/*
        enabled: true  #启用数据源监控
#mybatisplus的配置
mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  mapper-locations: classpath:mapper/*Mapper.xml
  global-config:
    db-config:
      id-type: auto

dubbo:
  #声明注册到zk的名字 应该程序的名称
  application:
    name: bills-service-provider
  #声明注册中心的地址和方式
  registry:
    address: zookeeper://127.0.0.1:2181
  #使用dubbo协议，将服务暴露在20880端口
  protocol:
    name: dubbo
    port: 20880
  #提供者全局配置
  provider:
    timeout: 4000
    retries: 2
    loadbalance: random

3、编写接口的实现类，在实现类中暴露服务。

package com.coydone.service.impl;

import org.apache.dubbo.config.annotation.Service;

@Service  //暴露服务
public class BillsServiceImpl implements BillsService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public int addUser(User user) {
        return userMapper.insert(user);
    }
}

4、修改启动类

@SpringBootApplication
@EnableDubbo//开启注解的dubbo功能
@MapperScan(basePackages = {"com.coydone.mapper"})
public class UserProvider {
    public static void main(String[] args) {
        SpringApplication.run(UserProvider.class,args);
        System.out.println("服务提供者启动成功");
    }
}

服务消费者

1、在pom文件中导入相关依赖，这里除了数据库相关依赖，其它和服务提供者工程一样。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>user-parent</artifactId>
        <groupId>com.coydone</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>bills-consumer</artifactId>

    <dependencies>
        <!--这是一个springboot-web项目-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>com.coydone</groupId>
            <artifactId>user-model</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>com.coydone</groupId>
            <artifactId>user-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>


        <!--dubbo相关的-->
        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <!-- 使用zk 做注册中心，Dubbo 需要的依赖 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

    </dependencies>

    <build>
        <!-- 当项目编译时，会把其它所有依赖的包全部打入jar包-->
        <finalName>user-consumer</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2、配置Dubbo相关。

#端口
server:
  port: 8080
#spring的配置
#数据源的配置
spring:
  mvc:
    format:
      date-time: yyyy-MM-dd HH:mm:ss
  jackson:
    date-format: yyyy-MM-dd HH:mm:ss
    time-zone: GMT+8
dubbo:
  #声明注册到zk的名字 应该程序的名称
  application:
    name: user-consumer
  #声明注册中心的地址和方式
  registry:
    address: zookeeper://127.0.0.1:2181

3、编写控制器，消费服务。

package com.coydone.contrller;

@RestController
@RequestMapping("/api")
public class UserController {

    @Reference
    public UserService userService;

    @RequestMapping("user/addUser")
    public int addBills(User user){
        return this.userService.addUser(user);
    }
}

4、启动类开启Dubbo。

package com.coydone;

@SpringBootApplication
@EnableDubbo
public class UserConsumer {

    public static void main(String[] args) {
        SpringApplication.run(UserConsumer.class,args);
        System.out.println("消费者启动成功");
    }
}

目录CONTENT

SpringBoot整合Dubbo

概述

编写代码

导入依赖

服务提供者

服务消费者

评论区