spring整合dubbo&zookeeper

zookeeper安装（单机）

下载地址 https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/，我这边使用的是v3.4.13

配置文件

下载解压后，复制一份conf/zoo_sample.cfg，重命名为zoo.cfg,设置dataDir就可以了。

#日志存储目录
dataDir=/Users/xuyongjun/Downloads/zookeeper-3.4.13/data
#心跳包时间
tickTime=2000
#监听客户端连接端口
clientPort=2181

启动zookeeper

下面命令适用于unix和linux系统，windows系统应该使用.cmd文件。

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

zookeeper配置完后，我们接着创建dubbo项目，我使用的是gradle来构建的，如果你创建完项目后src下面没有java目录，你可以build.gradle中添加下面的task执行。

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

./gradlew createDirs

添加依赖库

repositories {
//    mavenCentral()
    //国内镜像，下载要快点
    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'
}

服务提供者

定义服务接口

package com.example.provider;

public interface DemoService {

    String sayHello(String name);
}

实现接口

package com.example.provider;

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

使用spring配置声明服务

之前按照官网的xml配置，运行后一直报错；最后发现是命名空间的问题，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">


    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="hello-world-app"/>

    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/>

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.example.provider.DemoService" ref="demoService"/>

    <!-- 和本地bean一样实现服务 -->
    <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(); // 按任意键退出
    }
}

服务消费者

spring配置引用远程服务

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">

    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
    <dubbo:application name="consumer-of-helloworld-app"  />

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

    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="demoService" interface="com.example.provider.DemoService" />

</beans>

加载spring配置，调用远程服务

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"); // 获取远程服务代理
        String hello = demoService.sayHello("world"); // 执行远程方法
        System.out.println( hello ); // 显示调用结果
        
    }
}

代码已经上传到github上了，有问题可以拉下来参考；希望可以帮助到你。