【愚公系列】2023年06月 Java教学课程 144-Dubbo概述和基本使用

前言

1.互联网项目的指标

1、衡量网站的性能指标

• 响应时间：指执行一个请求从开始到最后收到响应数据所花费的总体时间

• 并发数：指系统同时能处理的请求数量

• 并发连接数：指的是客户端向服务器发起请求，并建立了TCP连接。每秒钟服务器连接的总TCP数量

• 请求数：也称为QPS(Query Per Second)指每秒多少请求

• 并发用户数：单位时间内有多少用户

• 吞吐量：指单位时间内系统能处理的请求数量

QPS: Query Per Second每秒查询数。
TPS: Transactions Per Second每秒事务数。
一个事务是指一 个客户机向服务器发送请求然后服务器做出反应的过程。客户机在发送请求时开始计时，收到服务器响应后结束
计时，以此来计算使用的时间和完成的事务个数。
一个页面的一次访问，只会形成一个TPS; 但一次页面请求，可能产生多次对服务器的请求，就会有多个QPS（QPS>=并发连接数>= TPS）

2、大型互联网项目架构目标

高性能：提供快速的访问体验。
高可用：在多人访问情况下，网页要保证可以正常访问。

2.架构演进

互联网架构演进的历程可以简单地分为四个阶段：单体架构、分布式架构、微服务架构和无服务器架构。

• 在单体架构时代，应用程序的所有组件都被打包在同一个进程和应用服务器中。

• 在分布式架构时代，应用程序被拆分成多个独立的、可伸缩的组件，它们可以在不同的服务器上运行。

• 微服务架构引入了一种更加模块化的方式来构建应用程序，即将一个大型的应用程序拆分成小而独立的服务。最近几年，无服务器架构成为一种新的趋势。

• 在无服务器架构中，开发人员可以将应用程序部署到云服务提供商的无服务器平台上，而不需要考虑服务器基础架构的问题。

一、Dubbo概述

1.Dubbo概念

Dubbo是一个高性能、轻量级的开源Java RPC框架，它可以提供服务注册、发现和治理等功能，帮助开发者快速构建分布式应用。

官网：https://cn.dubbo.apache.org/zh-cn/index.html

文档：https://dubbo.gitbooks.io/dubbo-user-book/content/demos/async-call.html

2.Dubbo架构

节点角色说明

调用关系说明：

• 服务容器负责启动，加载，运行服务提供者。

• 服务提供者在启动时，向注册中心注册自己提供的服务。

• 服务消费者在启动时，向注册中心订阅自己所需的服务。

• 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

• 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

• 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。

二、Dubbo快速入门

1.Windows11下zookeeper安装

1、下载软件包
zookeeper官网：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper

2、解压文件夹

3、进入zookeeper目录，创建data目录

4、进入conf目录 ，把zoo_sample.cfg 改名为zoo.cfg

5、打开zoo.cfg文件, 修改data属性：

dataDir=C:\Users\Happy\devTools\apache-zookeeper-3.7.1-bin\data
dataLogDir=C:\Users\Happy\devTools\apache-zookeeper-3.7.1-bin\log
ZooKeeper audit is disabled

进入Zookeeper的bin目录，启动服务命令

zkServer.cmd

2.安装Dubbo-Admin

1、下载dubbo-admin

地址 ： https://github.com/apache/dubbo-admin/tree/master

2、指定zookeeper地址

进入dubbo-admin\src\main\resources\application.properties 指定zookeeper地址

admin.registry.address=zookeeper://127.0.0.1:2181
admin.config-center=zookeeper://127.0.0.1:2181
admin.metadata-report.address=zookeeper://127.0.0.1:2181

3、打包dubbo-admin
注：这里要配置maven的环境变量才可以使用mvn命令

进入到解压dubbo的根目录下,进入命令行模式使用命令： mvn clean package -Dmaven.test.skip=true

4、使用
打包完成后会在dubbo-admin下生成一个target，里面有一个jar包，运行它：
使用命令java -jar dubbo-admin-server-0.5.0.jar

注意：zookeeper的服务一定要打开！就是那个zkServer.cmd

5、前台后端

dubbo-admin-ui 目录下执行命令

npm run dev

6、访问

浏览器输入。用户名密码都是root

http://localhost:8081/

3.spring和springmvc整合

