搭建dubbo-zk应用

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"?>

4.0.0

<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>

2.创建共用Dubbo_Api
2.1 pom
<?xml version="1.0" encoding="UTF-8"?>

Dubbo_Soul
com.youzha
1.0-SNAPSHOT

4.0.0

<artifactId>Dubbo_Api</artifactId>

<dependencies>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.16.20</version>
    </dependency>
</dependencies>

2.2 创建共用资源

整体目录结构：
|── com.youzha.dubbo
|── dto 封装共用返回Result
|── entity 共用参数，返回Body
|── service 暴露Service，提供给第三方使用

3.创建提供者Dubbo_Provider
3.1 pom
<?xml version="1.0" encoding="UTF-8"?>

Dubbo_Soul
com.youzha
1.0-SNAPSHOT

4.0.0

<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>

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"?>

Dubbo_Soul
com.youzha
1.0-SNAPSHOT

4.0.0

<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>

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