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>



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



</properties>

<dependencyManagement>

<dependencies>



<dependency>

<groupId>com.alibaba.spring.boot</groupId>

<artifactId>dubbo-spring-boot-starter</artifactId>

<version>${boot.dubbo.version}</version>

</dependency>



<dependency>

<groupId>com.101tec</groupId>

<artifactId>zkclient</artifactId>

<version>${zkclient.version}</version>

</dependency>



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



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



<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.总结

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

52-微服务技术栈（高级）：微服务网关Soul（搭建dubbo-zk应用）