zookeeper安裝（單機(jī)）

下載地址 https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/病游，我這邊使用的是v3.4.13

配置文件

下載解壓后礁遵，復(fù)制一份conf/zoo_sample.cfg政勃，重命名為zoo.cfg,設(shè)置dataDir就可以了。

#日志存儲目錄
dataDir=/Users/xuyongjun/Downloads/zookeeper-3.4.13/data
#心跳包時間
tickTime=2000
#監(jiān)聽客戶端連接端口
clientPort=2181

啟動zookeeper

下面命令適用于unix和linux系統(tǒng)，windows系統(tǒng)應(yīng)該使用.cmd文件。

/bin/zkServer.sh start
/bin/zkCli.sh -server

zookeeper配置完后诅迷，我們接著創(chuàng)建dubbo項目贡歧，我使用的是gradle來構(gòu)建的猎莲，如果你創(chuàng)建完項目后src下面沒有java目錄蜘欲，你可以build.gradle中添加下面的task執(zhí)行益眉。

task createdirs() {
    sourceSets*.java.srcDirs*.each { it.mkdirs() }
    sourceSets*.resources.srcDirs*.each { it.mkdirs() }
}

./gradlew createDirs

添加依賴庫

repositories {
//    mavenCentral()
    //國內(nèi)鏡像，下載要快點
    maven{ url'http://maven.aliyun.com/nexus/content/groups/public/'}
}

dependencies {
    testCompile group: 'junit', name: 'junit', version: '4.11'
    testCompile group: 'junit', name: 'junit', version: '4.12'
    compile group: 'com.alibaba', name: 'dubbo', version: '2.5.3'
    compile group: 'org.apache.zookeeper', name: 'zookeeper', version: '3.4.6', ext: 'pom'
    compile group: 'io.netty', name: 'netty-all', version: '4.0.35.Final'
    compile group: 'org.apache.curator', name: 'curator-recipes', version: '2.12.0'
// https://mvnrepository.com/artifact/com.101tec/zkclient
    compile group: 'com.101tec', name: 'zkclient', version: '0.2'
}

服務(wù)提供者

定義服務(wù)接口

package com.example.provider;

public interface DemoService {

    String sayHello(String name);
}

實現(xiàn)接口

package com.example.provider;

public class DemoServiceImpl implements DemoService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

使用spring配置聲明服務(wù)

之前按照官網(wǎng)的xml配置姥份，運行后一直報錯郭脂；最后發(fā)現(xiàn)是命名空間的問題，issues地址https://github.com/apache/incubator-dubbo/issues/1739

provider.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://code.alibabatech.com/schema/dubbo
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">


    <!-- 提供方應(yīng)用信息澈歉，用于計算依賴關(guān)系 -->
    <dubbo:application name="hello-world-app"/>

    <!-- 使用zookeeper注冊中心暴露服務(wù)地址 -->
    <dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/>

    <!-- 用dubbo協(xié)議在20880端口暴露服務(wù) -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- 聲明需要暴露的服務(wù)接口 -->
    <dubbo:service interface="com.example.provider.DemoService" ref="demoService"/>

    <!-- 和本地bean一樣實現(xiàn)服務(wù) -->
    <bean id="demoService" class="com.example.provider.DemoServiceImpl"/>
</beans>

加載spring配置

package com.example.provider;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

public class Provider {

    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:provider.xml");
        context.start();
        System.in.read(); // 按任意鍵退出
    }
}

服務(wù)消費者

spring配置引用遠(yuǎn)程服務(wù)

consumer.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://code.alibabatech.com/schema/dubbo
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 消費方應(yīng)用名展鸡，用于計算依賴關(guān)系，不是匹配條件埃难，不要與提供方一樣 -->
    <dubbo:application name="consumer-of-helloworld-app"  />

    <dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/>

    <!-- 生成遠(yuǎn)程服務(wù)代理莹弊，可以和本地bean一樣使用demoService -->
    <dubbo:reference id="demoService" interface="com.example.provider.DemoService" />

</beans>

加載spring配置，調(diào)用遠(yuǎn)程服務(wù)

package com.example.provider;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Consumer {

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:consumer.xml");
        context.start();
        DemoService demoService = (DemoService)context.getBean("demoService"); // 獲取遠(yuǎn)程服務(wù)代理
        String hello = demoService.sayHello("world"); // 執(zhí)行遠(yuǎn)程方法
        System.out.println( hello ); // 顯示調(diào)用結(jié)果
        
    }
}

代碼已經(jīng)上傳到github上了涡尘，有問題可以拉下來參考忍弛；希望可以幫助到你。