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

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

1、准备

zookeeper：直接去官方网站下载即可（以下是：zookeeper-3.4.6），下载后解压，不需要改任何配置即可使用，或者改配置（..zookeeper-3.4.6confzoo.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，成功访问首页

服务提供者界面：

服务消费者界面：

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