zookeeper的安装与使用

一、下载zookeeper

•     Zookeeper是Apacahe Hadoop的子项目，可以为分布式应用程序协调服务，适合作为Dubbo服务的注册中心，负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互。
• 

   使用百度网盘分享链接

链接：https://pan.baidu.com/s/1hddTGBzEQGMFQYh28PUAsw?pwd=md5u 

提取码：md5u

解压后，进入bin目录 点击zkServer.cmd

然后可以看到自己的端口2181即可。

 二、dubbox框架介绍

    Dubbo(读音[ˈdʌbəʊ])是阿里巴巴公司开源的一个基于Java的高性能RPC（Remote Procedure Call）框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和 Spring框架无缝集成。后期阿里巴巴停止了该项目的维护，于是当当网在这之上推出了自己的Dubbox。

节点角色说明：

• Provider: 暴露服务的服务提供方。
• Container: 服务运行容器。
• Registry: 服务注册与发现的注册中心。
• Consumer: 调用远程服务的服务消费方。
• Monitor: 统计服务的调用次调和调用时间的监控中心。
• 调用关系说明：
• 0. 服务容器负责启动，加载，运行服务提供者。
• 1. 服务提供者在启动时，向注册中心注册自己提供的服务。
• 2. 服务消费者在启动时，向注册中心订阅自己所需的服务。
• 3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
• 4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
• 5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

 三、dubbox入门案例

3.1 创建父工程 ，引入依赖控制版本

    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.3.2.RELEASE
    
    
    com.by
    dubbox_parent
    1.0-SNAPSHOT

    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
        
            com.alibaba.boot
            dubbo-spring-boot-starter
            0.1.0
        
        
        
            com.101tec
            zkclient
            0.10
        
    

3.2 定义公共接口 

   里面只简单写一个service接口

• HeflloService接口

package com.by.service;


public interface HeflloService {
    String hello();
}

 3.3 创建服务提供方模块

①pom.xml

    4.0.0
    
        com.by
        dubbox_parent
        1.0-SNAPSHOT
    

    dubbox_provider

    
        8
        8
        UTF-8
    
  
      
          com.by
          dubbox_interface
          1.0-SNAPSHOT
      
  

②创建service的实现类HelloServiceImpl.Java

package com.by.service;

import com.alibaba.dubbo.config.annotation.Service;
//import org.springframework.stereotype.Service;
@Service
public class HelloServiceImpl implements HeflloService{
    @Override
    public String hello() {
        return "hello,Dubbox.......";
    }
}

③application.properties

server.port=8080
#zookeeper??
dubbo.registry.address=zookeeper://127.0.0.1:2181
#???????,??????????????????
dubbo.application.name=dubbo-consumer
#??, Dubbo??????Dubbo?RMI?http?WebService
dubbo.protocol.name=dubbo

④创建启动类

package com.by;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class DubboxConsumerApp {
    public static void main(String[] args) {
        SpringApplication.run(DubboxConsumerApp.class,args);
    }
}

3.4 定义服务消费方

①pom.xml

    4.0.0
    
        com.by
        dubbox_parent
        1.0-SNAPSHOT
    

    dubbox_consumer

    
        8
        8
        UTF-8
    
    
        
            com.by
            dubbox_interface
            1.0-SNAPSHOT
        
    

 ②定义定义controller

package com.by.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.by.service.HeflloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller

public class HelloController {
    @Reference
  private    HeflloService heflloService;
    @RequestMapping("/hello")
    @ResponseBody // 想给浏览器返回一个json
    public String hello(){
       return heflloService.hello();
    }

}

③ application.properties

server.port=8081
#zookeeper??
dubbo.registry.address=zookeeper://127.0.0.1:2181
#???????,??????????????????
dubbo.application.name=dubbo-consumer
#??, Dubbo??????Dubbo?RMI?http?WebService
dubbo.protocol.name=dubbo

④定义启动类DubboxConsumerApp.java

package com.by;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class DubboxConsumerApp {
    public static void main(String[] args) {
        SpringApplication.run(DubboxConsumerApp.class,args);
    }
}

四、测试

首先打开zookeeper，然后先启动服务提供方，接着启动服务消费方（注意顺序） 

然后在浏览器中搜索服务消费方的网址即可。