Dubbo系列（二）dubbo的环境搭建

dubbo是一个分布式服务框架，提供一个SOA的解决方案。简单的说，dubbo就像在生产者和消费者中间架起了一座桥梁，使之能透明交互。本文旨在搭建一个可供使用和测试的dubbo环境，使用了spring框架、maven、zookeeper和dubbo服务。

1、准备

zookeeper：直接去官方网站下载即可（以下是：zookeeper-3.4.6），下载后解压，不需要改任何配置即可使用，或者改配置（..\zookeeper-3.4.6\conf\zoo.cfg）如下：

dubbo：直接去阿里巴巴下载即可(dubbo-admin即dubbo管理页面)，下载后解压并放到tomcat的webapps目录下，修改WEB-INF/dubbo.properties中属性如下：
#zookeeper的地址和端口
dubbo.registry.address=zookeeper://127.0.0.1:2181
#登录dubbo管理页面时的root用户和guest用户的密码
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest

2、代码：
如果你清楚生产者-消费者模型，那么将会很容易理解dubbo的使用步骤。一个生产者-消费者模型的代码实现需要3部分：生产者代码，消费者代码，中间接口。

2.1 中间接口：创建一个mavan项目，项目名字为dubbo-provideInterface，然后添加一个接口如下：

点击next，执行下一步；

依然点击next下一步；

点击finish按钮，maven项目创建完毕；

项目结构如图所示：

中间接口的代码：

package com.dubbo.provider.providerInterface;

/**

 * 服务端提供的中间接口

 * @author songzl

 *

 */

public interface ITest {

	public void sayHello(String message);

}

2.2生产者代码：创建一个mavan项目，项目名称为provideImpl，并引入spring依赖、中间接口依赖、zookeeper依赖及dubbo；

项目结构如图所示：

在此maven项目下的pom.xml文件中添加如下配置：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <groupId>com.dubbo.provider.providerImpl</groupId>

  <artifactId>providerImpl</artifactId>

  <version>0.0.1-SNAPSHOT</version>

  <packaging>jar</packaging>

  <name>providerImpl</name>

  <url>http://maven.apache.org</url>

  <properties>

    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

  </properties>

  <!--jetty启动插件-->

  <build>

  	<plugins>

  		<plugin>

  			<groupId>org.mortbay.jetty</groupId>

  			<artifactId>maven-jetty-plugin</artifactId>

  			<version>6.1.7</version>

  			<configuration>

  				<connectors>

  					<connector implementation="org.mortbay.jetty.nio.SelectChannelConnector">

  						<port>8888</port>

  						<maxIdleTime>30000</maxIdleTime>

  					</connector>

  				</connectors>

  				<webAppSourceDirectory>${project.build.directory}/${pom.artifactId}-${pom.version}</webAppSourceDirectory>

  				<contextPath>/</contextPath>

  			</configuration>

  		</plugin>

		<plugin>

		    <groupId>org.apache.maven.plugins</groupId>

		   <artifactId>maven-compiler-plugin</artifactId>

		    <version>2.3.2</version>

		   <configuration>

		       <source>1.6</source>

		        <target>1.6</target>

		        <encoding>UTF-8</encoding>

		    </configuration>

		</plugin>

  	</plugins>

  </build>

  <dependencies>

    <dependency>

      <groupId>junit</groupId>

      <artifactId>junit</artifactId>

      <version>3.8.1</version>

      <scope>test</scope>

    </dependency>

	<dependency>

    	<groupId>org.springframework</groupId>

    	<artifactId>spring-context</artifactId>

   		<version>4.0.2.RELEASE</version>

	</dependency>

    <dependency>

        <groupId>org.apache.zookeeper</groupId>

        <artifactId>zookeeper</artifactId>

        <version>3.4.6</version>

    </dependency>

    <dependency>

        <groupId>com.alibaba</groupId>

        <artifactId>dubbo</artifactId>

        <version>2.5.3</version>

    </dependency>

    <!-- 连接zookeeper的客户端 -->

    <dependency>

        <groupId>com.github.sgroschupf</groupId>

        <artifactId>zkclient</artifactId>

        <version>0.1</version>

    </dependency>

	</dependencies>

</project>

编写中间接口的实现，代码如下，注意这里通过注解的方式将此类标记为了spring服务：

此时要先配置依赖，不然实现类不能找到要实现的接口：

实现接口的代码如下：

package com.dubbo.provider.providerImpl;

import com.dubbo.provider.providerInterface.ITest;

/**

 * 实现中间接口

 * @author songzl

 *

 */

public class Test implements ITest{

	public void sayHello(String message) {

		System.out.println("service say:" +message);

	}

}

编写spring配置文件，注意需要引入dubbo的schema：

