SOA实例：Dubbo

Dubbo是一个分布式服务框架，它作用有：
1. 远程方法调用,如调用本地方法
2. 服务自动查找，不需知道服务提供方地址，注册中心基于接口名查询服务提供者的IP地址
3. 负载均衡及容错机制

定义服务接口: (该接口需单独打包，在服务提供方和消费方共享)

DemoService.java

1 2 3 4

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

 在服务提供方实现接口：(对服务消费方隐藏实现)

DemoServiceImpl.java

1 2 3 4 5 6 7 8 9 10 11

package com.alibaba.dubbo.demo.provider;    import com.alibaba.dubbo.demo.DemoService;    public class DemoServiceImpl implements DemoService {        public String sayHello(String name) {         return "Hello " + name;     }    }

 用Spring配置声明暴露服务：

 provider.xml

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

<?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="hello-world-app"  />        <!-- 使用multicast广播注册中心暴露服务地址 -->     <dubbo:registry address="multicast://224.5.6.7:1234" />        <!-- 用dubbo协议在20880端口暴露服务 -->     <dubbo:protocol name="dubbo" port="20880" />        <!-- 声明需要暴露的服务接口 -->     <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />        <!-- 和本地bean一样实现服务 -->     <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />    </beans>

 加载Spring配置：

Provider.java

1 2 3 4 5 6 7 8 9 10 11 12

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

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

<?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"  />         <!-- 使用zookeeper注册中心暴露服务地址 -->       <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->       <dubbo:registry address="zookeeper://127.0.0.1:2181" />        <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->     <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />    </beans>

 加载Spring配置，并调用远程服务：(也可以使用IoC注入)

Consumer.java

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

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 ); // 显示调用结果     }    }

ref: http://www.it610.com/article/2285944.htm