Dubbo与Zookeeper、Spring整合使用

转自:http://blog.csdn.net/hejingyuan6/article/details/47403299

Dubbo与Zookeeper、Spring整合使用

 
Dubbo采用全spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。
 

一：单机模式安装zookeeper

 
1,下载zookeeper注册中心，下载地址：http://www.apache.org/dyn/closer.cgi/zookeeper/ 下载后解压即可，进入E:\zookeeper-3.3.6\zookeeper-3.3.6\bin，
双击zkServer.cmd启动注册中心服务。
zkServer.sh【Linux】或zkServer.cmd【Windows】
 
2,在你执行启动脚本之前，还有几个基本的配置项需要配置一下，Zookeeper的配置文件在 conf 目录下，这个目录下有 zoo_sample.cfg 和 log4j.properties，你需要做的就是将zoo_sample.cfg 改名为 zoo.cfg，因为 Zookeeper在启动时会找这个文件作为默认配置文件。下面详细介绍一下，这个配置文件中各个配置项的意义。

 


   •tickTime：这个时间是作为Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。
   •dataDir：顾名思义就是 Zookeeper保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。
   •dataLogDir：顾名思义就是Zookeeper 保存日志文件的目录
   •clientPort：这个端口就是客户端连接Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求
 
配置好后，zookeeper会监听本机的2181端口。
当这些配置项配置好后，你现在就可以启动 Zookeeper 了，启动后要检查 Zookeeper 是否已经在服务，可以通过 netstat – ano 命令查看是否有你配置的 clientPort 端口号在监听服务。
 

二：服务提供者

 
定义服务接口:(该接口需单独打包，在服务提供方和消费方共享)

[java]
view plain
copy
print?

package com.unj.dubbotest.provider;  
  
import java.util.List;  
  
public interface DemoService {  
  
    String sayHello(String name);  
  
    public List getUsers();  
  
}  

在服务提供方实现接口：(对服务消费方隐藏实现)

[java]
view plain
copy
print?

package com.unj.dubbotest.provider.impl;  
  
import java.util.ArrayList;  
import java.util.List;  
  
import com.unj.dubbotest.provider.DemoService;  
  
public class DemoServiceImpl implements DemoService {  
  
    public String sayHello(String name) {  
        return "Hello " + name;  
    }  
  
    public List getUsers() {  
        List list = new ArrayList();  
        User u1 = new User();  
        u1.setName("hejingyuan");  
        u1.setAge(20);  
        u1.setSex("f");  
  
        User u2 = new User();  
        u2.setName("xvshu");  
        u2.setAge(21);  
        u2.setSex("m");  
  
          
        list.add(u1);  
        list.add(u2);  
          
        return list;  
    }  
}  

用Spring配置声明暴露服务：

[html]
view plain
copy
print?

<?xml version="1.0" encoding="UTF-8"?>  
<beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans  
        http://www.springframework.org/schema/beans/spring-beans.xsd  
        http://code.alibabatech.com/schema/dubbo  
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
        ">  
  
    <!-- 具体的实现bean -->  
    <bean id="demoService" class="com.unj.dubbotest.provider.impl.DemoServiceImpl" />  
  
    <!-- 提供方应用信息，用于计算依赖关系 -->  
    <dubbo:application name="xs_provider" />  
  
    <!-- 使用multicast广播注册中心暴露服务地址 -->  
    <!--<dubbo:registry address="multicast://224.5.6.7:1234" /> -->  
      
    <!-- 使用zookeeper注册中心暴露服务地址 --即zookeeper的所在服务器ip地址和端口号 -->  
    <dubbo:registry address="zookeeper://192.168.24.213:2181" />  
  
    <!-- 用dubbo协议在20880端口暴露服务 -->  
    <dubbo:protocol name="dubbo" port="20880" />  
  
    <!-- 声明需要暴露的服务接口 -->  
    <dubbo:service interface="com.unj.dubbotest.provider.DemoService"  
        ref="demoService" />  
  
</beans>  

加载Spring配置，启动服务（或者将项目建为web项目，然后在web.xml中配置好spring的启动，然后扔到tomcat中即可提供服务）：

[java]
view plain
copy
print?

package com.unj.dubbotest.provider.impl;  
  
import org.springframework.context.support.ClassPathXmlApplicationContext;  
  
public class Provider {  
  
    public static void main(String[] args) throws Exception {  
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(  
                new String[] { "applicationContext.xml" });  
        context.start();  
        System.in.read(); // 为保证服务一直开着，利用输入流的阻塞来模拟  
    }  
}  

三：服务消费者

 
通过Spring配置引用远程服务：

[html]
view plain
copy
print?

