使用dubbo+zookeeper+spring boot构建服务的方法详解

使用dubbo+zookeeper+spring boot构建服务的方法详解

前言

互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，Dubbo是一个分布式服务框架，在这种情况下诞生的。现在核心业务抽取出来，作为独立的服务，使前端应用能更快速和稳定的响应。

Dubbo是什么

Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。关于注册中心、协议支持、服务监控等内容

Dubbo能做什么

当网站变大后，不可避免的需要拆分应用进行服务化（微服务），以提高开发效率，调优性能，节省关键竞争资源等。

当服务越来越多时，服务的URL地址信息就会爆炸式增长，配置管理变得非常困难，F5硬件负载均衡器的单点压力也越来越大。

当进一步发展，服务间依赖关系变得错踪复杂，甚至分不清哪个应用要在哪个应用之前启动，架构师都不能完整的描述应用的架构关系。

接着，服务的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？等等……

在遇到这些问题时，都可以用Dubbo来解决。

本次和大家分享的是dubbo框架应用的初略配置和zookeeper注册中心的使用；说到注册中心现在我使用过的只有两种：zookeeper和Eureka，zk我结合dubbo来使用，而Eureka结合springcloud使用，因此后面将和大家分享一些关于微服务的一些篇章，希望对你有好的帮助。

安装注册中心zookeeper

dubbo框架之provider和consumer

dubbo-admin部署

安装注册中心zookeeper

首先，我们需要在网上搜索下zookeeper下载地址，我这里是linux系统，所以下载了zookeeper-3.3.6.tar.gz包，通过 tar -zxvf zookeeper-3.3.6.tar.gz 解压出来，需要注意的是一般的包里面配置文件都是默认的sample版本，zookeeper默认配置文件名只zoo.cfg，为了不每次指定文件名来运行，因此需要我们自己在conf目录下创建一个名称为zoo.cfg的配置文件，文件内容可以从zoo_sample.cfg拷贝或者把这个文件重命名都行，内容如下 vim zoo.cfg ：

# The number of milliseconds of each tick

tickTime=2000 #心跳频率

# The number of ticks that the initial

# synchronization phase can take

initLimit=10 #限制连接

# The number of ticks that can pass between

# sending a request and getting an acknowledgement

syncLimit=5

# the directory where the snapshot is stored.

dataDir=/tmp/zookeeper #数据存储文件夹

# the port at which the clients will connect

clientPort=2081 #zookeeper对外的端口

这里就不修改参数信息了，采用默认；简单介绍下linux下怎么编辑文件内容的常用的几个命令：

vim zoo.cfg：查看文件内容

insert：执行插入命令

esc：取消命令，再接着按:q：退出，:wq：保存并退出

当有了zoo.cfg后，我们只需要进入她的bin目录里面查找zkServer.sh文件，通过执行： ./zkServer.sh start 命令启动zookeeper注册中心，正常启动提示如：

通常情况是zookeeper作为注册中心在单独的一台服务器上，而程序（这里指我本地）需要调用另外注册中心需要检查zookeeper开放的端口是否能通，我本地是window10因此可以不需要通过zookeeper客户端去验证端口，只需要通过 telnet ip 2081 就能检测出是否端口开放；

dubbo框架之provider和consumer

首先为了方便，我们需要定义一个统一的接口，该接口就是业务抽出来的公用接口，我们单独对这种接口包装成一个module，我这里是dubbo_api，我们在这个module中定义如下的接口：

public interface UserService {

List getUsers();

}

然后，创建一个provider模块，这个模块去依赖dubbo_api模块，并且实现UserService接口，代码如：

public class UserServiceImpl implements UserService {

@Value("${server.port}")

private int port;

/**

* @return

*/

@Override

public List getUsers() {

List list = new ArrayList<>();

for (int i = 0; i < 5; i++) {

MoUser user = new MoUser();

user.setUserName("shenniu" + i);

user.setUserPwd("端口：" + port);

list.add(user);

}

return list;

}

}

作为服务提供者，要使用dubbo框架就需要先引入dubbo，然后再做一些配置，首先我们需要在dubbo_provider模块通过maven引入dubbo依赖，注册中心用的zookeeper所以也需要通过maven引入相应的依赖：

org.apache.zookeeper

zookeeper

3.4.8

com.101tec

zkclient

0.3

com.alibaba

dubbo

2.5.3

org.springframework

spring

com.example

dubbo_api

0.0.1-SNAPSHOT

完成依赖后，剩下的就是对dubbo的provider的配置了，创建resources/dubbo-conf/server.xml的配置文件，文件内容：

xmlns:xsi="http://w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

在DubboProviderApplication入口增加资源导入 @ImportResource("classpath:dubbo-conf/*.xml") ，到这里我们的服务提供端就完成了，查看下启动日志：

服务提供者启动暂无异常，再来看调用方创建一个dubbo_consumer的moduel，同样去引入dubbo_api公共接口的模块依赖，然后创建一个UserController，并暴露一个get的user接口：

@RestCXVunPeontroller

public class UserController {

@Autowired

private UserService userService;

@GetMapping("/users")

public List getUsers(){

return userService.getUsers();

}

}

这里的UserService是公共接口的注入；编码完成后剩下的就是consumer端引入dubbo和zookeeper依赖了：

org.apache.zookeeper

zookeeper

3.4.8

com.101tec

zkclient

0.3

com.alibaba

dubbo

2.5.3

org.springframework

spring

我们同样创建名称resources/dubbo-conf/client.xml的配置文件，并在application入口引入这个资源：

@ImportResource("classpath:dubbo-conf/*.xml")

@SpringBootApplication

public class DubboConsumerApplication {

public static void main(String[] args) {

SpringApplication.run(DubboConsumerApplication.class, args);

}

}

client.xml的配置内容如：

xmlns:xsi="http://w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

这个时候一个简单的服务提供者，服务调用者配置和编码都完成了，3个module如下：

然后分别启动provider，consumer；再通过consumer暴露的controller接口请求接口，我这里的地址是 http://localhost:8082/users ：

效果是Consumer通过注入的UserService接口依赖调用getUsers()拿到了Provider返回的结果，也表示此次dubbo框架的简单使用算成功了。

dubbo-admin部署

作为一个流行的rpc框架dubbo有这一个开源的监控工具dubbo-admin,不得不说现在网上现成的dubbo-admin.war包要么现在下来不能用要么就是下载需要csdn积分，版本多种多样有点坑啊，果断去git拉源码自己打包，git地址： https://github.com/apache/incubator-dubbo-ops ，拉下来后我们只需要关注dubbo-admin工程，其他的暂可忽略；打开项目后，我们需要改的地方只有如下截图配置（也可以对打包后的配置文件修改）：

#zookeeper配置地址和端口

dubbo.registry.address=zookeeper://127.0.0.1:2081

#后台登录密码

dubbo.admin.root.password=root

dubbo.admin.guest.password=guest

执行打包后，能得到名称：dubbo-admin-2.0.0.war包，然后放在tomcat中，再通过浏览器浏览，账号和密码：都是root；登录后能看到我们之前的启动的provider和consumer在里面，这就是dubbo-admin监控注册中心服务的界面，能够直接对这些服务做点击操作，其他的不多说自行尝试吧。

git地址： https://github.com/shenniubuxing3    nuget发布包：https://nuget.org/profiles/shenniubuxing3

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对我们的支持。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。