Dubbo+Zookeeper入门实例
2018-02-12 14:55
363 查看
现在的公司接口调用是通过dubbo来实现的,所以这两天就了解了一下dubbo是如何进行通信的,写了一个最简单的例子。自上得来终觉浅,绝知此事要躬行。
节点角色说明:Provider: 暴露服务的服务提供方。Consumer: 调用远程服务的服务消费方。Registry: 服务注册与发现的注册中心。Monitor: 统计服务的调用次调和调用时间的监控中心。Container: 服务运行容器。
调用关系说明:0. 服务容器负责启动,加载,运行服务提供者。1. 服务提供者在启动时,向注册中心注册自己提供的服务。2. 服务消费者在启动时,向注册中心订阅自己所需的服务。3. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。4. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。5. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
上面右边的图是两个工程需要引入的jar包,其中做出标记的“dubboProductor.jar”是服务者工程中提供服务的接口打的jar包,这个jar包要在消费者工程中被引入
<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服务者起个名 -->
<dubbo:application name="productor"/>
<!-- 用zookeeper注册服务中心暴露服务地址 -->
<dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/>
<!-- 暴露dubbo的通信端口 -->
<dubbo:protocol name="dubbo" port="20880"/>
<!-- 给消费者提供服务的接口 -->
<dubbo:service ref="bubboProdutor" interface="com.dubbo.service.DubboProductorTest"></dubbo:service>
<!-- 提供服务的实现类 -->
<bean id="bubboProdutor" class="com.dubbo.service.impl.DubboProductorTestImpl"></bean>
</beans>
提供服务的服务接口DubboProductorTest[java] view plain copypackage com.dubbo.service;
public interface DubboProductorTest {
public void sayHello();
}
服务接口的具体实现类DubboProductorTestImpl[java] view plain copypackage com.dubbo.service.impl;
import com.dubbo.service.DubboProductorTest;
public class DubboProductorTestImpl implements DubboProductorTest{
public void sayHello(){
System.out.println("这是我的第一个dubbo测试");
}
}
始终将dubbo服务保持开启状态[java] view plain copypackage com.dubbo.main;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class DubboProductorMain {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext cfg = new ClassPathXmlApplicationContext("com/dubbo/config/ApplicationContextProducror.xml");
cfg.start();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = new Date();
System.out.println("按任意键退出,时间:"+sdf.format(date));
//保证服务始终开启
System.in.read();
}
}
<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="customer"/>
<!-- 用zookeeper注册服务中心发现服务地址 -->
<dubbo:registry protocol="zookeeoer" address="zookeeper://127.0.0.1:2181"/>
<!-- 调用远程的接口 -->
<dubbo:reference id="dubboProvider" interface="com.dubbo.service.DubboProductorTest"/>
</beans>
消费者测试类CustomerMain[java] view plain copypackage com.dubbo.main;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.dubbo.service.DubboProductorTest;
public class CustomerMain {
public static void main(String[] args) throws InterruptedException{
ClassPathXmlApplicationContext cfig = new ClassPathXmlApplicationContext("com/dubbo/config/ApplicationContextCustomer.xml");
DubboProductorTest test = (DubboProductorTest) cfig.getBean("dubboProvider");
System.out.println("消费者调用服务方接口开始");
test.sayHello();
Thread.sleep(100000);
System.out.println("消费者调用服务方接口结束");
}
}
第二句话“这是我的第一个dubbo测试”是在启动消费者工程的时候才打印出来的。 我们在用zookeeper管理后台看一下在zookeeper中注册的服务者和消费者,zookeeper管理后台是通过解压dubbo-admin-2.5.4-SNAPSHOT.war,将解压获得文件放入到tomcat中的webapps文件夹下的root文件夹中的,你最好是复制一个tomcat,并改变tomcat中server.xml文件中所有的端口号,启动tomcat,我的端口号是8000,所以输入:http://127.0.0.1:8000就进入到zookeeper管理后台的登录页面了。
可以看到上面有一个消费者和一个服务者,他们名称正是在配置文件中给消费者和服务者所命名的。
后面的学习计划: 1.struts2源码及原理理清楚 2.熟悉设计模式,几种常见的设计模式要会掌握 3.spring和mybatis源码过一遍,里面的原理要清楚 4.Java的JVM要清楚 5.学习redis 感觉把学习计划一列出来感觉自己还是个java初级程序员啊,啊,要抓紧时间学习啦
前言.dubbo介绍
Dubbo是一个分布式服务框架,Dubbo的架构如图所示:节点角色说明:Provider: 暴露服务的服务提供方。Consumer: 调用远程服务的服务消费方。Registry: 服务注册与发现的注册中心。Monitor: 统计服务的调用次调和调用时间的监控中心。Container: 服务运行容器。
调用关系说明:0. 服务容器负责启动,加载,运行服务提供者。1. 服务提供者在启动时,向注册中心注册自己提供的服务。2. 服务消费者在启动时,向注册中心订阅自己所需的服务。3. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。4. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。5. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
一.项目构图和进入jar包
下面的图片是我写dubbo消费者和服务者工程以及两个工程需要引入的jar包,这个jar包中有可能是没有用的,我是直接引入的,很容易少包,你如果能用maven来引包的话可能会更好。上面右边的图是两个工程需要引入的jar包,其中做出标记的“dubboProductor.jar”是服务者工程中提供服务的接口打的jar包,这个jar包要在消费者工程中被引入
二.提供服务的服务者工程
服务者配置文件ApplicationContextProducror.xml [html] view plain copy<?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服务者起个名 -->
<dubbo:application name="productor"/>
<!-- 用zookeeper注册服务中心暴露服务地址 -->
<dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/>
<!-- 暴露dubbo的通信端口 -->
<dubbo:protocol name="dubbo" port="20880"/>
<!-- 给消费者提供服务的接口 -->
<dubbo:service ref="bubboProdutor" interface="com.dubbo.service.DubboProductorTest"></dubbo:service>
<!-- 提供服务的实现类 -->
<bean id="bubboProdutor" class="com.dubbo.service.impl.DubboProductorTestImpl"></bean>
</beans>
提供服务的服务接口DubboProductorTest[java] view plain copypackage com.dubbo.service;
public interface DubboProductorTest {
public void sayHello();
}
服务接口的具体实现类DubboProductorTestImpl[java] view plain copypackage com.dubbo.service.impl;
import com.dubbo.service.DubboProductorTest;
public class DubboProductorTestImpl implements DubboProductorTest{
public void sayHello(){
System.out.println("这是我的第一个dubbo测试");
}
}
始终将dubbo服务保持开启状态[java] view plain copypackage com.dubbo.main;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class DubboProductorMain {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext cfg = new ClassPathXmlApplicationContext("com/dubbo/config/ApplicationContextProducror.xml");
cfg.start();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = new Date();
System.out.println("按任意键退出,时间:"+sdf.format(date));
//保证服务始终开启
System.in.read();
}
}
三.消费者工程
消费者服务工程ApplicationContextCustomer.xml[html] view plain copy<?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="customer"/>
<!-- 用zookeeper注册服务中心发现服务地址 -->
<dubbo:registry protocol="zookeeoer" address="zookeeper://127.0.0.1:2181"/>
<!-- 调用远程的接口 -->
<dubbo:reference id="dubboProvider" interface="com.dubbo.service.DubboProductorTest"/>
</beans>
消费者测试类CustomerMain[java] view plain copypackage com.dubbo.main;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.dubbo.service.DubboProductorTest;
public class CustomerMain {
public static void main(String[] args) throws InterruptedException{
ClassPathXmlApplicationContext cfig = new ClassPathXmlApplicationContext("com/dubbo/config/ApplicationContextCustomer.xml");
DubboProductorTest test = (DubboProductorTest) cfig.getBean("dubboProvider");
System.out.println("消费者调用服务方接口开始");
test.sayHello();
Thread.sleep(100000);
System.out.println("消费者调用服务方接口结束");
}
}
四.输出结果
1.启动zookeeper,启动zookeeper就是点击你zookeeper安装文件中bin文件下的zkServer.cmd文件,注意你一定要先启动zookeeper服务 2.启动服务者和消费者工程,输出结果:第二句话“这是我的第一个dubbo测试”是在启动消费者工程的时候才打印出来的。 我们在用zookeeper管理后台看一下在zookeeper中注册的服务者和消费者,zookeeper管理后台是通过解压dubbo-admin-2.5.4-SNAPSHOT.war,将解压获得文件放入到tomcat中的webapps文件夹下的root文件夹中的,你最好是复制一个tomcat,并改变tomcat中server.xml文件中所有的端口号,启动tomcat,我的端口号是8000,所以输入:http://127.0.0.1:8000就进入到zookeeper管理后台的登录页面了。
可以看到上面有一个消费者和一个服务者,他们名称正是在配置文件中给消费者和服务者所命名的。
后面的学习计划: 1.struts2源码及原理理清楚 2.熟悉设计模式,几种常见的设计模式要会掌握 3.spring和mybatis源码过一遍,里面的原理要清楚 4.Java的JVM要清楚 5.学习redis 感觉把学习计划一列出来感觉自己还是个java初级程序员啊,啊,要抓紧时间学习啦
相关文章推荐
- dubbo+spring+zookeeper的集成入门实例
- Dubbo+Zookeeper入门实例
- Dubbo新手入门实例HelloWorld(基于Zookeeper注册中心)
- zookeeper 入门讲解实例 转
- dubbo入门实例及性能测试
- dubbo入门实例
- zookeeper+dubbo+dubbo 的管理界面的入门案例
- spring整合zookeeper与dubbo的入门案例(一)
- 学习淘淘商城第十一课(dubbo入门及单机版zookeeper安装)
- Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例
- Dubbo入门实例
- Zookeeper深入浅出之快速入门实例
- Dubbo入门实例
- dubbo 入门教程 基于zookeeper
- Dubbo框架应用之(四)--Dubbo基于Zookeeper实现分布式实例
- dubbo本地组播入门实例
- Dubbo学习总结(1)——Dubbo入门基础与实例讲解
- Dubbo 入门实例 本地伪集群测试Demo
- zookeeper入门讲解实例
- dubbo入门实例-demo