dubbo入门案例

windows安装zookeeper
把下载的zookeeper的文件解压到指定目录

D:\machine\zookeeper-3.3.6>


修改conf下增加一个zoo.cfg

内容如下：

# The number of milliseconds of each tick  心跳间隔 毫秒每次

tickTime=2000

# The number of ticks that the initial

# synchronization phase can take

initLimit=10

# The number of ticks that can pass between

# sending a request and getting anacknowledgement

syncLimit=5

# the directory where the snapshot isstored.  //镜像数据位置

dataDir=D:\\data\\zookeeper

#日志位置

dataLogDir=D:\\logs\\zookeeper

# the port at which the clients willconnect  客户端连接的端口

clientPort=2181

注：如果启动有报错提示cfg文件有错误，可以用zoo_sample.cfg内内容替代也是可以的



进入到bin目录，并且启动zkServer.cmd，这个脚本中会启动一个java进程

D:\machine\zookeeper-3.3.6>cd bin

D:\machine\zookeeper-3.3.6\bin>

D:\machine\zookeeper-3.3.6\bin >zkServer.cmd

启动后jps可以看到QuorumPeerMain的进程

D:\machine\zookeeper-3.3.6\bin >jps



启动客户端运行查看一下

D:\machine\zookeeper-3.3.6\bin>zkCli.cmd -server 127.0.0.1:2181



这个时候zookeeper已经安装成功了。

在dataDir=D:\\data\\zookeeper目录下
建立一个文本文件命名为myid，该文件内容为1


父项目用来存放公用的依赖包
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.chen</groupId>
  <artifactId>edu-common-parent</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>pom</packaging>
  <build/>
  <properties>
  	<spring.version>3.1.2.RELEASE</spring.version>
  </properties>
  <dependencies>
	  <!-- servlet -->
	  <dependency>
		<groupId>javax.servlet</groupId>
		<artifactId>javax.servlet-api</artifactId>
		<version>3.0.1</version>
	  </dependency>
	  <dependency>
		<groupId>jstl</groupId>
		<artifactId>jstl</artifactId>
		<version>1.2</version>
	  </dependency>
	  <dependency>
		<groupId>javax.servlet.jsp</groupId>
		<artifactId>jsp-api</artifactId>
		<version>2.1</version>
		<scope>provided</scope>
	  </dependency>
	  
	  <!-- spring -->
	  <dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-context-support</artifactId>
		<version>${spring.version}</version>
	 </dependency>
	  <dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-webmvc</artifactId>
		<version>${spring.version}</version>
	 </dependency>
	   	<dependency>
  		<groupId>org.springframework</groupId>
  		<artifactId>spring-orm</artifactId>
  		<version>${spring.version}</version>
  	 </dependency>
  	
  	 <!-- aop -->
	 <dependency>
		<groupId>org.aspectj</groupId>
		<artifactId>aspectjweaver</artifactId>
		<version>1.8.4</version>
	 </dependency>
	
	 <!-- mybatis-spring -->
	 <dependency>
		<groupId>org.mybatis</groupId>
		<artifactId>mybatis-spring</artifactId>
		<version>1.2.2</version>
	 </dependency>
	 
	 <!-- mybatis -->
	 <dependency>
		<groupId>org.mybatis</groupId>
		<artifactId>mybatis</artifactId>
		<version>3.2.8</version>
	 </dependency>
	 
	 <dependency>
        <groupId>asm</groupId>
        <artifactId>asm-commons</artifactId>
        <version>3.3.1</version>
    </dependency>
    <!-- 二级缓存ehcache -->
	<dependency>
		<groupId>net.sf.ehcache</groupId>
		<artifactId>ehcache</artifactId>
		<version>2.9.0</version>
	</dependency>
	
	<!-- dbcp -->
	<dependency>
		<groupId>commons-dbcp</groupId>
		<artifactId>commons-dbcp</artifactId>
		<version>1.4</version>
	</dependency>
	 
	<!-- mysql连接 -->
	<dependency>
		<groupId>mysql</groupId>
		<artifactId>mysql-connector-java</artifactId>
		<version>5.1.34</version>
	</dependency>
	
	<!-- slf4j-log4j -->
    <dependency>  
        <groupId>org.slf4j</groupId>  
        <artifactId>slf4j-api</artifactId>  
        <version>1.7.2</version>  
    </dependency>  
    <dependency>  
        <groupId>org.slf4j</groupId>  
        <artifactId>slf4j-log4j12</artifactId>  
        <version>1.7.2</version>  
    </dependency>  
	<dependency>
		<groupId>log4j</groupId>
		<artifactId>log4j</artifactId>
		<version>1.2.17</version>
	</dependency>
	
	<!-- jackson -->
  	<dependency>
  		<groupId>com.fasterxml.jackson.core</groupId>
  		<artifactId>jackson-databind</artifactId>
  		<version>2.2.3</version>
  	</dependency>
  	
	<dependency>
		<groupId>junit</groupId>
		<artifactId>junit</artifactId>
		<version>4.11</version>
	</dependency>
	
	<dependency>
		<groupId>com.alibaba</groupId>
		<artifactId>dubbo</artifactId>
		<version>2.3.0</version>
		<exclusions>  
            <exclusion>  
                <artifactId>spring</artifactId>  
                <groupId>org.springframework</groupId>  
                </exclusion>  
         </exclusions>  
	</dependency>
	<dependency>
		<groupId>org.apache.zookeeper</groupId>
		<artifactId>zookeeper</artifactId>
		<version>3.4.5</version>
	</dependency>
	<dependency>
		<groupId>com.101tec</groupId>
		<artifactId>zkclient</artifactId>
		<version>0.3</version>
	</dependency>
	<dependency>
		<groupId>org.jboss.netty</groupId>
		<artifactId>netty</artifactId>
		<version>3.2.5.Final</version>
	</dependency>
  </dependencies>
  
