dubbo是阿里巴巴开源的分布式服务框架,致力于提供高性能和透明化的rpc远程服务调用方案,以及soa服务治理方案,如果没有分布式需求,是不需要dubbo的,分布式环境dubbo的使用架构官方给出了一张图
图中涉及到的对象有4个:注册中心、监控管理中心、服务提供者、服务消费者,具体过程以实际项目的dubbo服务部署来介绍,如下图
zookeeper集群作为注册中心,dubbo-admin(dubbo官方提供的管理平台)作为服务的监控管理中心,流程说明如下
- 首先,启动zookeeper注册中心,dubbo-admin随后启动
- 启动dubbo服务提供方系统,启动过程中主动向注册中心注册
- 启动dubbo服务消费方系统,启动过程中向注册中心订阅服务
- 注册中心将服务提供方信息返回给消费方
- 消费方远程调用dubbo服务提供方的服务
实际项目通常是集群方式部署,但集群也是基于单节点的,所以,下面先介绍单节点的部署,单节点的意思是只有一个zookeeper、一个dubbo服务提供方、一个dubbo服务消费方,最后会介绍集群部署
安装zookeeper注册中心
首先安装注册中心,以zookeeper为例,还有其他可选方案如redis,从zookeeper官方网站下载安装包:zookeeper-3.4.9.tar.gz,解压安装
tar xvf zookeeper-3.4.9.tar.gz -C /usr/java cd /usr/java/zookeeper-3.4.9/conf cp zoo_sample.cfg zoo.cfg
启动zookeeper,zoo.cfg配置了启动端口等信息,默认:2181
cd /usr/java/zookeeper-3.4.9/bin ./zkServer.sh start
安装dubbo-admin管理中心
从http://pan.baidu.com/s/1dDlI7aL下载dubbo-admin-2.5.4.war包,官网已经不提供下载了,将下载的包放在tomcat的webapps目录,启动tomcat自动解压该war包,然后修改配置文件
cd /usr/java/apache-tomcat-7.0.70/webapps/dubbo-admin-2.5.4/WEB-INF vi dubbo.properties
修改zookeeper地址和端口(zookeeper注册中心)
dubbo.registry.address=zookeeper://172.17.210.124:2181 dubbo.admin.root.password=root dubbo.admin.guest.password=guest
重启tomcat(没修改就不用重启了),访问tomcat的url+“/dubbo-admin-2.5.4”登录dubbo管理中心,账户密码:root/root
dubbo服务提供方
注册中心和管理中心搭建好之后,开始着手实现dubbo服务提供方
声明服务接口
package com.xmyself.demo.dubbo.service; public interface TestService { public String test(); }
注意:声明的服务接口要生成一个jar包,服务消费方需要这个jar包才能调用远程的方法,因此,通常服务接口声明在独立的工程如dubbo-client中,这个工程专门打包成jar文件供消费方使用
服务实现类
package com.xmyself.demo.dubbo.service; public class TestServiceImpl implements TestService { public String test() { return "dubbo is running"; } }
现在,怎么启动dubbo服务呢?整一个main方法就行
package com.xmyself.demo.dubbo.service; public class Main { public static void main(String[] args) { // 启动容器,自动加载资源目录下的/META-INF/spring/*.xml初始化spring容器 com.alibaba.dubbo.container.Main.main(args); } }
我们有提到过,启动dubbo服务提供方时需要主动向注册中心注册服务,这需要依赖一些jar(说明:dubbo 2.5.3直接依赖了spring 2.5.6的全部jar)
<dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> </dependency> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.4</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.9</version> </dependency>
除了依赖,还需要配置注册中心的信息以及提交给注册中心的信息,dubbo使用了spring,启动dubbo的过程就是初始化spring容器的过程,因此,这些配置都以xml方式提供,在src/main/java目录(包和类的根目录,即classpath)新建META-INF/spring目录,里面放一个dubbo-server.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"> <!-- 提供方应用信息,用于计算依赖关系 --> <dubbo:application name="dubbo-test" /> <!-- 使用zookeeper注册中心暴露服务地址 --> <dubbo:registry protocol="zookeeper" address="172.17.210.124:2181" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="com.xmyself.demo.dubbo.service.TestService" ref="testService" version="0.0.1" /> <bean id="testService" class="com.xmyself.demo.dubbo.service.TestServiceImpl" /> </beans>
这时候运行main方法dubbo服务提供方就启动了
另外,还可以有另一种方式启动(就是自己来初始化spring上下文容器,不用com.alibaba.dubbo.container.Main.main())
public static void main(String[] args) throws Exception { ApplicationContext context = new ClassPathXmlApplicationContext("classpath:META-INF/spring/dubbo-server.xml"); context.start(); System.in.read();//阻塞 }
登陆dubbo管理中心,可以看到有了新的服务提供方
dubbo服务消费方
第一件事就是要依赖提供方提供的接口声明jar
<dependency> <groupId>com.xmyself</groupId> <artifactId>dubbo-client</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency>
然后配置dubbo、zookeeper的依赖
<dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> </dependency> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.4</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.9</version> </dependency>
dubbo依赖了spring2.5.6版本的所有包,如果使用新版spring,需要排除依赖,实际情况基本都会在新版的spring中初始化dubbo服务,但初始化方式完全相同
package com.test.dubbo; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.xmyself.demo.dubbo.service.TestService; public class Test { public static void main(String[] args) { ApplicationContext context = new ClassPathXmlApplicationContext("dubbo-client.xml"); TestService testService = (TestService) context.getBean("testService", TestService.class); System.out.println(testService.test()); } }
前面也有提到,服务消费方启动时需要向注册中心订阅服务,这些配置同样配置在xml文件,在src/main/java(包和类的根目录即classpath)新建dubbo-client.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"> <!-- 服务名称 --> <dubbo:application name="dubbo-test" /> <!-- 注册地址 --> <dubbo:registry protocol="zookeeper" address="172.17.210.124:2181" /> <!-- 服务接口 --> <dubbo:reference interface="com.xmyself.demo.dubbo.service.TestService" version="0.0.1" /> </beans>
运行main方法即启动了dubbo服务消费方
Java Service Wrapper容器
dubbo服务直接以main方法运行,不方便管理,找个容器让它运行比较好,tomcat是个不错的容器,但dubbo服务没必要整成web工程那么复杂
Java Service Wrapper小巧精悍,只有几百K大小,可以将带有main方法的jar包装成系统服务,然后再将wrapper配置成系统服务,随系统的启动而启动,非常方便
从Java Service Wrapper官网下载安装包:wrapper-linux-x86-64-3.5.30.tar.gz,放在/usr/file目录,然后解压
tar xvf /usr/file/wrapper-linux-x86-64-3.5.30.tar.gz -C /usr/java/ vi /usr/java/wrapper-linux-x86-64-3.5.30/conf/wrapper.conf
修改如下配置
wrapper.java.mainclass=com.test.dubbo.Main # Java Classpath (include wrapper.jar) Add class path elements as # needed starting from 1 wrapper.java.classpath.1=../lib/wrappertest.jar wrapper.java.classpath.2=../lib/wrapper.jar wrapper.java.classpath.3=/usr/file/*.jar
其实配置很简单,就是用来配置启动的main方法以及所需的jar包和xml文件路径
启动容器
cd /usr/java/wrapper-linux-x86-64-3.5.30/bin wrapper -c ../conf/wrapper.conf
每次这样启动实在不方便,Java Service Wrapper其实为我们提供了启动的shell脚本,这就是位于/usr/java/wrapper-linux-x86-64-3.5.30/bin目录下的testwrapper文件,启动脚本默认用测试的conf启动,修改成wrapper.conf即可,然后将文件重命名为“wrapperService”,就能以下面的方式运行或停止dubbo服务了
./wrapperService start ./wrapperService stop ./wrapperService restart
zookeeper集群配置
dubbo服务提供方与消费方单个和多个没有任何区别,只有zookeeper需要为集群单独配置
启动多个zookeeper实例(一般是在不同机器),然后将他们配置成集群,以提供稳定可靠的注册服务,zookeeper集群的启动是以集群中半数以上机器正常启动为基准的,因此zookeeper集群通常是奇数个节点,下面以3台zookeeper节点配置集群为例
在三台机器上安装zookeeper,然后修改配置文件,三台机器zoo.cfg配置相同(如果要在同一台机器启动三个zookeeper实例,端口要配置不同)
tickTime=2000 initLimit=10 syncLimit=5 clientPort=2181 dataDir=/tmp/zookeeper/data server.1=172.17.210.124:2888:3888 server.2=172.17.210.125:2888:3888 server.3=172.17.210.126:2888:3888
然后在每个/tmp/zookeeper/data/目录下创建一个myid文件(没有后缀名),文件内容分别为1、2、3,比如server.1=172.17.210.124:2888:3888就表示,172.17.210.124这台机器配置的myid文件内容为1,另外两台同理
简单说下配置“server.A=B:C:D”的意思
- A是一个数字,表示这个是第几号服务器
- B是这个服务器的ip地址
- C第一个端口用来集群成员的信息交换,表示的是这个服务器与集群中的Leader服务器交换信息的端口
- D是在leader挂掉时专门用来进行选举leader所用
依次启动三台服务器,这个zookeeper集群就配置好了
dubbo配置注册中心的时候只需要用逗号隔开多个注册中心就可以了
address="172.17.210.124:2181,172.17.210.125:2181,172.17.210.126:2181"