<?xml version="1.0" encoding="UTF-8"?>  
<beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans  
        http://www.springframework.org/schema/beans/spring-beans.xsd  
        http://code.alibabatech.com/schema/dubbo  
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
        ">  
  
    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->  
    <dubbo:application name="hjy_consumer" />  
  
    <!-- 使用zookeeper注册中心暴露服务地址 -->  
    <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->  
    <dubbo:registry address="zookeeper://192.168.24.213:2181" />  
  
    <!-- 生成远程服务代理，可以像使用本地bean一样使用demoService -->  
    <dubbo:reference id="demoService"  
        interface="com.unj.dubbotest.provider.DemoService" />  
  
</beans>  

调用服务测试：

[java]
view plain
copy
print?

package com.alibaba.dubbo.demo.pp;  
  
import java.util.List;  
  
import org.springframework.context.support.ClassPathXmlApplicationContext;  
  
import com.unj.dubbotest.provider.DemoService;  
  
public class Consumer {  
  
    public static void main(String[] args) throws Exception {  
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(  
                new String[] { "applicationContext.xml" });  
        context.start();  
  
        DemoService demoService = (DemoService) context.getBean("demoService");  
        String hello = demoService.sayHello("hejingyuan");  
        System.out.println(hello);  
  
        List list = demoService.getUsers();  
        if (list != null && list.size() > 0) {  
            for (int i = 0; i < list.size(); i++) {  
                System.out.println(list.get(i));  
            }  
        }  
        System.in.read();  
    }  
  
}  

测试结果：

附：Dubbo的管理页面

 
需要下载：dubbo-admin-2.5.3的war包
下载地址：http://download.csdn.net/detail/u013286716/7041185
 
操作如下：

1，替换掉tomcat/webapps下自带的ROOT文件夹内容（即替换tomcat的启动主页），将下载的war包解压到webapps/ROOT中，直接替换即可
 
   注意：jdk不要使用1.8，本次实验使用的为1.6
 
2，启动tomcat，访问ip:8080即可或者如果是本地的话使用localhost:8080
输入用户名密码，在E:\apache-tomcat-7.0.6-dubbo\webapps\ROOT\WEB-INF下的dubbo.properties文件中即可查看到，如：



3，访问http://192.168.24.213:38080/



4，启动我们的服务提供者和消费者即可查看到





 

整体说明：

    
    Zookeeper（注册中心）部署到213的机子上，服务提供者和服务消费者均在215的机子上运行，当然我们也可以分别将服务提供者和服务消费者部署到不同的两台机子上。

优点：
    服务提供者和服务消费者只需要知道注册中心即可，它们之间打交道需通过注册中心这个第三方，只要是注册中心中已经注册的服务，我们均可以使用，实现了服务提供者和服务消费者间的解耦。

另外转载:

dubbo 2.5.4-SNAPSHOT dubbo-admin 报错

问题描述：

RROR context.ContextLoader - Context initialization failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'uriBrokerService': Cannot create inner bean '(inner bean)' of type [com.alibaba.citrus.service.uribroker.impl.URIBrokerServiceImpl$URIBrokerInfo] while setting bean property 'brokers' with key [0]; nested excepti
on is org.springframework.beans.factory.BeanCreationException: Error creating bean with name '(inner bean)#25': Cannot create inner bean 'server' of type [com.alibaba.citrus.service.uribroker.uri.GenericURIBroker] while setting constructor argument; nested exception is org.springframework.beans.fact
ory.BeanCreationException: Error creating bean with name 'server': Error setting property values; nested exception is org.springframework.beans.NotWritablePropertyException: Invalid property 'URIType' of bean class [com.alibaba.citrus.service.uribroker.uri.GenericURIBroker]: Bean property 'URIType'
is not writable or has an invalid setter method. Does the parameter type of the setter match the return type of the getter?
at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveInnerBean(BeanDefinitionValueResolver.java:230)
at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveValueIfNecessary(BeanDefinitionValueResolver.java:122)
at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveManagedList(BeanDefinitionValueResolver.java:287)

我使用的是JDK 1.8.0_05, dubbo-admin版本是2.5.4-SNAPSHOT，也遇到了一样的问题。解决方案如：

[/code]

1、webx的依赖改为3.1.6版；

<dependency>
<groupId>com.alibaba.citrus</groupId>
<artifactId>citrus-webx-all</artifactId>
<version>3.1.6</version>
</dependency>

 

2、添加velocity的依赖，我用了1.7；

<dependency>
<groupId>org.apache.velocity</groupId>
<artifactId>velocity</artifactId>
<version>1.7</version>
</dependency>

 

3、对依赖项dubbo添加exclusion，避免引入旧spring

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>${project.parent.version}</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
</exclusions>
</dependency>

 

4、webx已有spring 3以上的依赖，因此注释掉dubbo-admin里面的spring依赖

<!--<dependency>-->
<!--<groupId>org.springframework</groupId>-->
<!--<artifactId>spring</artifactId>-->
<!--</dependency>-->

 

确定war包解压后lib目录没有spring 3 以下的依赖就行。然后运行正常了。