Dubbo作为一个RPC框架，其最核心的功能就是要实现跨网络的远程调用。本小节就是要创建两个应用，一个作为服务的提供方，一个作为服务的消费方。通过Dubbo来实现服务消费方远程调用服务提供方的方法。

1、服务提供方开发

开发步骤：

（1）创建maven工程（打包方式为war）dubbo-service，在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>

<groupId>com.itheima</groupId>
<artifactId>dubbo-service</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>

<properties>
<spring.version>5.1.9.RELEASE</spring.version>
<dubbo.version>2.7.4.1</dubbo.version>
<zookeeper.version>4.0.0</zookeeper.version>

</properties>

<dependencies>
<!-- servlet3.0规范的坐标 -->
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
<scope>provided</scope>
</dependency>
<!--spring的坐标-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<!--springmvc的坐标-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<!--日志-->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.21</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.21</version>
</dependency>
<!--Dubbo的起步依赖，版本2.7之后统一为rg.apache.dubb -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
<version>${dubbo.version}</version>
</dependency>
<!--ZooKeeper客户端实现 -->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>${zookeeper.version}</version>
</dependency>
<!--ZooKeeper客户端实现 -->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>${zookeeper.version}</version>
</dependency>
<!--依赖公共的接口模块-->
<dependency>
<groupId>com.itheima</groupId>
<artifactId>dubbo-interface</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
<build>
<plugins>
<!--tomcat插件-->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.1</version>
<configuration>
<port>9000</port>
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>
</project>

（2）配置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">
<!-- spring -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath*:spring/applicationContext*.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
</web-app>

（3）创建服务接口

package com.itheima.service;
public interface UserService {
public String sayHello();
}

（4）创建服务实现类

注意：服务实现类上使用的Service注解是Dubbo提供的，用于对外发布服务

package com.itheima.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.itheima.service.HelloService;

@Service
public class HelloServiceImpl implements HelloService {
public String sayHello() {
return "hello dubbo hello!~";
}
}

tomcat7:run

2、服务消费方开发

开发步骤：

（1）创建maven工程（打包方式为war）dubbo-web，pom.xml配置和上面服务提供者相同，只需要将Tomcat插件的端口号改为8082即可

（2）配置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">
<!-- Springmvc -->
<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:spring/springmvc.xml</param-value>
</init-param>
</servlet>

<servlet-mapping>
<servlet-name>springmvc</servlet-name>
<url-pattern>*.do</url-pattern>
</servlet-mapping>
</web-app>

（3）编写Controller

package com.itheima.controller;

import com.itheima.service.UserService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {

//注入Service
//@Autowired//本地注入

/*
1. 从zookeeper注册中心获取userService的访问url
2. 进行远程调用RPC
3. 将结果封装为一个代理对象。给变量赋值

*/

@Reference//远程注入
private UserService userService;


@RequestMapping("/sayHello")
public String sayHello(){
return userService.sayHello();
}

}

注意：Controller中注入HelloService使用的是Dubbo提供的@Reference注解

2.1 服务提供者

在dubbo-service工程中src/main/resources下创建applicationContext-service.xml

<?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:dubbo="http://dubbo.apache.org/schema/dubbo" xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">


<!--<context:component-scan base-package="com.itheima.service" />-->

<!--dubbo的配置-->
<!--1.配置项目的名称,唯一-->
<dubbo:application name="dubbo-service"/>
<!--2.配置注册中心的地址-->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<!--3.配置dubbo包扫描-->
<dubbo:annotation package="com.itheima.service.impl" />

</beans>

2.2 服务消费者

在dubbo-web工程中src/main/resources下创建applicationContext-web.xml

<?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:dubbo="http://dubbo.apache.org/schema/dubbo"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">

<mvc:annotation-driven/>
<context:component-scan base-package="com.itheima.controller"/>

<!--dubbo的配置-->
<!--1.配置项目的名称,唯一-->
<dubbo:application name="dubbo-web" >
<dubbo:parameter key="qos.port" value="33333"/>
</dubbo:application>
<!--2.配置注册中心的地址-->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<!--3.配置dubbo包扫描-->
<dubbo:annotation package="com.itheima.controller" />
</beans>

运行测试

tomcat7:run启动

在浏览器输入http://localhost:8000/user/sayHello.do ，查看浏览器输出结果