前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >大数据开发前置技能__Dubbox快速入门

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

作者头像
Maynor
发布2021-04-09 15:06:44
2720
发布2021-04-09 15:06:44
举报

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:\setup\dubbo-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,查看浏览器输出结果

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2021-03-12 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
文件存储
文件存储(Cloud File Storage,CFS)为您提供安全可靠、可扩展的共享文件存储服务。文件存储可与腾讯云服务器、容器服务、批量计算等服务搭配使用,为多个计算节点提供容量和性能可弹性扩展的高性能共享存储。腾讯云文件存储的管理界面简单、易使用,可实现对现有应用的无缝集成;按实际用量付费,为您节约成本,简化 IT 运维工作。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档