</project>

提供服务应用edu-service-user

dubbo配置文件applicationContext-dubbo-provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    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="edu-service-user" />
    
    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry protocol="zookeeper" address="132.126.1.98:2181"></dubbo:registry>	
    
    <!-- 用dubbo协议在20888端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20888" />
    
    <!-- 服务服务接口 -->
    <dubbo:service interface="com.chen.facade.UserFacade" ref="userFacadeImpl"/>
</beans>

暴露服务实现类UserFacadeImpl.java

package com.chen.facade.impl;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.chen.facade.UserFacade;
import com.chen.pojo.User;
import com.chen.service.UserService;

@Service
public class UserFacadeImpl implements UserFacade{
	
	@Autowired
	private UserService userService;
	
	public User getUser(Long id) {
		System.out.println("-===============================");
		return userService.getUser(id);
	}
}

公共接口类edu-facade-user
服务提供应用和消费者应用都要引用该应用

定义暴露服务类接口
UserFacade.java

package com.chen.facade;

import com.chen.pojo.User;

public interface UserFacade {
	public User getUser(Long id);
}

消费者应用edu-web-boss
dubbo配置文件applicationContext-dubbo-comsumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    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="edu-web-boss" />
    
    <!-- 注册中心地址 -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>	
    
    <!-- 服务服务接口 -->
    <dubbo:reference interface="com.chen.facade.UserFacade"  id="userFacade" check="false" />
</beans>

使用服务

package com.chen.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.chen.facade.UserFacade;
import com.chen.pojo.User;


@Controller
@RequestMapping("/user")
public class UserController {
	@Autowired
	private UserFacade userFacade;
	
	@ResponseBody
	@RequestMapping("hello")
	public String hello(){
		return "hello";
	}
	
	@RequestMapping("index")
	public String index(){
		return "index";
	}
	
	@ResponseBody
	@RequestMapping("getUser")
	public User getUser(){
		System.out.println("getuser1");
		User user =userFacade.getUser(1L);
		return user;
	}
	
}