16 Dubbo + ZooKeeper

16.1 Dubbo下载

GigHub下载地址：https://github.com/apache/dubbo-admin/tree/master-0.2.0

下载解压，点击进入dubbo-admin文件夹，在该路径下给项目打包

mvn package -Dmaven.skip.test=true  //-Dmaven.skip.test表示不打包测试包

打包成功后，在项目的target目录下有打包成功的文件:dubbo-admin-0.0.1-SNAPSHOT.jar

16.2 ZooKeeper下载安装

ZooKeeper下载地址：https://archive.apache.org/dist/zookeeper/

下载解压，点击进入得到如下文件夹

在conf目录下添加zoo.cfg文件

直接复制一份zoo_sample.cfg，把文件名改为“zoo.cfg”即可

服务端与客户端

16.3 Dubbo+ZooKeeper测试

管理员身份启动ZooKeeper服务端

运行Dubbo，运行打包好的dubbo-admin-0.0.1-SNAPSHOT.jar文件

在dubbo-admin-0.0.1-SNAPSHOT.jar路径下，直接使用命令运行

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

在浏览器中打开：http://localhost:7001/

用户名：root
密码：root

16.4 服务注册发现实战

1、创建项目

创建一个Maven的Module名为dubbo+zookeeper，删掉多余的文件，在该Module下创建两个SpringBoot项目，分别为 provider-service , sonsumer-service

2、编写provider-service项目

导入相关依赖

    
    
    
        org.apache.dubbo
        dubbo-spring-boot-starter
        2.7.3
    
    
    
        com.github.sgroschupf
        zkclient
        0.1
    
    
    
    
        org.apache.curator
        curator-framework
        5.2.0
    
    
    
        org.apache.curator
        curator-recipes
        5.2.0
    
    
    
        org.apache.zookeeper
        zookeeper
        3.7.0
        
        
            
                org.slf4j
                slf4j-log4j12
            
        
    
    
        org.springframework.boot
        spring-boot-starter-web
    
    
        org.springframework.boot
        spring-boot-starter-test
        test
    

编写配置文件 application.properties

server.port=8001
# 服务应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#哪些服务要被注册
dubbo.scan.base-packages=com.dzj.service

编写业务接口以及实现类

文件路径：com--dzj-service--TicketService.java

package com.dzj.service;

public interface TicketService {
    public String getTicket();
}

文件路径：com--dzj--service--TicketServiceImpl.java

package com.dzj.service;

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

//服务注册与发现
//@DubboService  //可以被扫描到，在项目启动就自动注册到注册中心
@Service
@Component
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "常回家看看";
    }
}

打开我们的Zookeeper服务，启动运行provider-server项目，登录Dubbo

可以看到我们的项目已经注册到Dubbo注册中心

接下来我们就看看如何在consumer-server项目中如何去使用我们注册到注册中心上的方法

3、编写consumer-server

导入相关依赖

    
    
    
        org.apache.dubbo
        dubbo-spring-boot-starter
        2.7.3
    
    
    
        com.github.sgroschupf
        zkclient
        0.1
    
    
    
    
        org.apache.curator
        curator-framework
        5.2.0
    
    
    
        org.apache.curator
        curator-recipes
        5.2.0
    
    
    
        org.apache.zookeeper
        zookeeper
        3.7.0
        
        
            
                org.slf4j
                slf4j-log4j12
            
        
    
    
        org.springframework.boot
        spring-boot-starter-web
    

    
        org.springframework.boot
        spring-boot-starter-test
        test
    

编写配置文件application.properties

server.port=8002
#消费者去哪里拿服务，需要暴露自己的名字
dubbo.application.name=consumer-server
#注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

编写接口以及实现类

文件路径：com--dzj--service--TicketService.java

package com.dzj.service;

public interface TicketService {
    public String getTicket();
}

文件路径：com--dzj-service--UserService.java

package com.dzj.service;

import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service  //这里是放到容器中
public class UserService {

    //想拿到provider-server提供的票,要去我们的注册中心拿到我们的服务
    @Reference //引用，Pom坐标,可以定义路径相同的接口名
    TicketService ticketService;

    public void buyTicket(){
        String ticket = ticketService.getTicket();
        System.out.println("在注册中心拿到--->"+ticket);
    }
}

在SpringBoot的测试类中调用测试

package com.dzj;

import com.dzj.service.UserService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ConsumerServerApplicationTests {

    @Autowired
    UserService userService;

    @Test
    void contextLoads() {
        userService.buyTicket();
    }

}

打开我们的Zookeeper服务，启动运行provider-server项目，启动运行测试类

查看结果，调用成功