原文链接：http://dtbuluo.com/blog/archives/123

推荐使用dubboframework作为分布式服务框架，强烈推荐使用zookeeper作为协调调度系统。关于这两个的安装和配置，请参照本人关于其安装博文，这边介绍一个简单的基于dubbo:protocol的demo，rpc服务调用哦。

说明：本人基于redhat6做的demo，jdk等各种环境都已经就绪了。建议java开发者了解linux系统。

demo项目如图：

运行结果如图：

demo开发步骤：

开发工具：eclipse for javaee

1、新建普通java项目，名称：dubbo-protocol

引入dubbo所需的jar包：

2、新建接口服务：com.enson.demo.service.DubboService

代码：

package com.enson.demo.service;

public interface DubboService {
	
	public String printWord(String word);

}

3、实现接口：com.enson.demo.service.impl.DubboServiceImpl

代码：

package com.enson.demo.service.impl;

import java.text.SimpleDateFormat;
import java.util.Date;

import com.enson.demo.service.DubboService;

public class DubboServiceImpl implements DubboService{

	@Override
	public String printWord(String word) {
		String outWord = new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss ]")
			.format(new Date()) + word;
		System.err.println(outWord);
		return outWord;
	}

}

4、创建provider.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-service-app" />

	<!-- 使用zookeeper注册中心暴露服务地址 -->
	<dubbo:registry address="zookeeper://127.0.0.1:2181" />

	<!-- 用dubbo协议在20880端口暴露服务 -->
	<dubbo:protocol name="dubbo" port="20880" />

	<!-- 声明需要暴露的服务接口 -->
	<dubbo:service interface="com.enson.demo.service.DubboService"
		ref="dubboService" />

	<!-- 和本地bean一样实现服务 -->
	<bean id="dubboService" class="com.enson.demo.service.impl.DubboServiceImpl" />

</beans>

5、创建test.Provider类，作为服务注册的入口：

package test;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Provider {

	public static void main(String[] args) throws IOException {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"provider.xml"});
        context.start();
 
        System.in.read(); // 按任意键退出

	}

}

以上完成了服务提供者的编写。

6、创建com.enson.custom.action.DubboAction

package com.enson.custom.action;

import com.enson.demo.service.DubboService;

public class DubboAction {
	public DubboService dubboService ;

	//Spring 方法注入
	public void setDubboService(DubboService dubboService) {
		this.dubboService = dubboService;
	}
	
	public String printWord(){
		System.out.println("action printWord被执行！");
		return this.dubboService.printWord("Hello World");// 执行远程方法
	}
}

7、创建cstom.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-custom-app"  />
 
    <!-- 使用zookeeper注册中心暴露发现服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
 
    <!-- 生成远程服务代理，可以和本地bean一样使用dubboService -->
    <dubbo:reference id="dubboService" interface="com.enson.demo.service.DubboService" />
    
    <!-- 普通的spring bean的定义 -->
    <bean id="dubboAction" class="com.enson.custom.action.DubboAction">
    <!-- 实例化action中的dubboService 方法注入 -->
    	<property name="dubboService" ref="dubboService"/>
    </bean>
 
</beans>

8、创建消费者类：test.Custom

package test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.enson.custom.action.DubboAction;

public class Custom {

	public static void main(String[] args) {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
				new String[] { "consumer.xml" });
		context.start();

		DubboAction dubboAction = (DubboAction) context.getBean("dubboAction"); // 获取远程服务代理
		String word = dubboAction.printWord();// 执行远程方法

		System.out.println(word); // 显示调用结果

	}

}

以上完成了消费者的编写，到此，整个demo编写完了，接下来就是测试。

测试：

1、启动zookeeper。

2、执行Provider。Run as java application

3、执行Custom。Run as java application

查看控制台即可。