大数据开发前置技能__Dubbox快速入门

1.Dubbox简介 1.1什么是SOA架构 SOA是Service-Oriented Architecture的首字母简称，它是一种支持面向服务的架构样式。从服务、基于服务开发和服务的结果来看，面向服务是一种思考方式。其实SOA架构更多应用于互联网项目开发。 为什么互联网项目会采用SOA架构呢？随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，迫切需一个治理系统确保架构有条不紊的演进。 我们看一下开发架构的演进过程。如下图：

 单一应用架构  当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的，数据访问框架(ORM) 是关键。  垂直应用架构  当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的 Web 框架(MVC) 是关键。  分布式服务架构  当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的 分布式服务框架(RPC) 是关键。  流动计算架构  当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。 此时，用于提高机器利用率的 资源调度和治理中心(SOA) 是关键。 我们今天所要讲解的Dubbox就是属于流动计算架构。 1.2 Dubbox简介 Dubbox 是一个分布式服务框架，其前身是阿里巴巴开源项目Dubbo ，被国内电商及互联网项目中使用，后期阿里巴巴停止了该项目的维护，当当网便在Dubbo基础上进行优化，并继续维护，为了与原有的Dubbo区分，故将其命名为Dubbox。

Dubbox 致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。简单的说，dubbox就是个服务框架，如果没有分布式的需求，其实是不需要用的，只有在分布式的时候，才有dubbox这样的分布式服务框架的需求，并且本质上是个服务调用的东东，说白了就是个远程服务调用的分布式框架。

节点角色说明：  Provider: 暴露服务的服务提供方。  Consumer: 调用远程服务的服务消费方。  Registry: 服务注册与发现的注册中心。  Monitor: 统计服务的调用次调和调用时间的监控中心。  Container: 服务运行容器。 调用关系说明：  0. 服务容器负责启动，加载，运行服务提供者。  1. 服务提供者在启动时，向注册中心注册自己提供的服务。  2. 服务消费者在启动时，向注册中心订阅自己所需的服务。  3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推 送变更数据给消费者。  4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用， 如果调用失败，再选另一台调用。  5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计 数据到监控中心。 1.3 Dubbox新特性（了解） Dubbox是从Dubbo演变过来的，保留了原有Dubbo的配置方式。这里我们介绍一下Dubbox新增的特性。 支持REST风格远程调用（HTTP JSON/XML)：基于非常成熟的JBoss RestEasy框架，在dubbox中实现了REST风格（HTTP JSON/XML）的远程调用，以显著简化企业内部的跨语言交互，同时显著简化企业对外的Open API、无线API甚至AJAX服务端等等的开发。事实上，这个REST调用也使得Dubbox可以对当今特别流行的“微服务”架构提供基础性支持。 另外，REST调用也达到了比较高的性能，在基准测试下，HTTP JSON与Dubbo 2.x默认的RPC协议（即TCP Hessian2二进制序列化）之间只有1.5倍左右的差距。 支持基于Kryo和FST的Java高效序列化实现：基于当今比较知名的Kryo和FST高性能序列化库，为Dubbo默认的RPC协议添加新的序列化实现，并优化调整了其序列化体系，比较显著的提高了Dubbo RPC的性能。 支持基于Jackson的JSON序列化：基于业界应用最广泛的Jackson序列化库，为Dubbo默认的RPC协议添加新的JSON序列化实现。 支持基于嵌入式Tomcat的HTTP remoting体系：基于嵌入式tomcat实现dubbo的HTTP remoting体系（即dubbo-remoting-http），用以逐步取代Dubbo中旧版本的嵌入式Jetty，可以显著的提高REST等的远程调用性能，并将Servlet API的支持从2.5升级到3.1。（注：除了REST，dubbo中的WebServices、Hessian、HTTP Invoker等协议都基于这个HTTP remoting体系）。 升级Spring：将dubbo中Spring由2.x升级到目前最常用的3.x版本，减少版本冲突带来的麻烦。 升级ZooKeeper客户端：将dubbo中的zookeeper客户端升级到最新的版本，以修正老版本中包含的bug。 支持完全基于Java代码的Dubbo配置：基于Spring的Java Config，实现完全无XML的纯Java代码方式来配置dubbo 调整Demo应用：暂时将dubbo的demo应用调整并改写以主要演示REST功能、Dubbo协议的新序列化方式、基于Java代码的Spring配置等等。 注：Dubbox和Dubbo 2.X是兼容的，没有改变Dubbo的任何已有的功能和配置方式（除了升级了Spring之类的版本）

2.Dubbox开发环境搭建 2.1注册中心Zookeeper 2.1.1 Zookeeper 介绍 官方推荐使用 zookeeper 注册中心。注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小。 Zookeeper 是 Apacahe Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为Dubbox 服务的注册中心，工业强度较高，可用于生产环境。 2.1.2 Zookeeper 在Linux系统的安装 安装步骤： 第一步：安装 jdk 第二步：把 zookeeper 的压缩包上传到 linux 系统。 Alt P 进入SFTP ，输入put d:zookeeper-3.4.6.tar.gz 上传 第三步：解压缩压缩包 tar-zxvf zookeeper-3.4.6.tar.gz 第四步：进入 zookeeper-3.4.6 目录，创建 data 文件夹。 mkdir data 第五步：进入conf目录 ，把 zoo_sample.cfg 改名为 zoo.cfg cd conf mv zoo_sample.cfg zoo.cfg 第六步：打开zoo.cfg , 修改 data 属性：dataDir=/root/zookeeper-3.4.6/data 2.1.3 Zookeeper 服务启动 进入bin目录，启动服务输入命令 ./zkServer.sh start 输出以下内容表示启动成功

