dubbo 使用 学习二(spring+dubbo+zookeeper单机服务)

学习目录在上一篇中有了,这篇我们来写一个本地的单服务的demo,下面我们看看需要什么!!!

1、zookeeper的安装:

(1)、zookeeper 的安装很简单,下载架包解压缩,解压缩后的目录下有个conf目录也就是zookeeper的配置文件在该目录下,该目录下有一个zoo_sample.cfg 文件,复制一个修改为zoo.cfg,像我们这里是单服务的所以这里的配置只需要修改dataDir的目录就可以了其他的可以不用修改,dataDir的目录可以自己随便定义!!!

2、服务提供者

创建一个maven 工程,配置spring ,dubbo,zookeeper等相关的jar包,下面来具体看看!

(1)、目录结构

(2)、我们配置pom.xml下载我们需要的jar包,pom.xml配置文件如下:

[html]view plaincopyprint?

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

com.test

dubboser

0.0.1

jar

dubboserver

http://maven.apache.org

UTF-8

3.1.4.RELEASE

1.6.6

junit

junit

3.8.1

test


org.springframework

spring-aop

${spring.version}

org.springframework

spring-asm

${spring.version}

org.springframework

spring-core

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-context

${spring.version}

org.springframework

spring-expression

${spring.version}



log4j

log4j

1.2.16

org.slf4j

slf4j-api

${slf4j.version}

org.slf4j

slf4j-log4j12

${slf4j.version}


com.alibaba

dubbo

2.5.3


com.github.sgroschupf

zkclient

0.1


org.apache.zookeeper

zookeeper

3.4.5

dubbo-demo


org.apache.maven.plugins

maven-compiler-plugin

2.1

1.5

1.5

UTF-8

false


xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

com.test

dubboser

0.0.1

jar

dubboserver

http://maven.apache.org

UTF-8

3.1.4.RELEASE

1.6.6

junit

junit

3.8.1

test


org.springframework

spring-aop

${spring.version}

org.springframework

spring-asm

${spring.version}

org.springframework

spring-core

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-context

${spring.version}

org.springframework

spring-expression

${spring.version}



log4j

log4j

1.2.16

org.slf4j

slf4j-api

${slf4j.version}

org.slf4j

slf4j-log4j12

${slf4j.version}


com.alibaba

dubbo

2.5.3


com.github.sgroschupf

zkclient

0.1


org.apache.zookeeper

zookeeper

3.4.5

dubbo-demo


org.apache.maven.plugins

maven-compiler-plugin

2.1

1.5

1.5

UTF-8

false


(3)、写服务接口,服务接口的实现

[java]view plaincopyprint?

packagecom.test.dubboser;

publicinterfaceServiceDemo {

publicString say(String str);

}

package com.test.dubboser;

public interface ServiceDemo {

public String say(String str);

}

[java]view plaincopyprint?

packagecom.test.dubboser;

publicclassServiceImpimplementsServiceDemo{

publicString say(String str) {

System.err.println("server: "+str);

return"hello: "+str;

}

}

package com.test.dubboser;

public class ServiceImp implements ServiceDemo{

public String say(String str) {

System.err.println("server: "+str);

return "hello: "+str;

}

}

(4)、向注册中心注册服务(将接口暴露出去),这里的注册中心是zookeeper

下面我们来看看,服务的配置也就是applicationProvider.xml这个配置文件中配置……

[html]view plaincopyprint?


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

">











ref="demoService"/>



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

">











ref="demoService" />


(5)、所有的准备都好了,下面我们启动服务提供者(提前启动zookeeper)

[java]view plaincopyprint?

packagecom.test.dubboser;

importjava.io.IOException;

importorg.springframework.context.support.ClassPathXmlApplicationContext;

publicclassMain {

publicstaticvoidmain(String[] args)throwsIOException {

ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext(newString[] {"applicationProvider.xml"});

context.start();

System.out.println("按任意键退出");

System.in.read();

}

}

package com.test.dubboser;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main {

public static void main(String[] args) throws IOException {

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "applicationProvider.xml" });

context.start();

System.out.println("按任意键退出");

System.in.read();

}

}

ok这样我们的服务提供者就好了,是不是很乱,我感觉也有点,所以之后会有个自己的小总结……

我们的服务提供者好了,我们来看看我们的服务消费者,也就是调用我们这里的服务的程序……

3、服务消费者开发

服务消费者的编写还是按照服务提供者一样的顺序来

(1)、目录结构

(2)、maven的pom.xml配置文件获取需要的架包

[html]view plaincopyprint?

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

com.test

dubbocli

0.0.1-SNAPSHOT

jar

dubboclient

http://maven.apache.org

UTF-8

3.1.4.RELEASE

1.6.6

junit

junit

3.8.1

test


org.springframework

spring-aop

${spring.version}

org.springframework

spring-asm

${spring.version}

org.springframework

spring-core

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-context

${spring.version}

org.springframework

spring-expression

${spring.version}



log4j

log4j

1.2.16

org.slf4j

slf4j-api

${slf4j.version}

org.slf4j

slf4j-log4j12

${slf4j.version}


com.alibaba

dubbo

2.5.3


com.github.sgroschupf

zkclient

0.1


org.apache.zookeeper

zookeeper

3.4.5

dubbo-demo


org.apache.maven.plugins

maven-compiler-plugin

