项目-好客租房-前后端系统搭建（1）

本是古典何须时尚 2023-10-12 14:15 31阅读 0赞

# 1.简介 #

## 1)内容 ##

《好客租房项目》采用SOA架构思想进行设计，采用SpringBoot、SpringMVC、Mybaits、Dubbo等技术框架实  
现，好客租房是直接促成房东与租户对接的生活服务平台，他包含房东发布房源，租户多维度寻找房源，智能匹配  
房源，近期行情查询等功能。减少中间环节产生的费用，提高房东与租户匹配的成功率。  
《好客租房项目》融合了RPC、大数据等相技术，如SpringBoot、SpringMVC、Mybaits、Dubbo、React.js、  
GraphQL、RocketMQ、Flume、ELK等技术，实现了移动web应用、微信小程序应用、后台管理应用等功能。

## 2)技术架构 ##

后端架构：SpringBoot+StringMVC+Dubbo+Mybatis+ELK+区块链  
前端架构：React.js+html5+百度地图+微信小程序

## 3)系统架构 ##

![在这里插入图片描述][bbed65dcfa444c388039df79140e28bb.png]

# 2.后台系统搭建 #

后台系统采用的是前后端分离开发模式，前端使用Ant Design Pro系统作为模板进行改造，后端采用的是  
SpringBoot+StringMVC+Dubbo+Mybatis的架构进行开发。

## 1)前端搭建 ##

![在这里插入图片描述][cb318ba4242f487888ceae9d2c647050.png]

### (1)创建工程 ###

![在这里插入图片描述][af8d4bcfa2a64065bf772b27d774c5e6.png]  
第三步，执行命令导入相关的依赖：  
![在这里插入图片描述][3abcf5da4e4f423ca08223718e295426.png]

### (2)修改logo以及版权信息 ###

将logo部分修改为：  
![在这里插入图片描述][2162d73d8999430183a2b1b6919bcbde.png]

全局的布局文件在这：  
![在这里插入图片描述][8b954929c3a24e44b0603466c74f90e5.png]  
打开看代码，发现，左侧的菜单是自定义组件：

{
        isTop && !isMobile ? null : (
    	<SiderMenu
    		logo={
        logo}
    		Authorized={
        Authorized}
    		theme={
        navTheme}
    		onCollapse={
        this.handleMenuCollapse}
    		menuData={
        menuData}
    		isMobile={
        isMobile}
    		{
        ...this.props}
    	/>
    )}
    //导入
    import SiderMenu from '@/components/SiderMenu';

打开/components/SiderMenu文件：  
![在这里插入图片描述][3073291f6b0f4251bff0fe15b1b485cd.png]  
在Footer.js文件中修改版权信息：

import React, {
         Fragment } from 'react';
    import {
         Layout, Icon } from 'antd';
    import GlobalFooter from '@/components/GlobalFooter';
    const {
         Footer } = Layout;
    const FooterView = () => (
    	<Footer style={
        {
         padding: 0 }}>
    	<GlobalFooter
    	copyright={
        
    	<Fragment>
    	Copyright <Icon type="copyright" /> 2018 黑马程序员 博学谷 出品
    	</Fragment>
    	}
    	/>
    	</Footer>
    );
    export default FooterView;

### (3)编写左侧菜单 ###

根据需求，修改左侧的菜单：

{
         //房源管理
    path: '/house',
    name: 'house',
    icon: 'home',
    routes: [
    {
        
    path: '/house/resource',
    name: 'resource',
    component: './haoke/House/Resource'
    },
    {
        
    path: '/house/addResource',
    name: 'addResource',
    component: './haoke/House/AddResource'
    },
    {
        
    path: '/house/kanfang',
    name: 'kanfang',
    component: './haoke/House/KanFang'
    },
    {
        
    path: '/house/zufang',
    name: 'zufang',
    component: './haoke/House/ZuFang'
    }
    ]
    },
    {
         //房东管理
    path: '/fangdong',
    name: 'fangdong',
    icon: 'key',
    routes: [
    {
        
    path: '/fangdong/list',
    name: 'list',
    component: './haoke/FangDong/List'
    }
    ]
    },
    {
         //用户管理
    path: '/users',
    name: 'users',
    icon: 'user',
    routes: [
    {
        
    path: '/users/list',
    name: 'list',
    component: './haoke/Users/List'
    }
    ]
    },
    {
         //合约管理
    path: '/heyue',
    name: 'heyue',
    icon: 'file-text',
    routes: [
    {
        
    path: '/heyue/list',
    name: 'list',
    component: './haoke/HeYue/List'
    }
    ]
    },
    {
         //资讯管理
    path: '/news',
    name: 'news',
    icon: 'message',
    routes: [
    {
        
    path: '/news/list',
    name: 'list',
    component: './haoke/News/List'
    }
    ]
    },
    {
         //问答管理
    path: '/qa',
    name: 'qa',
    icon: 'question-circle',
    routes: [
    {
        
    path: '/news/list',
    name: 'list',
    component: './haoke/News/List'
    }
    ]
    },
    {
         //财务管理
    path: '/finance',
    name: 'finance',
    icon: 'money-collect',
    routes: [
    {
        
    path: '/finance/bill',
    name: 'bill',
    component: './haoke/Finance/Bill'
    },
    {
        
    path: '/finance/tixian',
    name: 'tixian',
    component: './haoke/Finance/TiXian'
    }
    ]
    },
    {
         //系统管理
    path: '/system',
    name: 'system',
    icon: 'laptop',
    routes: [
    {
        
    path: '/system/interface',
    name: 'interface',
    component: './haoke/System/Interface'
    },
    {
        
    path: '/system/dict',
    name: 'dict',
    component: './haoke/System/Dict'
    },
    {
        
    path: '/system/contract',
    name: 'contract',
    component: './haoke/System/Contract'
    }
    ]
    },