关闭服务输入命令 ./zkServer.sh stop 输出以下提示信息

查看状态： ./zkServer.sh status 如果启动状态，提示

如果未启动状态，提示：

2.2 Dubbox本地 JAR包部署与安装 Dubbox的jar包并没有部署到Maven的中央仓库中，大家在Maven的中央仓库中可以查找到Dubbo的最终版本是2.5.3 , 阿里巴巴解散了Dubbo团队后由当当网继续维护此项目，并改名为 Dubbox ,坐标不变，版本变更了，但是并没有提交到中央仓库。 我们现在需要手动将Dubbox的jar包安装到我的本地仓库中。 先将dubbo-2.8.4.jar包放到d:setup, 然后输入命令 mvn install:install-file -Dfile=d:setupdubbo-2.8.4.jar -DgroupId=com.alibaba -DartifactId=dubbo -Dversion=2.8.4 -Dpackaging=jar 2.3配置离线约束 地址： 链接 3.Dubbox入门 3.1配置方式

3.1.1框架搭建 （1）创建Maven工程（POM） dubboxdemo-parent ，在pom.xml中引入依赖

代码语言：javascript复制

<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>cn.itcast.dubboxdemo</groupId>
  <artifactId>dubboxdemo-parent</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>pom</packaging>  
    <properties>		
		<spring.version>4.2.4.RELEASE</spring.version>
   </properties>    
	<dependencies>
		<!-- Spring -->
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-beans</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-jdbc</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-aspects</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jms</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context-support</artifactId>
			<version>${spring.version}</version>
		</dependency>	
		<!-- dubbo相关 -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.8.4</version>			
		</dependency>
		<dependency>
			<groupId>org.apache.zookeeper</groupId>
			<artifactId>zookeeper</artifactId>
			<version>3.4.6</version>
		</dependency>
		<dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.1</version>
		</dependency>
		<dependency>
			<groupId>javassist</groupId>
			<artifactId>javassist</artifactId>
			<version>3.11.0.GA</version>
		</dependency>		
	</dependencies>
   <build>  
	  <plugins>
	      <plugin>  
	          <groupId>org.apache.maven.plugins</groupId>  
	          <artifactId>maven-compiler-plugin</artifactId>  
	          <version>2.3.2</version>  
	          <configuration>  
	              <source>1.7</source>  
	              <target>1.7</target>  
	          </configuration>  
	      </plugin>  	      
	  </plugins>  
    </build> 
</project>
（2）创建Maven模块（JAR）  dubboxdemo-interface  

（3）创建Maven模块（WAR） dubboxdemo-service  
     在pom.xml 中，添加tomcat7插件
 <build>  
	  <plugins>
	      <plugin>
				<groupId>org.apache.tomcat.maven</groupId>
				<artifactId>tomcat7-maven-plugin</artifactId>
				<configuration>
					<!-- 指定端口 -->
					<port>8081</port>
					<!-- 请求路径 -->
					<path>/</path>
				</configuration>
	  	  </plugin>
	  </plugins>  
    </build>

代码语言：javascript复制

 在webapp下创建WEB-INF/web.xml 

代码语言：javascript复制

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns="http://java.sun.com/xml/ns/javaee"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
	version="2.5">	
	<!-- 加载spring容器 -->
	<context-param>
		<param-name>contextConfigLocation</param-name>
		<param-value>classpath:applicationContext*.xml</param-value>
	</context-param>
	<listener>		<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
	</listener>	
</web-app>

代码语言：javascript复制

（4）创建Maven模块（WAR） dubboxdemo-web   

在pom.xml 中，添加tomcat7插件

代码语言：javascript复制