<?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:jee="http://www.springframework.org/schema/jee"

       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

       xmlns:context="http://www.springframework.org/schema/context"

       xmlns:util="http://www.springframework.org/schema/util"

       xmlns:configurator="http://cocoon.apache.org/schema/configurator"

       xmlns:avalon="http://cocoon.apache.org/schema/avalon"

       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd

                           http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd

                           http://cocoon.apache.org/schema/configurator http://cocoon.apache.org/schema/configurator/cocoon-configurator-1.0.1.xsd

                           http://code.alibabatech.com/schema/dubbo

                           http://code.alibabatech.com/schema/dubbo/dubbo.xsd

                           http://cocoon.apache.org/schema/avalon http://cocoon.apache.org/schema/avalon/cocoon-avalon-1.0.xsd" default-lazy-init="false">

  	<!--提供方应用名称信息，这个相当于起一个名字，我们dubbo管理页面比较清晰是哪个应用暴露出来的 -->

  	<dubbo:application name="dubbo_provider"></dubbo:application>

    <!--使用zookeeper注册中心暴露服务地址 -->

    <dubbo:registry address="zookeeper://127.0.0.1:2181"  check="false" subscribe="false" register=""></dubbo:registry>

    <!--要暴露的服务接口 -->

    <dubbo:service interface="com.dubbo.provider.providerInterface.ITest" ref="springservice"/>

    <bean id="springservice" class="com.dubbo.provider.providerImpl.Test"></bean>

</beans>

测试服务端提供者代码：

package foo;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**

 * 测试服务提供者

 * @author songzl

 *

 */

public class Demo {

	public static void main(String[] args) {

		ApplicationContext applicationContext = new ClassPathXmlApplicationContext(new String[] {"classpath*:applicationContext.xml" });

		while(true);

	}

}

消费者代码：
创建一个mavan项目，项目名字为dubboConsumer，并引入spring依赖、中间接口依赖、zookeeper依赖及dubbo依赖，这里和生产者是完 全相同的，不在重复pom.xml配置。

编写spring配置文件，注意需要引入dubbo的schema：

<?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:jee="http://www.springframework.org/schema/jee"

       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

       xmlns:context="http://www.springframework.org/schema/context"

       xmlns:util="http://www.springframework.org/schema/util"

       xmlns:configurator="http://cocoon.apache.org/schema/configurator"

       xmlns:avalon="http://cocoon.apache.org/schema/avalon"

       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd

                           http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd

                           http://cocoon.apache.org/schema/configurator http://cocoon.apache.org/schema/configurator/cocoon-configurator-1.0.1.xsd

                           http://code.alibabatech.com/schema/dubbo

                           http://code.alibabatech.com/schema/dubbo/dubbo.xsd

                           http://cocoon.apache.org/schema/avalon http://cocoon.apache.org/schema/avalon/cocoon-avalon-1.0.xsd" default-lazy-init="false">

  	<dubbo:application name="dubbo_consumer"></dubbo:application>

    <!--使用zookeeper注册中心暴露服务地址 -->

    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>

    <dubbo:protocol name="dubbo" port="20880" />

    <!--要引用的服务 -->

    <dubbo:reference interface="com.dubbo.provider.providerInterface.ITest" id="springservice" ></dubbo:reference>

</beans>

编写客户端测试代码：

package com.dubbo.provider.providerImpl.dubboConsumer;

import java.io.IOException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.dubbo.provider.providerInterface.ITest;

/**

 * 客户端测试

 * @author songzl

 *

 */

public class ClientDemo {

	public static void main(String[] args) {

		  // 这里注意spring配置文件的名字和路径

		  ApplicationContext applicationContext = new ClassPathXmlApplicationContext(

		                  new String[] { "classpath*:applicationContext.xml" });

		  ITest test = (ITest) applicationContext.getBean("springservice");

		  test.sayHello("我在这里消费！！！");

		  try {

			  System.in.read();

		  } catch (IOException e) {

		      e.printStackTrace();

		  }

	}

}

开始测试：
1.启动zookeeper。执行zookeeper目录下：bin/zkServer.cmd启动服务
2.启动dubbo服务。启动dubbo所在tomcat（详见本文开头），dubbo启动后，可通过http://127.0.0.1:8080/dubbo-admin来查看dubbo服务状态
3.启动生产者服务（clean package jetty:run）。运行生产者测试类Client.Java
4.启动消费者服务（clean package jetty:run）。运行消费者服务代码ClientDemo.java，此时可以在生产者的控制台看到服务被调用了。
此时整个dubbo测试已经完成。同时我们可以在dubbo的web端看到生产者、消费者的状态以及各个服务的调用情况。

在启动tomcat时总是报如下错误：

运行报错： Bean property 'URIType' is not writable or has an invalid，uritypewritable；

因为 jdk 是1.8的版本，和 dubbo-admin 存在兼容性问题，后来我本机调整为1.7的jdk问题解决，若小伙伴需要刨根问底，可以问下度娘，此处不再多说；

我的tomcat配置的端口是8081，方位地址是http://127.0.0.1:8081/dubbo-admin，成功访问首页

服务提供者界面：

服务消费者界面：

到此结束，环境搭建完毕，测试成功！