dubbo+zookeeper+springboot构建服务

　　本次和你们分享的是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 ：

 1 # The number of milliseconds of each tick  2 tickTime=2000 #心跳频率
 3 # The number of ticks that the initial  4 # synchronization phase can take  5 initLimit=10 #限制链接
 6 # The number of ticks that can pass between  7 # sending a request and getting an acknowledgement  8 syncLimit=5
 9 # the directory where the snapshot is stored. 10 dataDir=/tmp/zookeeper #数据存储文件夹 11 # the port at which the clients will connect 12 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中定义以下的接口：

1 public interface UserService { 2     
3     List<MoUser> getUsers(); 4 }

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

 1 public class UserServiceImpl implements UserService {  2 
 3     @Value("${server.port}")  4     private int port;  5 
 6     /**  7  * @return  8      */
 9  @Override 10     public List<MoUser> getUsers() { 11 
12         List<MoUser> list = new ArrayList<>(); 13         for (int i = 0; i < 5; i++) { 14             MoUser user = new MoUser(); 15             user.setUserName("shenniu" + i); 16             user.setUserPwd("端口：" + port); 17  list.add(user); 18  } 19         return list; 20  } 21 }

　　做为服务提供者，要使用dubbo框架就须要先引入dubbo，而后再作一些配置，首先咱们须要在dubbo_provider模块经过maven引入dubbo依赖，注册中心用的zookeeper因此也须要经过maven引入相应的依赖：

 1 <dependency>
 2             <groupId>org.apache.zookeeper</groupId>
 3             <artifactId>zookeeper</artifactId>
 4             <version>3.4.8</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>com.101tec</groupId>
 8             <artifactId>zkclient</artifactId>
 9             <version>0.3</version>
10         </dependency>
11         <dependency>
12             <groupId>com.alibaba</groupId>
13             <artifactId>dubbo</artifactId>
14             <version>2.5.3</version>
15             <exclusions>
16                 <exclusion>
17                     <groupId>org.springframework</groupId>
18                     <artifactId>spring</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>
22         <dependency>
23             <groupId>com.example</groupId>
24             <artifactId>dubbo_api</artifactId>
25             <version>0.0.1-SNAPSHOT</version>
26         </dependency>

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

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans
 5             http://www.springframework.org/schema/beans/spring-beans.xsd
 6             http://code.alibabatech.com/schema/dubbo
 7             http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 8 
 9     <!-- 提供者名称 -->
10     <dubbo:application name="demo-provider" />
11 
12     <!-- zookeeper注册中心的服务地址 -->
13     <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
14 
15     <!-- 用dubbo协议在20880端口暴露服务，协议通讯端口 -->
16     <dubbo:protocol name="dubbo" port="20880" />
17 
18     <!-- 用户服务接口 -->
19     <dubbo:service interface="service.UserService" ref="userService" />
20 
21     <!-- 用户服务接口实现 -->
22     <bean id="userService" class="com.example.demo.service.UserServiceImpl"/>
23 </beans>

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

　　

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

 1 @RestController  2 public class UserController {  3  @Autowired  4     private UserService userService;  5 
 6     @GetMapping("/users")  7     public List<MoUser> getUsers(){  8 
 9         return userService.getUsers(); 10  } 11 }

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

 1 <dependency>
 2             <groupId>org.apache.zookeeper</groupId>
 3             <artifactId>zookeeper</artifactId>
 4             <version>3.4.8</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>com.101tec</groupId>
 8             <artifactId>zkclient</artifactId>
 9             <version>0.3</version>
10         </dependency>
11         <dependency>
12             <groupId>com.alibaba</groupId>
13             <artifactId>dubbo</artifactId>
14             <version>2.5.3</version>
15             <exclusions>
16                 <exclusion>
17                     <groupId>org.springframework</groupId>
18                     <artifactId>spring</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>

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

1 @ImportResource("classpath:dubbo-conf/*.xml") 2 @SpringBootApplication 3 public class DubboConsumerApplication { 4     public static void main(String[] args) { 5         SpringApplication.run(DubboConsumerApplication.class, args); 6  } 7 }

　　client.xml的配置内容如：

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans
 5             http://www.springframework.org/schema/beans/spring-beans.xsd
 6             http://code.alibabatech.com/schema/dubbo
 7             http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 8 
 9     <!-- 服务名 -->
10     <dubbo:application name="demo-consumer" />
11 
12     <!-- zookeeper注册中心暴露服务地址 -->
13     <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
14 
15     <!-- 用户服务接口 -->
16     <dubbo:reference id="userService" interface="service.UserService" />
17 
18 </beans>

　　这个时候一个简单的服务提供者，服务调用者配置和编码都完成了，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工程，其余的暂可忽略；打开项目后，咱们须要改的地方只有以下截图配置（也能够对打包后的配置文件修改）：

　　

1 #zookeeper配置地址和端口 2 dubbo.registry.address=zookeeper://127.0.0.1:2081
3 #后台登陆密码 4 dubbo.admin.root.password=root 5 dubbo.admin.guest.password=guest

　　执行打包后，能获得名称：dubbo-admin-2.0.0.war包，而后放在tomcat中，再经过浏览器浏览，帐号和密码：都是root；登陆后能看到咱们以前的启动的provider和consumer在里面，这就是dubbo-admin监控注册中心服务的界面，可以直接对这些服务作点击操做，其余的很少说自行尝试吧。