```bash
 <build>  
	  <plugins>
	      <plugin>
				<groupId>org.apache.tomcat.maven</groupId>
				<artifactId>tomcat7-maven-plugin</artifactId>
				<configuration>
					<!-- 指定端口 -->
					<port>8082</port>
					<!-- 请求路径 -->
					<path>/</path>
				</configuration>
	  	  </plugin>
	  </plugins>  
    </build>
 在webapp下创建WEB-INF/web.xml 
 
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns="http://java.sun.com/xml/ns/javaee"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
	version="2.5">	
   <!-- 解决post乱码 -->
	<filter>
		<filter-name>CharacterEncodingFilter</filter-name>
		<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
		<init-param>
			<param-name>encoding</param-name>
			<param-value>utf-8</param-value>
		</init-param>
		<init-param>  
            <param-name>forceEncoding</param-name>  
            <param-value>true</param-value>  
        </init-param>  
	</filter>
	<filter-mapping>
		<filter-name>CharacterEncodingFilter</filter-name>
		<url-pattern>/*</url-pattern>
	</filter-mapping>	
  <servlet>
  	<servlet-name>springmvc</servlet-name>
  	<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  	<!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载-->
  	<init-param>
  		<param-name>contextConfigLocation</param-name>
  		<param-value>classpath:springmvc.xml</param-value>
  	</init-param>
  </servlet>  
  <servlet-mapping>
  	<servlet-name>springmvc</servlet-name>
  	<url-pattern>*.action</url-pattern>
  </servlet-mapping>
</web-app>

代码语言：javascript复制

（5）构建依赖，让dubboxdemo-service 模块和dubboxdemo-web模块都依赖dubboxdemo-interface模块

3.1.2服务提供者
开发步骤：
（1）创建业务接口
在dubboxdemo-service 模块创建包cn.itcast.dubboxdemo.service，用于存放业务接口，创建接口UserService 

```bash
package cn.itcast.dubboxdemo.service;
/**
 * 业务接口
 * @author Administrator
 *
 */
public interface UserService {	
	public String getName();	
}
（2）创建业务实现类
创建包cn.itcast.dubboxdemo.service.impl ，用于存放业务实现类。创建业务实现类：
package cn.itcast.dubboxdemo.service.impl;
import org.springframework.stereotype.Service;
import cn.itcast.dubbodemo.service.UserService;
@Service
public class UserServiceImpl implements UserService {
	public String getName() {		
		return "itheima";
	}
}

（3）编写配置文件 在src/main/resources下创建applicationContext-service.xml ,内容如下： <context:component-scan base-package=“cn.itcast.dubboxdemo.service.impl” /> <dubbo:application name=“dubboxdemo-service”/> <dubbo:registry address=“zookeeper://192.168.17.129:2181”/> <dubbo:service protocol=“dubbo” timeout=“2000” connections=“100” interface =“cn.itcast.dubboxdemo.service.UserService” ref=“userServiceImpl” /> （4）测试运行 tomcat7:run 3.1.3服务消费者 开发步骤： （1）编写Controller

代码语言：javascript复制

package cn.itcast.dubboxdemo.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 cn.itcast.dubbodemo.service.UserService;
@Controller
@RequestMapping("/user")
public class UserController {
	@Autowired
	private UserService userService;	
	@RequestMapping("/name")
	@ResponseBody
	public String showName(){
		return userService.getName();
	}		
}

（2）编写spring配置文件 在src/main/resources下创建springmvc.xml

代码语言：javascript复制

<context:component-scan base-package="cn.itcast.dubboxdemo.controller" />
<mvc:annotation-driven >
	<mvc:message-converters register-defaults="false">
		<bean class="org.springframework.http.converter.StringHttpMessageConverter">  
			<constructor-arg value="UTF-8" />
		</bean>  
	</mvc:message-converters>	
</mvc:annotation-driven>	
<!-- 引用dubbo 服务 -->
<dubbo:application name="dubboxdemo-web" />
<dubbo:registry address="zookeeper://192.168.17.129:2181"/>
<dubbo:reference interface="cn.itcast.dubboxdemo.service.UserService" id="userService" />

（3）测试运行 tomcat7:run 在浏览器输入http://localhost:8082/user/name.action，查看浏览器输出结果 3.2注解方式 3.2.1框架搭建 与配置方式相同（步骤略） 3.2.2服务提供者 （1）创建包cn.itcast.dubboxdemo.service.impl ，用于存放业务实现类。创建业务实现类：

代码语言：javascript复制

package cn.itcast.dubboxdemo.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import cn.itcast.dubboxdemo.service.UserService;
@Service
public class UserServiceImpl implements UserService {
	public String getName() {		
		return "itcast";
	}
}

注意：Service注解与原来不同，需要引入com.alibaba包下的 （2）在src/main/resources下创建applicationContext-service.xml ,内容如下： <dubbo:annotation package=“cn.itcast.dubboxdemo.service” /> <dubbo:application name=“dubboxdemo-service”/> <dubbo:registry address=“zookeeper://192.168.17.129:2181”/> 注意：dubbo:annotation用于扫描@Service注解，不用编写服务发布的配置。 3.2.3服务消费者 （1）编写Controller

代码语言：javascript复制

package cn.itcast.dubboxdemo.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 cn.itcast.dubbodemo.service.UserService;
@Controller
@RequestMapping("/user")
public class UserController {
	@Autowired
	private UserService userService;	
	@RequestMapping("/name")
	@ResponseBody
	public String showName(){
		return userService.getName();
	}		
}

（2）编写spring配置文件 在src/main/resources下创建springmvc.xml

代码语言：javascript复制

	<!-- 引用dubbo 服务 -->
 <dubbo:annotation package="cn.itcast.dubboxdemo.controller" />  	
<dubbo:application name="dubboxdemo-web" />
<dubbo:registry address="zookeeper://192.168.17.129:2181"/>

（3）测试运行 tomcat7:run 在浏览器输入http://localhost:8082/user/name.action，查看浏览器输出结果

dubbo 文件存储 http rpc xml

0 人点赞