2.1

1.5

1.5

UTF-8

false


xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

com.test

dubbocli

0.0.1-SNAPSHOT

jar

dubboclient

http://maven.apache.org

UTF-8

3.1.4.RELEASE

1.6.6

junit

junit

3.8.1

test


org.springframework

spring-aop

${spring.version}

org.springframework

spring-asm

${spring.version}

org.springframework

spring-core

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-context

${spring.version}

org.springframework

spring-expression

${spring.version}



log4j

log4j

1.2.16

org.slf4j

slf4j-api

${slf4j.version}

org.slf4j

slf4j-log4j12

${slf4j.version}


com.alibaba

dubbo

2.5.3


com.github.sgroschupf

zkclient

0.1


org.apache.zookeeper

zookeeper

3.4.5

dubbo-demo


org.apache.maven.plugins

maven-compiler-plugin

2.1

1.5

1.5

UTF-8

false


注意:服务提供者 ,服务消费者以及安装的zookeeper保持相同的版本号,这样能省去很多麻烦,而不同版本的错误在前中有记录过可以看看……

(3)、服务消费者的配置applicationConsumer.xml

[html]view plaincopyprint?


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

">









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

">








(4)、消费端,也就是调用服务端的方法

[java]view plaincopyprint?

packagecom.test.dubbocli;

importorg.springframework.context.support.ClassPathXmlApplicationContext;

importcom.test.dubboser.ServiceDemo;

publicclassMain {

publicstaticvoidmain(String[] args)throwsInterruptedException {

inti=0;

while(i++<5){

run();

Thread.sleep(3000);

}

}

publicstaticvoidrun(){

ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext(newString[] {"applicationConsumer.xml"});

context.start();

ServiceDemo demoServer = (ServiceDemo) context.getBean("demoServicemy");

String str=demoServer.say("java ---->>>");

System.err.println("res: "+str);

}

}

package com.test.dubbocli;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.test.dubboser.ServiceDemo;

public class Main {

public static void main(String[] args) throws InterruptedException {

int i=0;

while(i++<5){

run();

Thread.sleep(3000);

}

}

public static void run(){

ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "applicationConsumer.xml" });

context.start();

ServiceDemo demoServer = (ServiceDemo) context.getBean("demoServicemy");

String str=demoServer.say("java ---->>>");

System.err.println("res: "+str);

}

}

注意:这里我们引入了一个类 com.test.dubboser.ServiceDemo 类,这个类是服务端的接口,所以在启动消费端的时候我们要把服务端生成jar包导入到消费端……

我们看到了消费端调用服务端的方法就和调用本地的方法一样方便,ok 例子就到这里……

4、整个开发流程:

(1)、安装zookeeper,修改dataDir

(2)、开发服务端即服务提供者,当然前提示已经有了zookeeper dubbo spring 等jar包,这里使用了maven也就是pom.xml 配置

(3)、将服务端注册到注册中心暴露服务地址配置添加

(4)、使用dubbo协议将指定的服务端口暴露配置添加

(5)、声明需要暴露的服务接口

(6)、实现服务接口

(7)、启动服务端

这样 整个服务提供者就ok了

(1)、服务消费者开发,同样需要zookeeper dubbo spring 等相关的jar包,这里使用的是maven所以配置pom.xml

(2)、使用zookeeper广播注册中心发现暴露的服务地址的配置添加

(3)、生成 远程代理的配置添加

(4)、将服务端生成jar包引入

(5)、调用服务端服务

5、注意点

(1)、三个地方提到了zookeeper 、zookeeper的安装、服务端注册、客户端注册 这三个地方的zookeeper使用同一版本,这样能省去一些不必要的错误!!!

(2)、记得在服务消费者引入服务提供者的jar,也就是要把服务端打成jar包引入到服务消费者!!!

6、使用dubbo、zookeeper到底做了什么

我们在网上能查到dubbo、zookeeper是做什么的,这里不说的那么具体还详细,第一你能看到官网的解释,第二我也刚开始学习不能误人子弟,下面就是我个人的简单理解:

zookeeper 是注册中心,我们写的服务注册到注册到zookeeper,zookeeper将服务端的相关配置存储并管理更新,而服务消费者链接到zookeeper注册中心通过zookeeper这个注册中心获取服务端的相关信息,生成远程代理服务就调用服务端提供的方法了!!!这是我简单的一个理解,当然zookeeper还有软负载等功能,但是具体的怎么实现的也不太清,先知道的自己可以查看资料学习!!!

7、demo源码下载

(1)、zookeeper 安装包下载:http://download.csdn.net/detail/qh_java/9655026

zookeeper安装包下载地址

(2)、服务端服、服务消费者以及服务端的jar包(maven工程)下载:http://download.csdn.net/download/qh_java/9655491

dubbo zookeeper小demo下载

ok到此我们简单的小demo学习就ok了 下片我们看看本地伪集群的配置


愿意了解或者源码的朋友直接求求交流分享技术:2042849237

更多详细源码参考来源:http://minglisoft.cn/technology

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,294评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,780评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,001评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,593评论 1 289
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,687评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,679评论 1 294
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,667评论 3 415
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,426评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,872评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,180评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,346评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,019评论 5 340
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,658评论 3 323
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,268评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,495评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,275评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,207评论 2 352

推荐阅读更多精彩内容