Dubbo zookeeper 初探

转：http://blog.csdn.net/u011270461/article/details/12144623

建议参考资料：

http://blog.csdn.net/lin_fs/article/details/7395307

http://blog.csdn.net/goliathray/article/details/8565801

http://zy116494718.iteye.com/blog/1830138

http://agapple.iteye.com/blog/1292473

http://www.open-open.com/news/view/1442a5c

http://code.alibabatech.com/wiki/display/dubbo/Home

http://code.alibabatech.com/wiki/display/dubbo/User+Guide-zh

先把zookeeper在本地给安装好，

安装方法参考：http://blog.csdn.net/wxwzy738/article/details/16330253

这里的话讲述了两个工程一个工程是提供服务的，一个工程是调用服务的，因为dubbo是跟spring进行无缝连接的，故功能配置在spring的配置文件中，跟spring进行整合开发

1、工程是以maven进行构建的，使用的jar包如下：

2、服务提供者的工程

a、dubbo-demo-api 定义接口

publicinterfaceIProcessData{
publicStringdeal(Stringdata);
}

b、dubbo-demo-provider服务提供者

publicclassProcessDataImplimplementsIProcessData{

/*
*@seecom.xxx.bubbo.provider.IProcessData#deal(java.lang.String)
*/
@Override
publicStringdeal(Stringdata){
try{
Thread.sleep(1000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
return"Finished:"+data;
}
}

c、applicationProvider.xml配置

<?xmlversion="1.0"encoding="UTF-8"?>
<beansxmlns="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
">

<!--Applicationname-->
<dubbo:applicationname="hello-world-app"/>

<!--registryaddress,usedforservicetoregisteritself-->
<dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>

<!--exposethisservicethroughdubboprotocol,throughport20880-->
<!--
<dubbo:protocolname="dubbo"port="20880"/>

<dubbo:protocolname="dubbo"port="9090"server="netty"
client="netty"codec="dubbo"serialization="hessian2"charset="UTF-8"
threadpool="fixed"threads="100"queues="0"iothreads="9"buffer="8192"
accepts="1000"payload="8388608"/>
-->
<!--ServiceinterfaceConcurrentControl-->
<dubbo:serviceinterface="com.huangjie.dubbo_Service.service.IProcessData"
ref="demoService"executes="10"/>

<!--DefaultProtocol-->
<!--
<dubbo:protocolserver="netty"/>
-->

<!--designateimplementation-->
<beanid="demoService"class="com.huangjie.dubbo_Service.service.impl.ProcessDataImpl"/>

</beans>

d、启动服务

publicclassDubboProviderMain{
publicstaticvoidmain(String[]args)throwsException{
ClassPathXmlApplicationContextcontext=newClassPathXmlApplicationContext(
newString[]{"applicationProvider.xml"});
context.start();

System.out.println("Pressanykeytoexit.");
System.in.read();
}
}

3、服务调用者的工程

a、调用类

publicclassConsumerThdimplementsRunnable{

/*
*@seejava.lang.Runnable#run()
*/
@Override
publicvoidrun(){
ClassPathXmlApplicationContextcontext=newClassPathXmlApplicationContext(
newString[]{"applicationConsumer.xml"});
context.start();

IProcessDatademoService=(IProcessData)context.getBean("demoService");//get
//service
//invocation
//proxy
Stringhello=demoService.deal("nihao");//doinvoke!

System.out.println(Thread.currentThread().getName()+""+hello);
}

publicstaticvoidmain(String[]args){
newThread(newConsumerThd()).start();
/**
*输出结果：
*Thread-0Finished:nihao
*/
}
}

b、applicationConsumer.xml配置

<?xmlversion="1.0"encoding="UTF-8"?>
<beansxmlns="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
">

<!--consumerapplicationname-->
<dubbo:applicationname="consumer-of-helloworld-app"/>

<!--registryaddress,usedforconsumertodiscoverservices-->
<dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
<dubbo:consumertimeout="5000"/>
<!--whichservicetoconsume?-->
<dubbo:referenceid="demoService"interface="com.huangjie.dubbo_Service.service.IProcessData"/>
</beans>

4、最后需要把zookeeper的服务给启动，在zookeeper安装文件夹下面的bin目录里面的zkServer.cmd给点击运行。不要关闭窗口，保持服务运行

这样整个调用就完成了，这样的好处是只要远程提供ip地址及端口号，以及对外调用的类，客户端就可以调用，客户端不必知道服务端的地址之类的

而且服务端可以开多个zookeeper服务，这样如果其中一个zookeeper 服务死掉了，其他服务还能正常运行

工程下载路径：http://download.csdn.net/detail/wxwzy738/6553431