在src/pages目录下创建haoke文件夹，项目中的页面代码均放在此目录中：  
![在这里插入图片描述][b007b096dc5640c897d3022de159738e.png]  
修改，进入系统后，默认打开房源管理页面：  
![在这里插入图片描述][644464768e5d422f8564923281f126d4.png]

## 2)新增房源 ##

#### (1)数据结构 ####

![在这里插入图片描述][e02f901069754c5f8a97c067d4d4db29.png]  
![在这里插入图片描述][30d06a7b5b994f6b8dea418043d494bf.png]

#### (2)编写页面 ####

根据需求文档以及数据结构，进行编写页面。  
![在这里插入图片描述][7b7d2856d5654158b32155fcbab75f9d.png]

##### form组件 #####

[form组件官方文档][form]：https://ant.design/components/form-cn/

在页面中，通过@Form.create()对页面进行了包装，包装之后，会在this.props中增加form对象，该对象将包含有  
丰富的功能，如下：  
![在这里插入图片描述][543d5c5763da44b18822b9778bb84d2a.png]  
在from表单中，需要通过getFieldDecorator（表单数据双向绑定）方法进行包装注册，才能获取到其值。  
用法：

<FormItem {
        ...formItemLayout} label="支付方式">
    {
        getFieldDecorator('paymentMethod',
    {
        initialValue:'1',rules:[{
         required: true, message:"此项为必填项" }]})
    (
    <Select style={
        {
         width: '50%' }}>
    <Option value="1">付一押一</Option>
    <Option value="2">付三押一</Option>
    <Option value="3">付六押一</Option>
    <Option value="4">年付押一</Option>
    <Option value="5">其它</Option>
    </Select>
    )}
    </FormItem>

> 经过 getFieldDecorator 包装的控件，表单控件会自动添加 value （或 valuePropName 指定的其他属  
> 性） onChange （或 trigger 指定的其他属性），数据同步将被 Form 接管，这会导致以下结果：

1.  你不再需要也不应该用 onChange 来做同步，但还是可以继续监听 onChange 等事件。
2.  你不能用控件的 value defaultValue 等属性来设置表单域的值，默认值可以用  
    getFieldDecorator 里的 initialValue 。
3.  你不应该用 setState ，可以使用 this.props.form.setFieldsValue 来动态改变表单值。  
    特别注意
    
    1.  getFieldDecorator 不能用于装饰纯函数组件。
    2.  如果使用的是 react@<15.3.0 ，则 getFieldDecorator 调用不能位于纯函数组件中: https://githu  
        b.com/facebook/react/pull/6534

校验：  
在getFieldDecorator的参数中可以增加校验规则：

{
        initialValue:'1',rules:[{
         required: true, message:"1 此项为必填项" }]})

其它的校验规则如下：  
![在这里插入图片描述][f71b89cca6484ae7b54e5c3df9716a57.png]

##### 表单提交 #####

表单的提交通过submit按钮完成，通过onSubmit方法进行拦截处理。  
![在这里插入图片描述][68612a7d96a04791b37ed86066f10355.png]  
提交方法：

handleSubmit = e => {
        
    	const {
         dispatch, form } = this.props;
    	e.preventDefault();
    	form.validateFieldsAndScroll((err, values) => {
        
    		if (!err) {
        
    		if(values.facilities){
        
    		values.facilities = values.facilities.join(",");
    		}
    		if(values.floor_1 && values.floor_2){
        
    		values.floor = values.floor_1 + "/" + values.floor_2;
    		}
    		values.houseType = values.houseType_1 + "室" + values.houseType_2 +
    		"厅"
    		+ values.houseType_3 + "卫" + values.houseType_4 +
    		"厨"
    		+ values.houseType_2 + "阳台";
    		delete values.floor_1;
    		delete values.floor_2;
    		delete values.houseType_1;
    		delete values.houseType_2;
    		delete values.houseType_3;
    		delete values.houseType_4;
    		delete values.houseType_5;
    		dispatch({
        
    		type: 'form/submitRegularForm',
    		payload: values,
    		});
    	}
    	});
    };

