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