技术需求点:
一.dubbo机制和原理;
二.构建dubbo调用实例;
本文涉及:SpringBoot、Dubbo(包括Dubbo-admin)、Zookeeper
一.Dubbo机制和原理
dubbo的官方描述就一句话:dubbo是一款高性能Java RPC框架。它能实现分布式应用的相互调用,服务管理。
组成结构:
完整的dubbo服务由注册中心,服务提供者,服务消费者,监控四部分组成,其中监控部分不是必须的。provider启动时会将服务实例注册到注册中心(dubbo推荐的注册中心是zookeeper,要是自身集成一个注册中心就更完美了),consumer启动时会去注册中心获取可用的服务列表,包括服务的ip、端口、实例名等信息,并缓存在自己本地,调用时直接根据ip等信息调用provider的服务,即使注册中心崩溃了,因为consumer端还有缓存,依然可以正常调用。
用处:
- 远程调用:实现远程透明的方法调用,就像调用本地方法一样,调用细节dubbo帮我们做好了;
- 服务管理:通过注册中心,实现服务端的动态管理;
- 负载均衡和容错:4种负载均衡模式,可以根据自己的项目自由选择,容错机制保证系统稳定;
dubbo协议
dubbo支持8种协议,官方推荐使用dubbo协议。该协议采用单一的长链接和异步通讯,适合小数据量高并发的场景,单一长链接避免了频繁建立TCP链接的性能损耗。而且,dubbo协议底层通信默认使用netty这种性能非常优秀的框架,提高了并发能力。使用单一长链接也有个缺点,大批消息通过一条链接管道处理,因此如果某个请求占用时间过长,势必会影响其它请求的传输速度,因此dubbo协议不适合传送大数据量的服务,比如文件、视频等。
dubbo服务的实现原理
dubbo底层实现是动态代理,由dubbo框架创建远程服务(接口)对象的代理对象,通过代理调用远程方法。用张图来表达,一看便知。
二.构建dubbo调用实例
项目结构:
1.api接口
api单独出来一个工程,定义实体和接口,目的是避免提供者和消费者写重复的写实体类和接口。提供者和消费者maven引入这个包,使用和实现即可。
- User实体类
public class User implements Serializable {
private String name;
private Integer age;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
}
- UserService接口
public interface UserService {
public User getUser();
}
2.服务提供者
- pom文件
依赖的spring-boot-starter-parent、spring-boot-starter-web等插件不赘述,需要源码的同学可以自取,链接在最下方。使用dubbo需要引入dubbo和zookeeper客户端两个依赖:
<!--dubbo 依赖 -->
<dependency>
<groupId>com.alibaba.spring.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.0.0</version>
</dependency>
<!-- zookeeper client依赖 -->
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>
- 实现api包中的UserService:UserServiceImpl
@Services要引用dubbo的,不要引成Spring的,该注解将提供者提供的UserService服务暴露出去,供消费者使用。
@Service
@Component
public class UserServiceImpl implements UserService {
@Override
public User getUser() {
User user=new User();
user.setName("provider的user");
user.setAge(1);
return user;
}
}
- DubboProviderApplication启动类
@EnableDubboConfiguration使用这个注解开启dubbo。
@EnableDubboConfiguration
@SpringBootApplication
public class DubboProviderApplication extends SpringBootServletInitializer {
public static void main(String[] args) {
SpringApplication.run(DubboProviderApplication.class,args);
}
}
- 配置文件:application.properties
# 配置端口
server.port=9090
//在dubbo中注册的名字
spring.dubbo.application.name=dubbo-provider
//注册中心zookeeper的注册地址
spring.dubbo.application.registry=zookeeper://127.0.0.1:2181
3.服务消费者
pom文件,启动类与提供者相同。
- UserController
写一个controller,使用@Reference远程调用提供者的userService服务。
@RestController
public class UserController {
@Reference
private UserService userService;
@RequestMapping("/consumer")
public User getUsers(){
return userService.getUser();
}
}
- 配置文件:application.properties
# 配置端口
server.port=9091
//在dubbo中注册的名字
spring.dubbo.application.name=dubbo-consumer
//注册中心zookeeper的注册地址
spring.dubbo.application.registry=zookeeper://127.0.0.1:2181
4.启动Zookeeper
下载地址:链接:https://pan.baidu.com/s/1j2INKXGLtvWzKx6xjVjwWA,提取码:yb04
把zookeeper下载到本地,解压,利用zoo_sample.cfg拷贝一份zoo.cfg到相同目录作为配置文件,修改下里面的data地址用于保存数据,其它默认即可,bin目录下启动zookeeper,windows点击zkServer.cmd启动,linux目录下./zkServer.sh start,我这里是windows环境。详细使用参考这篇:Zookeeper入门看这篇就够了
zookeeper是有个监控工具的zooINspector,可以视图化的看到写入的节点信息,好用的一米,一并放在上面的下载地址了。
整个项目启动顺序:zookeeper-->服务提供者-->服务消费者
按顺序启动好之后,调用消费者的consumer接口http://127.0.0.1:9091/consumer,发现调用成功。
5.dubbo-admin
下载地址:https://github.com/apache/dubbo-admin,git下载速度还行。
dubbo-admin是duboo的服务监控工具,以单独的服务实例运行,它在dubbo加入apache之后地位被提高了,被单独作为一个分支下载,而且支持restful的调用方式。使用也很简单,下载下来的包里有个dubbo-admin,打开这个项目,用springboot的方式直接运行即可。
注意dubbo-admin的运行端口默认7001,不要跟自己的项目冲突了,另外,dubbo-admin控制台登录时候的用户名、密码是配置文件中的这两句,root用户的密码是root,guest用户的密码是guest:
spring.root.password=root
spring.guest.password=guest
登录成功后查看控制台,可以看到自己注册的服务信息,也可以做一些管理操作。
实例源码地址:https://github.com/superxcp/dubbo-sample
官方文档:http://dubbo.apache.org/zh-cn/