通过form.validateFieldsAndScroll()对表单进行校验，通过values获取表单中输入的值。通过dispatch()调用  
model中定义的方法。

##### 自动完成 #####

[文档][Link 1]：https://ant.design/components/auto-complete-cn/  
楼盘的数据通过自动完成实现：

![在这里插入图片描述][24da0db2731d43ef93bf61e14a96bfb8.png]  
实现代码：

//数据
    const estateMap = new Map([
    	['中远两湾城','1001|上海市,上海市,普陀区,远景路97弄'],
    	['上海康城','1002|上海市,上海市,闵行区,莘松路958弄'],
    	['保利西子湾','1003|上海市,上海市,松江区,广富林路1188弄'],
    	['万科城市花园','1004|上海市,上海市,闵行区,七莘路3333弄2区-15区'],
    	['上海阳城','1005|上海市,上海市,闵行区,罗锦路888弄']
    	]);
    	<AutoComplete
    	style={
        {
         width: '100%' }}
    	dataSource={
        this.state.estateDataSource}
    	placeholder="搜索楼盘"
    	onSelect={
        (value, option)=>{
        
    	let v = estateMap.get(value);
    	this.setState({
        
    	estateAddress: v.substring(v.indexOf('|')+1),
    	estateId : v.substring(0,v.indexOf('|'))
    	});
    	}}
    	onSearch={
        this.handleSearch}
    	filterOption={
        (inputValue, option) =>
    	option.props.children.toUpperCase().indexOf(inputValue.toUpperCase()) !== -1}
    	/>
    	// 通过onSearch进行动态设置数据源，这里使用的数据是静态数据
    	handleSearch = (value)=>{
        
    	let arr = new Array();
    	if(value.length > 0 ){
        
    	estateMap.forEach((v, k) => {
        
    	if(k.startsWith(value)){
        
    	arr.push(k);
    	}
    	});
    	}
    	this.setState({
        
    	estateDataSource: arr
    	});
    	} ;
    	// 通过onSelect设置，选择中楼盘数据后，在楼盘地址中填写地址数据
    	onSelect={
        (value, option)=>{
        
    	let v = estateMap.get(value);
    	this.setState({
        
    	estateAddress: v.substring(v.indexOf('|')+1),
    	estateId : v.substring(0,v.indexOf('|'))
    	});
    }}

##### 图片上传 #####

图片上传通过自定义组件PicturesWall完成，在PicturesWall中，通过Upload组件实现  
效果：  
![在这里插入图片描述][fee8edfa43464c0fa49e2f0c10d6adcd.png]  
![在这里插入图片描述][4ff56e8432ee4b1aaaaaf0a16fcc8bdb.png]  
在代码实现中，需要解决的问题是：父组件如何获取子组件中的数据。  
解决思路：父组件通过属性的方式进行引用子组件，在bind方法中改变this的引用为父组件，在子组件中，通过  
this.props获取传入的函数，进行调用，即可把数据传递到父组件中。  
父组件：  
![在这里插入图片描述][af519f50d6704a4f9d41a3f260ea9e8a.png]  
子组件：  
![在这里插入图片描述][51dd1bc8b3f74a3da99d4ff2dc420830.png]  
父组件中的方法，获取数据：  
![在这里插入图片描述][8d097200131b42fe8f5dc2440522e9c8.png]

# 3.后台系统服务 #

前端系统已经搭建完成，需要后台系统为其提供接口服务。如：新增房源、房源列表、房东列表等。

## 1)架构 ##

![在这里插入图片描述][25e6cb88406a4cbaa5da053d83a281a1.png]  
说明：  
在后台服务的架构中，采用了RPC+微服务的架构思想，RPC采用dubbo框架作为服务治理框架，对外接口采用  
RESTful和GraphQL接口方式。

## 2) dubbo快速入门 ##

### (1)什么是dubbo? ###

Apache Dubbo™ (incubating)是一款高性能Java RPC框架。[官网][Link 2]：http://dubbo.apache.org/zh-cn/index.html  
![在这里插入图片描述][8c5d02fee8994d7caad6fe1d9803c36f.png]

> 早期的介绍：  
> DUBBO是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，是阿里巴巴SOA服务  
> 化治理方案的核心框架，每天为2,000+个服务提供3,000,000,000+次访问量支持，并被广泛应用于阿里巴巴  
> 集团的各成员站点。  
> Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个  
> 层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo采用的是一种非常简单的模型，  
> 要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服  
> 务消费方（Consumer）两个角色。关于注册中心、协议支持、服务监控等内容。  
> 什么是RPC？  
> ![在这里插入图片描述][3e2e646a62ac4eb59a9bd49cb1ae51c4.png]

