springboot：2.2.2

alibaba.dubbo：2.0.0

zkclinet：0.10

JDK：1.8

1.创建父工程

Idea或Eclipse创建普通Maven工程，GAV定义随意，也可以参考我的

G：com.youzha

A：Dubbo_Soul

V：1.0-SNAPSHOT

父pom完整文件(该文件包括三个子module，在之后创建)

<?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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.youzha</groupId>
    <artifactId>Dubbo_Soul</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>Dubbo_Provider</module>
        <module>Dubbo_Consumer</module>
        <module>Dubbo_Api</module>
    </modules>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.2.RELEASE</version>
    </parent>
    <properties>
        <!--1.0版本增加-->
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <boot.dubbo.version>2.0.0</boot.dubbo.version>
        <zkclient.version>0.10</zkclient.version>
        <!--1.0版本结束-->
    </properties>
    <dependencyManagement>
        <dependencies>
            <!--1.0 开始-->
            <dependency>
                <groupId>com.alibaba.spring.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>${boot.dubbo.version}</version>
            </dependency>
            <!-- ZooKeeper client -->
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
            <!--1.0结束-->
        </dependencies>
    </dependencyManagement>
</project>

2.创建共用Dubbo_Api

2.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>Dubbo_Soul</artifactId>
        <groupId>com.youzha</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>Dubbo_Api</artifactId>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.20</version>
        </dependency>
    </dependencies>
</project>

2.2 创建共用资源

整体目录结构：

|── com.youzha.dubbo

|── dto 封装共用返回Result

|── entity 共用参数，返回Body

|── service 暴露Service，提供给第三方使用

3.创建提供者Dubbo_Provider

3.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>Dubbo_Soul</artifactId>
        <groupId>com.youzha</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>Dubbo_Provider</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.youzha</groupId>
            <artifactId>Dubbo_Api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--com.dubbo-springBoot依赖 -->
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

3.2 Service

需要注意的是，这里的@Service引自：import com.alibaba.dubbo.config.annotation.Service;，标注其为一个Dubbo的Service，而下面的@Component才是将其注入成一个Spring Bean。

import com.alibaba.dubbo.config.annotation.Service;
import com.youzha.dubbo.entity.User;
import com.youzha.dubbo.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.Date;
/**
 * @author youzhaxiaobo
 * @version 1.0
 * @date 2020/7/1 19:06
 * @Desc
 */
@Slf4j
@Service
@Component
public class UserServiceImpl implements UserService {
    @Override
    public User findById(int id) {
        if(id < 0) {
            log.info("非法请求，ID:{}", id);
            return null;
        }
        User user = new User(1, "youzha", 1L, new Date());
        log.info("提供者返回数据:{}", user.toString());
        return user;
    }
}

3.3 Controller

这里的Controller模拟多个服务，除提供Dubbo接口外，自身还提供Http接口。

import com.youzha.dubbo.dto.ResultDTO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
/**
 * @author youzhaxiaobo
 * @version 1.0
 * @date 2020/7/4 0004 13:52
 * @Desc
 */
@Slf4j
@RestController
@RequestMapping("/provider")
public class ProviderController {
    @GetMapping(value = "/hello", produces = MediaType.APPLICATION_JSON_VALUE)
    public ResultDTO getUserById(@RequestParam("id") int id) {
        log.info("id=" + id);
        if (id > 0) {
            return new ResultDTO(-1, "获取失败");
        }
        return new ResultDTO(200, "获取成功");
    }
}

3.4 启动类Application

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
 * @author youzhaxiaobo
 * @version 1.0
 * @date 2020/7/1 19:15
 * @Desc
 */
@EnableDubbo
@SpringBootApplication
public class DubboProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboProviderApplication.class, args);
    }
}

3.5 配置文件

server:
  port: 9091
spring:
  main:
    allow-bean-definition-overriding: true
dubbo:
  application:
    name: dubbo-consumer
    id: dubbo-consumer
  registry:
    address: zookeeper://127.0.0.1:2181
  protocol:
    name: dubbo
    port: 20883
  scan:
    base-packages: com.youzha.dubbo.service
