Dubbo+Zookeeper 项目搭建

gmdzxx

Dubbo是什么：

     分布式服务框架
     --高性能和透明化的RPC远程服务调用方案
     --SOA服务治理方案

Dubbo解决问题:

     透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。
     软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器。
     服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。

Maven工程搭建：

pom文件见附件pom.zip

项目工程结构：








applicationContext_dubbo-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">
  
    <!-- ************************************************************************ -->
<!-- 将多个配置文件位置放到列表中 -->  

    <bean id="propertyResources" class="java.util.ArrayList">  
        <constructor-arg>  
            <list>  
           <value>classpath:/config.properties</value>
            </list>  
        </constructor-arg>  
    </bean>  
      
    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">  
        <property name="locations" ref="propertyResources" />  
    </bean>
  
   <!-- ************************************************************************ -->
  
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="dubbo-service-provider" />

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

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

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

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="cn.ias.agdis.techtest.dubbo.provider.service.UserService"
        ref="userService" version="1.0.0" protocol="dubbo,hessian"/>

    <!-- 和本地bean一样实现服务 -->
    <bean id="userService" class="cn.ias.agdis.techtest.dubbo.provider.service.impl.UserServiceImpl">
        <property name="dao" ref="userDao"/>
    </bean>
  
     
    <!-- dao bean -->
    <bean id="userDao" class="cn.ias.agdis.techtest.dubbo.provider.dao.impl.UserDaoImpl" />
  
</beans>


applicationContext_dubbo-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="dubbo-service-consumer" />

<dubbo:consumer check = "false"/>

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

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

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:reference id="userServiceRPC" interface="cn.ias.agdis.techtest.dubbo.provider.service.UserService"
     version="1.0.0" registry="techtestRegistry"/>


</beans>


web.xml

<!DOCTYPE web-app PUBLIC
"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
"http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>
<display-name>Archetype Created Web Application</display-name>

<!-- location of spring xml files -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:/applicationContext_dubbo-provider.xml,classpath:/applicationContext-webservice-producer.xml</param-value>
</context-param>
   
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

<!-- CXF servlet -->
<servlet>
<servlet-name>CXFServlet</servlet-name>
<servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>

<!-- all our webservices are mapped under this URI pattern -->
<servlet-mapping>
<servlet-name>CXFServlet</servlet-name>
<url-pattern>/webservices/*</url-pattern>
</servlet-mapping>

</web-app>


工程源码：

源码文件见附件 mytechtest.zip