### (2)框架说明 ###

#### 背景 ####

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架  
构势在必行，亟需一个治理系统确保架构有条不紊的演进。  
![在这里插入图片描述][80569749063b42d8b880187f9bebde54.png]

> 单一应用架构  
> 当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架(ORM)是关键。  
> 垂直应用架构  
> 当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的Web框架(MVC)是关键。  
> 分布式服务架构  
> 当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中  
> 心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。  
> 流动计算架构  
> 当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心(SOA)是关键。

#### 需求 ####

![在这里插入图片描述][87fa4f146c3141449824df0860057ebb.png]  
在大规模服务化之前，应用可能只是通过 RMI 或 Hessian 等工具，简单的暴露和引用远程服务，通过配置服务的  
URL地址进行调用，通过 F5 等硬件进行负载均衡。  
`当服务越来越多时，服务 URL 配置管理变得非常困难，F5 硬件负载均衡器的单点压力也越来越大。` 此时需要一个服务注册中心，动态的注册和发现服务，使服务的位置透明。并通过在消费方获取服务提供方地址列表，实现软负载均衡和 Failover，降低对 F5 硬件负载均衡器的依赖，也能减少部分成本。  
`当进一步发展，服务间依赖关系变得错踪复杂，甚至分不清哪个应用要在哪个应用之前启动，架构师都不能完整的描述应用的架构关系。` 这时，需要自动画出应用间的依赖关系图，以帮助架构师理清理关系。  
`接着，服务的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？` 为了解决这些问题，第一步，要将服务现在每天的调用量，响应时间，都统计出来，作为容量规划的参考指标。其次，要可以动态调整权重，在线上，将某台机器的权重一直加大，并在加大的过程中记录响应时间的变化，直到响应时间到达阈值，记录此时的访问量，再以此访问量乘以机器数反推总容量。  
以上是 Dubbo 最基本的几个需求。

#### 架构 ####

![在这里插入图片描述][a088b1eba2da489788248083849df765.png]

> 节点角色说明

![在这里插入图片描述][18dbf17602754d58ac5bd49194276ee5.png]

> 调用关系说明

1.  服务容器负责启动，加载，运行服务提供者。
2.  服务提供者在启动时，向注册中心注册自己提供的服务。
3.  服务消费者在启动时，向注册中心订阅自己所需的服务。
4.  注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
5.  服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另  
    一台调用。
6.  服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。  
    Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。  
    [更多介绍参见：][Link 3]http://dubbo.apache.org/zh-cn/docs/user/preface/architecture.html

#### 注册中心 ####

dubbo支持多种注册中心，推荐使用ZooKeeper。http://dubbo.apache.org/zh-cn/docs/user/references/registr  
y/introduction.html  
![在这里插入图片描述][2cda28eca2214795bd3a33fc0750bfd3.png]  
Zookeeper 是 Apacahe Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo 服务的注  
册中心，工业强度较高，可用于生产环境，并推荐使用。  
![在这里插入图片描述][df2504f5274f4094a515746496b7d559.png]  
流程说明：

*  服务提供者启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的 URL 地址
 *  服务消费者启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者 URL 地址。并向  
    /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址
 *  监控中心启动时: 订阅  
    /dubbo/com.foo.BarService 目录下的所有提供者和消费者 URL 地址。

支持以下功能：

*  当提供者出现断电等异常停机时，注册中心能自动删除提供者信息
 *  当注册中心重启时，能自动恢复注册数据，以及订阅请求
 *  当会话过期时，能自动恢复注册数据，以及订阅请求
 *  当设置 <dubbo:registry check=“false” /> 时，记录失败注册和订阅请求，后台定时重试
 *  可通过 <dubbo:registry username=“admin” password=“1234” /> 设置 zookeeper 登录信息
 *  可通过 <dubbo:registry group=“dubbo” /> 设置 zookeeper 的根节点，不设置将使用无根树
 *  支持 \* 号通配符 <dubbo:reference group=“*" version="*” /> ，可订阅服务的所有分组和所有版本的提供者  
    在本套课程中，使用docker容器化技术进行部署和开发，如果对docker不熟悉的同学可以采用传统的部署方式，  
    效果是一样的。  
    之所以采用docker部署的形式，是考虑到微服务节点的部署，以及后续的集群扩展的便捷性。

> 环境：ubuntu-16.04.3 + docker 17.03.2-ce  
> 参考资料中的《VMware Workstation 中安装 Ubuntu16.04 虚拟机.docx》文档进行安装，统一环境。

环境：ubuntu-16.04.3 + docker 17.03.2-ce
    参考资料中的《VMware Workstation 中安装 Ubuntu16.04 虚拟机.docx》文档进行安装，统一环境。