logging:
  level:
    root: info
    org.springframework.boot: info
    org.apache.ibatis: info
    org.dromara.soul.bonuspoint: info
    org.dromara.soul.lottery: info
    org.dromara.soul: info

4.创建消费者Dubbo_Consumer

4.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>Dubbo_Soul</artifactId>
        <groupId>com.youzha</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>Dubbo_Consumer</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.youzha</groupId>
            <artifactId>Dubbo_Api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--com.dubbo-springBoot依赖 -->
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

4.2 Service

4.2.1 定义Sevice

这个Service是我们自己业务所需，只是在这个Service中的某些数据我们要调用Provider服务而已，这个和Provider提供的service本身没有直接关系，也不需要保持方法名，入参的完全一致，只是引用。

public interface RemoteUserService {
    /**
     * ID查找用户
     * @param id    用户ID
     * @return  USER对象
     */
    User findById(int id);
}

4.2.2 定义ServiceImpl

import com.alibaba.dubbo.config.annotation.Reference;
import com.youzha.dubbo.entity.User;
import com.youzha.dubbo.service.RemoteUserService;
import com.youzha.dubbo.service.UserService;
import org.springframework.stereotype.Service;
/**
 * @author youzhaxiaobo
 * @version 1.0
 * @date 2020/7/1 19:06
 * @Desc
 */
@Service
public class UserServiceImpl implements RemoteUserService {
    @Reference
    private UserService userService;
    @Override
    public User findById(int id) {
        return userService.findById(id);
    }
}

说明：

实现是的我们自身的业务接口
通过dubbo的@Reference注解，注入Provider的Service【而提供者是通过dubbo的@Service注解暴露，暴露和注入都在zookeeper获取】

4.3 Controller

@Slf4j
@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    @Autowired
    private RemoteUserService userService;
    @GetMapping(value = "/getUserById", produces = MediaType.APPLICATION_JSON_VALUE)
    public ResultDTO getUserById(@RequestParam("id") int id) {
        log.info("id=" + id);
        User user = userService.findById(id);
        log.info("消费者获取用户，信息为:{}", user);
        if(null == user) {
           return new ResultDTO(-1, "获取失败");
        }
        return new ResultDTO(200, "获取成功", user);
    }
}

4.4 启动类Application

@EnableDubbo
@SpringBootApplication
public class DubboConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboConsumerApplication.class, args);
    }
}

4.5 配置文件

server:
  port: 9092
spring:
  main:
    allow-bean-definition-overriding: true
dubbo:
  application:
    name: dubbo-consumer
    id: dubbo-consumer
  registry:
    address: zookeeper://127.0.0.1:2181
  protocol:
    name: dubbo
    port: 20883
  scan:
    base-packages: com.youzha.dubbo.service
logging:
  level:
    root: info
    org.springframework.boot: info
    org.apache.ibatis: info
    org.dromara.soul.bonuspoint: info
    org.dromara.soul.lottery: info
    org.dromara.soul: info

5.验证

5.1 运行zookeeper

当然前提是需要安装zk，配置文件也可以看到我这里启动的本地zk（如果你使用的其他地址的zk，替换上图zk的地址即可），如果没有可以参考这个附件：

📎zookeeper.rar

运行前你需要解压打开：zookeeper-3.4.14\conf\zoo.cfg，确保对应的dataDir在你本地存在，如果是Linux系统换成对应的路径即可，下图示例：Windows本地

进入：zookeeper-3.4.14\bin，

如果你和我一样是Windows环境测试，双击：zkServer.cmd，

如果你是Linux环境，启动zkServer.sh，二者效果完全一致，启动后类似下图则表示启动完成：

5.2 启动提供者

直接启动对应的启动类Application即可。

5.3 启动消费者

直接启动对应的启动类Application即可。

5.4 请求验证

postman发送地址请求：http://localhost:9092/consumer/getUserById?id=1

查看消费者日志：

查看提供者日志：

6.总结

如果你在本章节，运行并未出现上述效果，可能是哪里出错了，我们在接下来的网关接入，一样比对着可以修复，你可以百度自行解决当前问题，也可直接进入下一章节，进行网关接入，一起验证。

2.搭建dubbo-zk应用