Dubbo zookeeper 初探
2013-11-14 21:39
295 查看
转: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
/content/2966869.html
/article/3877350.html
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在本地给安装好,
安装方法参考:/article/7578550.html
这里的话讲述了两个工程一个工程是提供服务的,一个工程是调用服务的,因为dubbo是跟spring进行无缝连接的,故功能配置在spring的配置文件中,跟spring进行整合开发
1、工程是以maven进行构建的,使用的jar包如下:
![](http://img.blog.csdn.net/20131114212706531?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvd3h3enk3Mzg=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
2、服务提供者的工程
a、dubbo-demo-api 定义接口
c、applicationProvider.xml配置
d、启动服务
3、服务调用者的工程
a、调用类
b、applicationConsumer.xml配置
![](http://img.blog.csdn.net/20131114213852500?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvd3h3enk3Mzg=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)
这样整个调用就完成了,这样的好处是只要远程提供ip地址及端口号,以及对外调用的类,客户端就可以调用,客户端不必知道服务端的地址之类的
而且服务端可以开多个zookeeper服务,这样如果其中一个zookeeper 服务死掉了,其他服务还能正常运行
工程下载路径:http://download.csdn.net/detail/wxwzy738/6553431
建议参考资料:
http://blog.csdn.net/lin_fs/article/details/7395307
http://blog.csdn.net/goliathray/article/details/8565801
/content/2966869.html
/article/3877350.html
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在本地给安装好,
安装方法参考:/article/7578550.html
这里的话讲述了两个工程一个工程是提供服务的,一个工程是调用服务的,因为dubbo是跟spring进行无缝连接的,故功能配置在spring的配置文件中,跟spring进行整合开发
1、工程是以maven进行构建的,使用的jar包如下:
2、服务提供者的工程
a、dubbo-demo-api 定义接口
public interface IProcessData { public String deal(String data); }b、dubbo-demo-provider 服务提供者
public class ProcessDataImpl implements IProcessData { /* * @see com.xxx.bubbo.provider.IProcessData#deal(java.lang.String) */ @Override public String deal(String data) { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } return "Finished:" + data; } }
c、applicationProvider.xml配置
<?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 "> <!-- Application name --> <dubbo:application name="hello-world-app" /> <!-- registry address, used for service to register itself --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <!-- expose this service through dubbo protocol, through port 20880 --> <!-- <dubbo:protocol name="dubbo" port="20880" /> <dubbo:protocol name="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" /> --> <!-- Service interface Concurrent Control --> <dubbo:service interface="com.huangjie.dubbo_Service.service.IProcessData" ref="demoService" executes="10" /> <!-- Default Protocol --> <!-- <dubbo:protocol server="netty" /> --> <!-- designate implementation --> <bean id="demoService" class="com.huangjie.dubbo_Service.service.impl.ProcessDataImpl" /> </beans>
d、启动服务
public class DubboProviderMain { public static void main(String[] args) throws Exception { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[]{"applicationProvider.xml"}); context.start(); System.out.println("Press any key to exit."); System.in.read(); } }
3、服务调用者的工程
a、调用类
public class ConsumerThd implements Runnable { /* * @see java.lang.Runnable#run() */ @Override public void run() { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[]{"applicationConsumer.xml"}); context.start(); IProcessData demoService = (IProcessData) context.getBean("demoService"); // get // service // invocation // proxy String hello = demoService.deal("nihao"); // do invoke! System.out.println(Thread.currentThread().getName() + " "+hello); } public static void main(String[] args) { new Thread(new ConsumerThd()).start(); /** * 输出结果: * Thread-0 Finished:nihao */ } }
b、applicationConsumer.xml配置
<?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 "> <!-- consumer application name --> <dubbo:application name="consumer-of-helloworld-app" /> <!-- registry address, used for consumer to discover services --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <dubbo:consumer timeout="5000"/> <!-- which service to consume? --> <dubbo:reference id="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
相关文章推荐
- Dubbo zookeeper 初探【转】
- Maven Dubbo zookeeper 初探
- Dubbo zookeeper 初探
- Dubbo zookeeper 初探
- dubbo zookeeper初探
- Dubbo zookeeper 初探【转】
- Dubbo框架结合Zookeeper注册中心使用初探
- Dubbo zookeeper 初探
- Dubbo zookeeper 初探
- Dubbo zookeeper 初探【转】
- dubbo初探二之简单搭建zookeeper注册中心
- Dubbo + Zookeeper入门初探
- Dubbo zookeeper 初探(1)
- Dubbo zookeeper 初探(2)
- Dubbo zookeeper 初探【转】
- [置顶] 分布式系统初探-zookeeper&dubbo环境搭建
- Dubbo zookeeper 初探
- Dubbo zookeeper 初探【转】
- [置顶] 分布式系统初探-ssm整合zookeeper & dubbo
- Dubbo zookeeper 初探