![在这里插入图片描述][c1287c51904a4df9a9f9f2c50436ca9d.png]

## 3 )编写服务提供方 ##

### (1)创建工程 ###

![在这里插入图片描述][903e475738db4c7ebf9e55a17cc61d06.png]  
![在这里插入图片描述][3750ffc5a94e482094aeaf9da8a80435.png]  
![在这里插入图片描述][b15a13b064334010bb5ef9d37f37087e.png]

### (2)导入依赖 ###

在itcast-dubbo工程中编写pom.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
    <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>
    	
    	<parent>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-parent</artifactId>
    	<version>2.1.0.RELEASE</version>
    	</parent>
    	<groupId>cn.itcast.dubbo</groupId>
    	<artifactId>itcast-dubbo</artifactId>
    	<packaging>pom</packaging>
    	<version>1.0-SNAPSHOT</version>
    	<modules>
    	<module>itcast-dubbo-service</module
    	</modules>
    	<dependencies>
    	
    	<dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-test</artifactId>
    	<scope>test</scope>
    	</dependency>
    	
    	<dependency>
    	<groupId>com.alibaba.boot</groupId>
    	<artifactId>dubbo-spring-boot-starter</artifactId>
    	<version>0.2.0</version>
    	</dependency>
    	
    	<dependency>
    	<groupId>com.alibaba</groupId>
    	<artifactId>dubbo</artifactId>
    	<version>2.6.4</version>
    	</dependency>
    	</dependencies>
    	<build>
    	<plugins>
    	
    	<plugin>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-maven-plugin</artifactId>
    	</plugin>
    	</plugins>
    	</build>
    </project>

itcast-dubbo-service依赖：

### (3)创建User对象 ###

package cn.itcast.dubbo.pojo;
    // 使用dubbo要求传输的对象必须实现序列化接口
    public class User implements java.io.Serializable {
        
    	private static final long serialVersionUID = -7341603933521593227L;
    	private Long id;
    	private String username;
    	private String password;
    	private Integer age;
    	public Long getId() {
        
    		return id;
    	}
    	public void setId(Long id) {
        
    		this.id = id;
    	}
    	public String getUsername() {
        
    		return username;
    	}
    	public void setUsername(String username) {
        
    		this.username = username;
    	}
    	public String getPassword() {
        
    		return password;
    	}
    	public void setPassword(String password) {
        
    		this.password = password;
    	}
    	public Integer getAge() {
        
    		return age;
    	}
    	public void setAge(Integer age) {
        
    		this.age = age;
    	}
    }

### (4)创建UserService（接口）提供查询服务 ###

package cn.itcast.dubbo.service;
    import cn.itcast.dubbo.pojo.User;
    import java.util.List;
    public interface UserService {
        
    /**
    * 查询所有的用户数据
    *
    * @return
    */
    	List<User> queryAll();
    }

### (5)创建UserServiceImpl实现类 ###

package cn.itcast.dubbo.service.impl;
    import java.util.ArrayList;
    import java.util.List;
    import cn.itcast.dubbo.pojo.User;
    import cn.itcast.dubbo.service.UserService;
    import com.alibaba.dubbo.config.annotation.Service;
    @Service(version = "${dubbo.service.version}") //声明这是一个dubbo服务
    public class UserServiceImpl implements UserService {
        
    /**
    * 实现查询，这里做模拟实现，不做具体的数据库查询
    */
    public List<User> queryAll() {
        
    	List<User> list = new ArrayList<User>();
    	for (int i = 0; i < 10; i++) {
        
    	User user = new User();
    	user.setAge(10 + i);
    	user.setId(Long.valueOf(i + 1));
    	user.setPassword("123456");
    	user.setUsername("username_" + i);
    	list.add(user);
    	}
    	return list;
    	}
    }

### (6)编写application.properties配置文件 ###

# Spring boot application
    spring.application.name = itcast-dubbo-service
    server.port = 9090
    # Service version
    dubbo.service.version = 1.0.0
    # 服务的扫描包
    dubbo.scan.basePackages = cn.itcast.dubbo.service
    # 应用名称
    dubbo.application.name = dubbo-provider-demo
    # 协议以及端口
    dubbo.protocol.name = dubbo
    dubbo.protocol.port = 20880
    # zk注册中心
    dubbo.registry.address = zookeeper://172.16.55.185:2181
    dubbo.registry.client = zkclient

### (7)编写启动类 ###

package cn.itcast.dubbo;
    import org.springframework.boot.WebApplicationType;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.builder.SpringApplicationBuilder;
    @SpringBootApplication
    public class DubboProvider {
        
    	public static void main(String[] args) {
        
    		new SpringApplicationBuilder(DubboProvider.class)
    		.web(WebApplicationType.NONE) // 非 Web 应用
    		.run(args);
    	}
    }

