Spring 集成 Dubbo

ZooKeeper

ZooKeeper 可以作为 Dubbo 的注册中心。

Dubbo 未对 Zookeeper 服务器端做任何侵入修改,只需安装原生的 Zookeeper 服务器即可,所有注册中心逻辑适配都在调用 Zookeeper 客户端时完成。

安装

ZooKeeper 发布中心 选择需要的版本,下载后解压到本地。

配置

  1. vi conf/zoo.cfg

如果不需要集群,zoo.cfg 的内容如下 2

  1. tickTime=2000
  2. initLimit=10
  3. syncLimit=5
  4. dataDir=/home/dubbo/zookeeper-3.3.3/data
  5. clientPort=2181

如果需要集群,zoo.cfg 的内容如下 3

  1. tickTime=2000
  2. initLimit=10
  3. syncLimit=5
  4. dataDir=/home/dubbo/zookeeper-3.3.3/data
  5. clientPort=2181
  6. server.1=10.20.153.10:2555:3555
  7. server.2=10.20.153.11:2555:3555

并在 data 目录 4 下放置 myid 文件:

  1. mkdir data
  2. vi myid

myid 指明自己的 id,对应上面 zoo.cfgserver. 后的数字,第一台的内容为 1,第二台的内容为 2,内容如下:

  1. 1

启动

Linux 下执行 bin/zkServer.sh ;Windows bin/zkServer.cmd 启动 ZooKeeper 。

命令行

  1. telnet 127.0.0.1 2181
  2. dump

或者:

  1. echo dump | nc 127.0.0.1 2181

用法:

  1. dubbo.registry.address=zookeeper://10.20.153.10:2181?backup=10.20.153.11:2181

或者:

  1. <dubbo:registry protocol="zookeeper" address="10.20.153.10:2181,10.20.153.11:2181" />
  1. Zookeeper是 Apache Hadoop 的子项目,强度相对较好,建议生产环境使用该注册中心
  2. 其中 data 目录需改成你真实输出目录
  3. 其中 data 目录和 server 地址需改成你真实部署机器的信息
  4. 上面 zoo.cfg 中的 dataDir
  5. http://zookeeper.apache.org/doc/r3.3.3/zookeeperAdmin.html

Dubbo

Dubbo 采用全 Spring 配置方式,透明化接入应用,对应用没有任何 API 侵入,只需用 Spring 加载 Dubbo 的配置即可,Dubbo 基于 Spring 的 Schema 扩展进行加载。

如果不想使用 Spring 配置,可以通过 API 的方式 进行调用。

服务提供者

完整安装步骤,请参见:示例提供者安装

定义服务接口

DemoService.java 1

  1. package com.alibaba.dubbo.demo;
  2. public interface DemoService {
  3. String sayHello(String name);
  4. }

在服务提供方实现接口

DemoServiceImpl.java 2

  1. package com.alibaba.dubbo.demo.provider;
  2. import com.alibaba.dubbo.demo.DemoService;
  3. public class DemoServiceImpl implements DemoService {
  4. public String sayHello(String name) {
  5. return "Hello " + name;
  6. }
  7. }

用 Spring 配置声明暴露服务

provider.xml:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  5. 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">
  6. <!-- 提供方应用信息,用于计算依赖关系 -->
  7. <dubbo:application name="hello-world-app" />
  8. <!-- 使用multicast广播注册中心暴露服务地址 -->
  9. <dubbo:registry address="multicast://224.5.6.7:1234" />
  10. <!-- 用dubbo协议在20880端口暴露服务 -->
  11. <dubbo:protocol name="dubbo" port="20880" />
  12. <!-- 声明需要暴露的服务接口 -->
  13. <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />
  14. <!-- 和本地bean一样实现服务 -->
  15. <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />
  16. </beans>

如果注册中心使用 ZooKeeper,可以将 dubbo:registry 改为 zookeeper://127.0.0.1:2181

加载 Spring 配置

Provider.java:

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Provider {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/provider.xml"});
        context.start();
        System.in.read(); // 按任意键退出
    }
}

服务消费者

完整安装步骤,请参见:示例消费者安装

通过 Spring 配置引用远程服务

consumer.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="consumer-of-helloworld-app"  />

    <!-- 使用multicast广播注册中心暴露发现服务地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />

    <!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
    <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />
</beans>

如果注册中心使用 ZooKeeper,可以将 dubbo:registry 改为 zookeeper://127.0.0.1:2181

加载Spring配置,并调用远程服务

Consumer.java 3

import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.alibaba.dubbo.demo.DemoService;

public class Consumer {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/consumer.xml"});
        context.start();
        DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
        String hello = demoService.sayHello("world"); // 执行远程方法
        System.out.println( hello ); // 显示调用结果
    }
}
  1. 该接口需单独打包,在服务提供方和消费方共享
  2. 对服务消费方隐藏实现
  3. 也可以使用 IoC 注入

FAQ

建议使用 dubbo-2.3.3 以上版本的 zookeeper 注册中心客户端。

资料

Dubbo

Github | 用户手册 | 开发手册 | 管理员手册

ZooKeeper

官网 | 官方文档