本節我們演示下dubbo專案的搭建，服務端和客戶端進行遠端通訊，通過zookeeper進行註冊的實現。

      專案結構圖

Dubbo-client客戶端

Dubbo-host 宿主服務

Dubbo-model實體Model

Dubbo-service服務

Dubbo-service-impl服務實現

model

model層需要實現序列化介面Serializable

package com.dubbo.model;

import java.io.Serializable;

public class ProductModel implements Serializable {

	//產品名稱
	private String name;
	
	//產品編碼
	private String code;

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getCode() {
		return code;
	}

	public void setCode(String code) {
		this.code = code;
	}

	
}
 

package com.dubbo.service;

import java.util.List;

import com.dubbo.model.ProductModel;

public interface ProductService {
	
	public  List<ProductModel> GetAllProcuct();

}

package com.dubbo.service.impl;

import java.util.ArrayList;
import java.util.List;

import com.dubbo.model.ProductModel;
import com.dubbo.service.ProductService;

public class ProductServiceImpl implements ProductService  {

	
	public List<ProductModel> GetAllProcuct() {
		// TODO Auto-generated method stub
		List<ProductModel> list=new ArrayList<ProductModel>();
		
		ProductModel  model1=new ProductModel();
		model1.setCode("001");
		model1.setName("可口可樂");
		list.add(model1);
		
		ProductModel  model2=new ProductModel();
		model2.setCode("002");
		model2.setName("百事可樂");
		list.add(model2);
		
		
		ProductModel  model3=new ProductModel();
		model3.setCode("003");
		model3.setName("非常可樂");
		list.add(model3);
		
		return list;
	}

}
 

applicationContext.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  
        ">  
   
    <!-- 具體的實現bean -->  
   <bean id="productService" class="com.dubbo.service.impl.ProductServiceImpl" />  
      
  <!-- 提供方應用資訊，用於計算依賴關係 -->  
   <dubbo:application name="provider"  />  
   <dubbo:monitor protocol= "registry" />
   <!-- 使用zookeeper註冊中心暴露服務地址 -->  
   <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" />   
      <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181" />    -->
   <!-- 用dubbo協議在20880埠暴露服務 -->  
   <dubbo:protocol name="dubbo" port="20880" />  
 
   <!-- 宣告需要暴露的服務介面 -->  
  <dubbo:service interface="com.dubbo.service.ProductService" ref="productService" />  
    
</beans>  
 

package com.dubbo.host;

import java.io.IOException;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args )
    {
    	
    	ClassPathXmlApplicationContext  context =new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"});  
        context.start();  

        System.out.println( "dubbol服務啟動" );
        try {
			System.in.read();
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
        System.out.println("關閉服務");
        context.close();
    }
}

cllient

<?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"  />  
  
   <!-- 使用zookeeper註冊中心暴露服務地址 -->  
   <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" />   
     <!--  <dubbo:registry address="zookeeper://127.0.0.1:2181" />   --> 
   
   <!--   <dubbo:monitor protocol= "registry" /> -->
  <dubbo:reference id="productService"  
       interface="com.dubbo.service.ProductService" />  

    
</beans>  

package com.dubbo.client;

import java.util.List;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.dubbo.model.ProductModel;
import com.dubbo.service.ProductService;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args )
    {
    	
    
     	ClassPathXmlApplicationContext  context =new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"});  
        context.start();  

    	 
        ProductService service = (ProductService) context.getBean("productService"); //  
    	       List<ProductModel> list =service.GetAllProcuct();
    	     for(ProductModel model:list)
    	     {
    	    	 System.out.println(model.getCode()+"--"+model.getName());
    	    	 
    	     }

        System.out.println( "dubbo呼叫完成!" );
    }
}

http://download.csdn.net/detail/zx13525079024/9601687