![在这里插入图片描述][705189889cec44b0bd9efb89e55e49c2.png]

## 4)编写服务消费方 ##

### (1)创建工程 ###

![在这里插入图片描述][c0a2cbf0c8d64499ab442af33c665ced.png]

### (2)导入依赖 ###

<?xml version="1.0" encoding="UTF-8"?>
    <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">
    	<parent>
    	<artifactId>itcast-dubbo</artifactId>
    	<groupId>cn.itcast.dubbo</groupId>
    	<version>1.0-SNAPSHOT</version>
    	</parent>
    	<modelVersion>4.0.0</modelVersion>
    	<artifactId>itcast-dubbo-consumer</artifactId>
    	<dependencies>
    	
    	<dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter</artifactId>
    	</dependency>
    	<dependency>
    	<groupId>org.apache.zookeeper</groupId>
    	<artifactId>zookeeper</artifactId>
    	<version>3.4.13</version>
    	</dependency>
    	<dependency>
    	<groupId>com.github.sgroschupf</groupId>
    	<artifactId>zkclient</artifactId>
    	<version>0.1</version>
    	</dependency>
    	
    	<dependency>
    	<groupId>cn.itcast.dubbo</groupId>
    	<artifactId>itcast-dubbo-service</artifactId>
    	<version>1.0-SNAPSHOT</version>
    	</dependency>
    	</dependencies>
    </project>

### (3)编写测试用例 ###

![在这里插入图片描述][a9bd31dca4254567a5a11ca104f5537e.png]

package cn.itcast.dubbo.consumer;
    import cn.itcast.dubbo.pojo.User;
    import cn.itcast.dubbo.service.UserService;
    import com.alibaba.dubbo.config.annotation.Reference;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    import java.util.List;
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class TestUserService {
        
    	@Reference(version = "1.0.0")
    	private UserService userService;
    	
    	@Test
    	public void testQueryAll(){
        
    	List<User> users = this.userService.queryAll();
    	for (User user : users) {
        
    		System.out.println(user);
    	}
    	}
    }

### (4)编写application.properties配置文件 ###

# Spring boot application
    spring.application.name = itcast-dubbo-consumer
    server.port = 9091
    # 应用名称
    dubbo.application.name = dubbo-consumer-demo
    # zk注册中心
    dubbo.registry.address = zookeeper://172.16.55.185:2181
    dubbo.registry.client = zkclient

### (5)进行测试 ###

![在这里插入图片描述][7b5671f19b9b44979dbdb307555102de.png]  
测试结果，发现可以获取到数据，说明，已经成功调用了service中提供的接口。

### (6)dubbo Admin ###

Dubbo提供了可视化的界面管理工具，方便我们对服务进行管理，它就是dubbo admin，[代码地址：][Link 4]  
https://github.com/apache/incubator-dubbo-ops

部署安装：  
第一步，下载并且解压：

git clone https://github.com/apache/incubator-dubbo-ops.git
    #或者使用资料中提供的incubator-dubbo-ops.tar.gz

第二步，修改配置文件：  
在 dubbo-admin-backend/src/main/resources/application.properties 中指定注册中心地址。  
![在这里插入图片描述][b01bb20855fb4b56adec151cea1b7820.png]  
第三步，使用maven进行构建项目：

> 如未安装maven请先安装maven
> 
> 1.  上传解压apache-maven-3.6.0-bin.tar.gz
> 2.  配置环境变量：

vim /etc/profile
    #写入如下内容
    export MVN_HOME=/haoke/apache-maven-3.6.0
    export PATH={
        MVN_HOME}/bin:PATH

构建命令：

mvn clean package

第四步，通过mavn插件启动程序：

mvn --projects dubbo-admin-backend spring-boot:run

第五步，访问系统

打开浏览器，进行访问：http://172.16.55.185:8080/\#/

![在这里插入图片描述][e74ff0334cf74fada93c392839a4d59c.png]  
![在这里插入图片描述][858fda3753334d1ead2be37d8e1b432b.png]  
查看服务消费者的详情：  
![在这里插入图片描述][3934cf75b6e54510af3e122b9fab6b22.png]

### (7)服务的负载均衡 ###

在集群负载均衡时，Dubbo 提供了多种均衡策略，缺省为 random 随机调用。具体参看：http://dubbo.apache.  
org/zh-cn/docs/user/demos/loadbalance.html  
负载均衡的策略：

![在这里插入图片描述][d120512d99ee418898622fb458ba13c0.png]  
下面，我们测试下轮询：  
设置消费方的代码：

