SpringBoot集成Dubbo服务，我行你也行

0x00、基础概念

首先要简单了解下Dubbo、RPC、分布式是什么，不然干起来会懵。先说分布式，简单说就是把一个完整的系统拆分成不同的服务，然后将这些服务放在不同的服务器上减轻单体服务的压力提高并发量和性能，而不同服务之间需要互相调用，而远程过程调用（RPC）就可以让一台计算机上的程序调用另一个台计算机上的子程序，就像调用本地程序一样。RPC是一种服务器-客户端模式，通过发送请求-接受回应进行交互，（注意RPC是一种技术思想）

而Dubbo是阿里巴巴公司开源的一个服务框架，可以轻松实现各个服务之间的RPC调用。

另外Dubbo还需要使用一个注册中心，可以使用Multicast、Redis、Zookeeper 等，用于服务地址的注册与查找，官方文档中推荐我们使用Zookeeper，那我们就使用Zookeeper吧。

0x01、工作流程

1. 服务提供者在启动时，向注册中心注册自己所提供的服务，就是提供自己的方法信息。

2. 服务消费者在启动时，向注册中心订阅自己所需的服务。

3. 注册中心返回服务提供者地址列表给消费者，如果有变动，注册中心会主动推送最新的数据给消费者。

4. 服务消费者通过负载均衡算法从提供的服务列表中选一台提供者进行调用，如果失败，则选择另一台调用。

0x02、使用步骤

参考了很多文章，发现他们基于SpringBoot时依赖的jar也不一样，源码我并没有阅读过，所以试了不同jar，发现也有所不同，下面会说明。

0.安装zookeeper

这里就不说了，是必须要安装的。

1.引入依赖

下面这种方式是依赖最多的，如果不引入上面两个，在我的项目中会报错，是因为zookeeper类找不到。

<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.14</version><exclusions><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions>
</dependency>
<dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.10</version>
</dependency>
<dependency><groupId>com.alibaba.spring.boot</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.0.0</version>
</dependency>

2.定义服务接口

这个推荐单独打包，在服务提供方和消费方中都引入，在这里就不单独打包了。

public interface IUser {public List<String> listUserId();
}

3.服务提供方实现接口

注意这里的@Service注解不是Spring中的，是dubbo中的。

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;import java.util.List;
import java.util.function.Supplier;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@Service
@Component
public class UserImpl  implements IUser{int i =0;@Overridepublic List<String> listUserId() {List<String> collect = Stream.generate(() -> {return "user"+(++i);}).limit(20).collect(Collectors.toList());return collect;}
}

4.配置

在application.properties中配置如下信息，可能你会看到其他文章是dubbo.开头的，而非spring.

spring.dubbo.application.name=user-provider
spring.dubbo.registry.address=zookeeper://localhost:2181

然后在启动类上加入下面这个注解，用于开启dubbo的自动配置。

@EnableDubboConfiguration

还有一个注解是@EnableDubbo，和上面的作用一样，但是，启动时可能会报以下错误。

错误信息中说了是application.name没有配置，但是上面你也确确实实在application.properties中写了，解决办法很简单，就是把application.properties中关于dubbo配置前面的spring.删了，改成下面这样，就可以启动了。

dubbo.application.name=user-provider
dubbo.registry.address=zookeeper://localhost:2181

服务消费者

注意这是两个工程。

0.配置

dubbo.application.name=user-consumer
dubbo.registry.address=zookeeper://localhost:2181

1.定义服务接口

同样加入接口，包名要一样。

public interface IUser {public List<String> listUserId();
}

2.控制器

在字段上加入@Reference注解就完事了，便实现了对服务提供者的所实现的IUser进行调用。

@RestController
public class TestController {private Logger log = LoggerFactory.getLogger(TestController.class);@Referenceprivate IUser user;@GetMapping("listUserId")public List<String> listUser() {return user.listUserId();}
}

启动

先启动zookeeper，然后启动服务提供者，最后在启动服务消费者，可以通过zkui查看zk的数据，里面的consumers是服务消费着，providers是服务提供者。

另一个依赖

这次只需要加入这一个依赖即可，他内部已经加入了所需的依赖，配置信息是dubbo.XX开头

<dependency><groupId>com.alibaba.boot</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>0.2.0</version>
</dependency>

总结

后端的路还长，跑着学啊。