spring集成dubbo

现在将系统按照服务划分成多个部分。代码功能分为前端和后台服务已经很流行。下面我将介绍基于maven项目结构的spring集成dubbo功能。

1、首先找zookeeper网站下载zookeeper-3.4.6.tar.gz包，将其放置到服务器上。

2、解压zookeeper包 ,安装。并将/confg/zoo.sample.cfg更名成zoo.cfg

3、修改配置文件内容，如图

4、在spring服务器端导入需要的dubbo包和zookeeper包：

 <dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>dubbo</artifactId>
   <version>${dubbo.version}</version>
   <exclusions>
      <exclusion>
         <groupId>org.springframework</groupId>
         <artifactId>spring</artifactId>
      </exclusion>
   </exclusions>
</dependency>
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.4.6</version>
</dependency>

5、客户端也要导入所需要的包：

  <dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>${dubbo.version}</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
</exclusions>
</dependency>

6、服务器端提服务接口和服务实现

package com.ucf.dubbo;

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

import org.springframework.stereotype.Component;

@Component
public class DemoServiceImpl implements DemoService {
@Override
    public String sayHello(String name) {
return "Hello Dubbo,Hello " + name;
    }

}

7、编写dubbo配置文件  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">

<!-- 提供方应用信息，用于计算依赖关系 -->       <dubbo:application name="hello-world-app"  />

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

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

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

<!-- 声明需要暴露的服务接口 -->       <dubbo:service interface="com.ucf.dubbo.DemoService" ref="demoService" />

<!-- 和本地bean一样实现服务 -->       <bean id="demoService" class="com.ucf.dubbo.DemoServiceImpl" /></beans>

8、客户端编写接口（注意这个接口一定要和服务提供方接口的路径一致）

package com.ucf.dubbo;

import org.springframework.stereotype.Component;

/**
 * Created by user on 2015/11/3.
 */
@Component
public interface DemoService {
    String sayHello(String name);
}

9、客户端的配置文件如下：dubbo-customer.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" /> -->       <dubbo:registry address="zookeeper://192.168.1.224:2181" />       <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->       <dubbo:reference id="demoService" interface="com.ucf.dubbo.DemoService" /></beans>

9、服务器端将配置文件放置到spring上下文中

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"    xmlns:util="http://www.springframework.org/schema/util"     xmlns:mvc="http://www.springframework.org/schema/mvc"    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   xmlns:aop="http://www.springframework.org/schema/aop"   xmlns:context="http://www.springframework.org/schema/context"   xmlns:jdbc="http://www.springframework.org/schema/jdbc"    xmlns:tx="http://www.springframework.org/schema/tx"

  xmlns:task="http://www.springframework.org/schema/task"   xsi:schemaLocation="       http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd      http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd      http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd      http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd      http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd

     http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd      http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd"   default-lazy-init="true">

<context:property-placeholder location="classpath:/META-INF/app.properties" />   <util:properties id="appSettings" location="classpath:/META-INF/app.properties" />   <context:component-scan base-package="com.ucf,com.mybatis.sys.dto" />

<import resource="classpath:ucf-jdbc.xml"/>   <import resource="classpath:applicationContext-aop.xml" />   <import resource="classpath:radis.xml"/>   <import resource="dubbo-provider.xml"/>

</beans>

10、客户端将其将配置文件放置到spring上下文中

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"       xmlns:util="http://www.springframework.org/schema/util"       xmlns:mvc="http://www.springframework.org/schema/mvc"       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"       xmlns:aop="http://www.springframework.org/schema/aop"       xmlns:context="http://www.springframework.org/schema/context"       xmlns:jdbc="http://www.springframework.org/schema/jdbc"       xmlns:tx="http://www.springframework.org/schema/tx"

      xmlns:task="http://www.springframework.org/schema/task"       xsi:schemaLocation="       http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd      http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd      http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd      http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd      http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd

     http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd      http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd"       default-lazy-init="true">       <context:property-placeholder location="/META-INF/app.properties" />       <util:properties id="appSettings" location="/META-INF/app.properties" />

<import resource="dubbo-customer.xml"/>

</beans>

11、写个demo启动测试

hdb.dubbo;

com.ucf.dubbo.DemoService;
org.springframework.context.support.ClassPathXmlApplicationContext;

Consumer {
    main([] args) {
        ClassPathXmlApplicationContext context = ClassPathXmlApplicationContext();
        context.start();
        DemoService demoService = (DemoService)context.getBean();  hello = demoService.sayHello(); System..println(hello);
    }
}

结果如图：