package cn.itcast.dubbo.consumer;
    import cn.itcast.dubbo.pojo.User;
    import cn.itcast.dubbo.service.UserService;
    import com.alibaba.dubbo.config.annotation.Reference;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    import java.util.List;
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class TestUserService {
        
    	@Reference(version = "1.0.0", loadbalance = "roundrobin")
    	private UserService userService;
    	@Test
    	public void testQueryAll(){
        
    	for (int i = 0; i < 50; i++) {
        
    	List<User> users = this.userService.queryAll();
    	for (User user : users) {
        
    		System.out.println(user);
    	}
    	try {
        
    		Thread.sleep(1000);
    	} catch (InterruptedException e) {
        
    		e.printStackTrace();
    	}
    	}
    	}
    }

测试方法： 启动多个提供方，进行测试，观察提供方的输出，会发现会有轮询的效果出现。

### (8)dubbo:// 协议 ###

dubbo提供的协议：  
![在这里插入图片描述][90dfe5b74d1349f5a13534db52278de7.png]  
Dubbo 缺省协议采用单一长连接和 NIO 异步通讯，适合于小数据量大并发的服务调用，以及服务消费者机器数远大于服务提供者机器数的情况。  
反之，Dubbo 缺省协议不适合传送大数据量的服务，比如传文件,传视频等，除非请求量很低。  
![在这里插入图片描述][1c90132428904301986db28b89728e46.png]

*  Transporter （传输）: mina, netty, grizzy Serialization（序列化）: dubbo,
 *  hessian2, java, json Dispatcher（分发调度）: all, direct, message,
 *  execution, connection ThreadPool（线程池）: fixed, cached

> 特性

缺省协议，使用基于 mina 1.1.7 和 hessian 3.2.1 的 tbremoting 交互。

*  连接个数：单连接
 *  连接方式：长连接
 *  传输协议：TCP
 *  传输方式：NIO 异步传输
 *  序列化：Hessian 二进制序列化
 *  适用范围：传入传出参数数据包较小（建议小于100K），消费者比提供者个数多，单一消费者无法压满提供者，尽量不要用 dubbo 协议传输大文件或超大字符串。
 *  适用场景：常规远程服务方法调用

