学习目录在上一篇中有了，这篇我们来写一个本地的单服务的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
（2）、服务端服、服务消费者以及服务端的jar包（maven工程）下载：http://download.csdn.net/download/qh_java/9655491
ok到此我们简单的小demo学习就ok了 下片我们看看本地伪集群的配置
愿意了解或者源码的朋友直接求求交流分享技术：2042849237
更多详细源码参考来源：http://minglisoft.cn/technology
网友评论