[bbed65dcfa444c388039df79140e28bb.png]: https://img-blog.csdnimg.cn/bbed65dcfa444c388039df79140e28bb.png
[cb318ba4242f487888ceae9d2c647050.png]: https://img-blog.csdnimg.cn/cb318ba4242f487888ceae9d2c647050.png
[af8d4bcfa2a64065bf772b27d774c5e6.png]: https://img-blog.csdnimg.cn/af8d4bcfa2a64065bf772b27d774c5e6.png
[3abcf5da4e4f423ca08223718e295426.png]: https://img-blog.csdnimg.cn/3abcf5da4e4f423ca08223718e295426.png
[2162d73d8999430183a2b1b6919bcbde.png]: https://img-blog.csdnimg.cn/2162d73d8999430183a2b1b6919bcbde.png
[8b954929c3a24e44b0603466c74f90e5.png]: https://img-blog.csdnimg.cn/8b954929c3a24e44b0603466c74f90e5.png
[3073291f6b0f4251bff0fe15b1b485cd.png]: https://img-blog.csdnimg.cn/3073291f6b0f4251bff0fe15b1b485cd.png
[b007b096dc5640c897d3022de159738e.png]: https://img-blog.csdnimg.cn/b007b096dc5640c897d3022de159738e.png
[644464768e5d422f8564923281f126d4.png]: https://img-blog.csdnimg.cn/644464768e5d422f8564923281f126d4.png
[e02f901069754c5f8a97c067d4d4db29.png]: https://img-blog.csdnimg.cn/e02f901069754c5f8a97c067d4d4db29.png
[30d06a7b5b994f6b8dea418043d494bf.png]: https://img-blog.csdnimg.cn/30d06a7b5b994f6b8dea418043d494bf.png
[7b7d2856d5654158b32155fcbab75f9d.png]: https://img-blog.csdnimg.cn/7b7d2856d5654158b32155fcbab75f9d.png
[form]: https://ant.design/components/form-cn/
[543d5c5763da44b18822b9778bb84d2a.png]: https://img-blog.csdnimg.cn/543d5c5763da44b18822b9778bb84d2a.png
[f71b89cca6484ae7b54e5c3df9716a57.png]: https://img-blog.csdnimg.cn/f71b89cca6484ae7b54e5c3df9716a57.png
[68612a7d96a04791b37ed86066f10355.png]: https://img-blog.csdnimg.cn/68612a7d96a04791b37ed86066f10355.png
[Link 1]: https://ant.design/components/auto-complete-cn/
[24da0db2731d43ef93bf61e14a96bfb8.png]: https://img-blog.csdnimg.cn/24da0db2731d43ef93bf61e14a96bfb8.png
[fee8edfa43464c0fa49e2f0c10d6adcd.png]: https://img-blog.csdnimg.cn/fee8edfa43464c0fa49e2f0c10d6adcd.png
[4ff56e8432ee4b1aaaaaf0a16fcc8bdb.png]: https://img-blog.csdnimg.cn/4ff56e8432ee4b1aaaaaf0a16fcc8bdb.png
[af519f50d6704a4f9d41a3f260ea9e8a.png]: https://img-blog.csdnimg.cn/af519f50d6704a4f9d41a3f260ea9e8a.png
[51dd1bc8b3f74a3da99d4ff2dc420830.png]: https://img-blog.csdnimg.cn/51dd1bc8b3f74a3da99d4ff2dc420830.png
[8d097200131b42fe8f5dc2440522e9c8.png]: https://img-blog.csdnimg.cn/8d097200131b42fe8f5dc2440522e9c8.png
[25e6cb88406a4cbaa5da053d83a281a1.png]: https://img-blog.csdnimg.cn/25e6cb88406a4cbaa5da053d83a281a1.png
[Link 2]: http://dubbo.apache.org/zh-cn/index.html
[8c5d02fee8994d7caad6fe1d9803c36f.png]: https://img-blog.csdnimg.cn/8c5d02fee8994d7caad6fe1d9803c36f.png
[3e2e646a62ac4eb59a9bd49cb1ae51c4.png]: https://img-blog.csdnimg.cn/3e2e646a62ac4eb59a9bd49cb1ae51c4.png
[80569749063b42d8b880187f9bebde54.png]: https://img-blog.csdnimg.cn/80569749063b42d8b880187f9bebde54.png
[87fa4f146c3141449824df0860057ebb.png]: https://img-blog.csdnimg.cn/87fa4f146c3141449824df0860057ebb.png
[a088b1eba2da489788248083849df765.png]: https://img-blog.csdnimg.cn/a088b1eba2da489788248083849df765.png
[18dbf17602754d58ac5bd49194276ee5.png]: https://img-blog.csdnimg.cn/18dbf17602754d58ac5bd49194276ee5.png
[Link 3]: http://dubbo.apache.org/zh-cn/docs/user/preface/architecture.html
[2cda28eca2214795bd3a33fc0750bfd3.png]: https://img-blog.csdnimg.cn/2cda28eca2214795bd3a33fc0750bfd3.png
[df2504f5274f4094a515746496b7d559.png]: https://img-blog.csdnimg.cn/df2504f5274f4094a515746496b7d559.png
[c1287c51904a4df9a9f9f2c50436ca9d.png]: https://img-blog.csdnimg.cn/c1287c51904a4df9a9f9f2c50436ca9d.png
[903e475738db4c7ebf9e55a17cc61d06.png]: https://img-blog.csdnimg.cn/903e475738db4c7ebf9e55a17cc61d06.png
[3750ffc5a94e482094aeaf9da8a80435.png]: https://img-blog.csdnimg.cn/3750ffc5a94e482094aeaf9da8a80435.png
[b15a13b064334010bb5ef9d37f37087e.png]: https://img-blog.csdnimg.cn/b15a13b064334010bb5ef9d37f37087e.png
[705189889cec44b0bd9efb89e55e49c2.png]: https://img-blog.csdnimg.cn/705189889cec44b0bd9efb89e55e49c2.png
[c0a2cbf0c8d64499ab442af33c665ced.png]: https://img-blog.csdnimg.cn/c0a2cbf0c8d64499ab442af33c665ced.png
[a9bd31dca4254567a5a11ca104f5537e.png]: https://img-blog.csdnimg.cn/a9bd31dca4254567a5a11ca104f5537e.png
[7b5671f19b9b44979dbdb307555102de.png]: https://img-blog.csdnimg.cn/7b5671f19b9b44979dbdb307555102de.png
[Link 4]: https://github.com/apache/incubator-dubbo-ops
[b01bb20855fb4b56adec151cea1b7820.png]: https://img-blog.csdnimg.cn/b01bb20855fb4b56adec151cea1b7820.png
[e74ff0334cf74fada93c392839a4d59c.png]: https://img-blog.csdnimg.cn/e74ff0334cf74fada93c392839a4d59c.png
[858fda3753334d1ead2be37d8e1b432b.png]: https://img-blog.csdnimg.cn/858fda3753334d1ead2be37d8e1b432b.png
[3934cf75b6e54510af3e122b9fab6b22.png]: https://img-blog.csdnimg.cn/3934cf75b6e54510af3e122b9fab6b22.png
[d120512d99ee418898622fb458ba13c0.png]: https://img-blog.csdnimg.cn/d120512d99ee418898622fb458ba13c0.png
[90dfe5b74d1349f5a13534db52278de7.png]: https://img-blog.csdnimg.cn/90dfe5b74d1349f5a13534db52278de7.png
[1c90132428904301986db28b89728e46.png]: https://img-blog.csdnimg.cn/1c90132428904301986db28b89728e46.png