温州网站建设选择乐云seo,做一个网站一般要多少钱,有没有哪个网站可以做LCM模组,网站404页面优化dubbo框架详细介绍 一、网站应用的演进单一应用架构垂直应用架构分布式服务架构流动计算架构 二、分布式架构存在的问题分布式架构问题架构问题的解决方案 三、dubbo架构什么是dubbo?什么是RPC?RPC基本原理dubbo的功能dubbo基本架构dubbo支持的协议dubbo的特点 四、dubbo实例… dubbo框架详细介绍 一、网站应用的演进单一应用架构垂直应用架构分布式服务架构流动计算架构 二、分布式架构存在的问题分布式架构问题架构问题的解决方案 三、dubbo架构什么是dubbo?什么是RPC?RPC基本原理dubbo的功能dubbo基本架构dubbo支持的协议dubbo的特点 四、dubbo实例dubbo简单案例创建服务提供者创建服务消费者配置tomcat 启动服务 dubbo直连案例使用dubbo最基本的项目结构代码实现 zookeeper注册中心zookeeper注册中心简介 dubbozookeeper案例重要 一、网站应用的演进
随着互联网的发展网站应用的规模不断扩大常规的垂直应用架构已无法应对分布式服务架构以及流动计算架构势在必行亟需一个治理系统确保架构有条不紊的演进。
单一应用架构
当网站流量很小时只需一个应用将所有功能都部署在一起以减少部署节点和成本。此时用于简化增删改查工作量的数据访问框架(ORM)是关键。
垂直应用架构
当访问量逐渐增大单一应用增加机器带来的加速度越来越小提升效率的方法之一是将应用拆成互不相干的几个应用以提升效率。此时用于加速前端页面开发的Web框架(MVC)是关键。
分布式服务架构
当垂直应用越来越多应用之间交互不可避免将核心业务抽取出来作为独立的服务逐渐形成稳定的服务中心使前端应用能更快速的响应多变的市场需求。此时用于提高业务复用及整合的分布式服务框架(RPC)是关键。
流动计算架构
当服务越来越多容量的评估小服务资源的浪费等问题逐渐显现此时需增加一个调度中心基于访问压力实时管理集群容量提高集群利用率。此时用于提高机器利用率的资源调度和治理中心(SOA)是关键。
二、分布式架构存在的问题
分布式架构问题
分布式架构主要的难点是解决服务治理问题。 当服务越来越多将会存在如下问题
服务 URL 配置管理变得非常困难F5 硬件负载均衡器的单点压力也越来越大。服务间依赖关系变得错踪复杂分不清启动顺序和架构关系服务的调用量越来越大服务的容量问题就暴露出来这个服务需要多少机器支撑什么时候该加机器
架构问题的解决方案
提供注册中心需要一个服务注册中心动态地注册和发现服务使服务的位置透明。并通过在消费方获取服务提供方地址列表实现软负载均衡和 Failover降低对 F5 硬件负载均衡器的依赖也能减少部分成本。自动提供一个依赖关系图缕清架构关系实时监控要将服务现在每天的调用量响应时间都统计出来作为容量规划的参考指标。要可以动态调整权重在线上将某台机器的权重一直加大并在加大的过程中记录响应时间的变化直到响应时间到达阈值记录此时的访问量再以此访问量乘以机器数反推总容量。
三、dubbo架构
什么是dubbo?
Apache Dubbo 是一款高性能、轻量级的开源 Java RPC 框架它提供了三大核心能力
面向接口的远程方法调用智能容错和负载均衡服务自动注册和发现。
Dubbo 是一个分布式服务框架致力于提供高性能和透明化的 RPC 远程服务调用方案、服务治理方案。
什么是RPC?
RPC 【Remote Procedure Call】是指远程过程调用是一种进程间通信方式是一种技术思想而不是规范。它允许程序调用另一个地址空间网络的另一台机器上的过程或函数而不用开发人员显式编码这个调用的细节。调用本地方法和调用远程方法一样。 RPC 的实现方式可以不同。例如 java 的 rmi, spring 远程调用等。 RPC 概念是在上世纪 80 年代由 Brue Jay Nelson(布鲁·杰伊·纳尔逊)提出。使用 PRC 可以将本地的调用扩展到远程调用分布式系统的其他服务器。 RPC 的特点
简单使用简单建立分布式应用更容易。高效调用过程看起来十分清晰效率高。通用进程间通讯的方式有通用的规则
RPC基本原理 PRC 调用过程
调用方 client 要使用右侧 server 的功能方法发起对方法的调用client stub 是 PRC 中定义的存根看做是 client 的助手。stub 把要调用的方法参数进行序 列化方法名称和其他数据包装起来。通过网络 socket(网络通信的技术)把方法调用的细节内容发送给右侧的 serverserver 端通过 socket 接收请求的方法名称参数等数据传给 stub。server 端接到的数据由 serverstub(server 的助手)处理调用 server 的真正方法处理业务server 方法处理完业务把处理的结果对象Object交给了助手助手把 Object 进行序 列化对象转为二进制数据。server 助手二进制数据交给网络处理程序通过网络将二进制数据发送给 client。client 接数据交给 client 助手。client 助手接收数据通过反序列化为 java 对象Object作为远程方法调用结果。
dubbo的功能 面向接口的好处
面向接口代理调用接口的方法在 A 服务器调用 B 服务器的方法由 dubbo 实现对 B 的调用无需关心实现的细节就像 MyBatis 访问 Dao 的接口可以操作数据库一样。不用关心 Dao 接口方法的实现。这样开发是方便舒服的
dubbo基本架构 节点角色说明
节点角色说明Provider暴露服务的服务提供方Consumer调用远程服务的服务消费方Registry服务注册与发现的注册中心Monitor统计服务的调用次数和调用时间的监控中心Container服务运行容器
调用关系说明
0.服务容器负责启动加载运行服务提供者。1.服务提供者在启动时向注册中心注册自己提供的服务。2.服务消费者在启动时向注册中心订阅自己所需的服务。3.注册中心返回服务提供者地址列表给消费者如果有变更注册中心将基于长连接推送变更数据给消费者。4.服务消费者从提供者地址列表中基于软负载均衡算法选一台提供者进行调用如果调用失败再选另一台调用。5.服务消费者和提供者在内存中累计调用次数和调用时间定时每分钟发送一次统计数据到监控中心。
dubbo支持的协议
支持多种协议dubbo , hessian , rmi , http, webservice , thrift , memcached , redis。 dubbo 官方推荐使用 dubbo 协议。dubbo 协议默认端口 20880
dubbo的特点
Dubbo 架构具有以下几个特点分别是连通性、健壮性、伸缩性、以及向未来架构的升级性。
四、dubbo实例
dubbo简单案例
实际生产应用中不会使用直连模式此处只是为了演示dubbo的远程调用功能实际生产中一般都要结合注册中心来使用dubbo常用的注册中心为zookeeper注册 中心。
创建服务提供者
通过maven创建一个webapp应用dubbo-direct-provider 结构如下图 pom文件中加入dubbo依赖 由于dubbo和spring无缝对接所以可以使用spring直接整合dubbo使用
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdorg.example/groupIdartifactIddubbo-direct-provider/artifactIdversion1.0-SNAPSHOT/versionpackagingwar/packagingpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!-- spring-webmvc --dependencygroupIdorg.springframework/groupIdartifactIdspring-webmvc/artifactIdversion5.2.15.RELEASE/version/dependency!-- spring-context --dependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.2.15.RELEASE/version/dependency!-- dubbo --dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo/artifactIdversion2.7.3/version/dependency/dependencies
/project
创建service接口及其实现类: 接口类SomeService.java 实现类SomeServiceImpl.java
package org.example.service;import org.springframework.stereotype.Service;public interface SomeService {public String hello(String msg);
}package org.example.service.impl;import org.example.service.SomeService;public class SomeServiceImpl implements SomeService {public String hello(String msg) {return hello msg;}
}在resources下新建dubbo的配置文件 dubbo-direct-provider.xml 配置dubbo相关参数
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://dubbo.apache.org/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbohttp://dubbo.apache.org/schema/dubbo/dubbo.xsd!--声明dubbo 的服务名称唯一应用标识--dubbo:application namedubbo-direct-provider/!--声明dubbo的协议和端口号--dubbo:protocol namedubbo port20880/!--暴露服务dubbo是基于接口提供服务的ref:实现类的引用registry由于是使用直连的方式值为“N/A”--dubbo:service interfaceorg.example.service.SomeService refsomeServiceImpl registryN/A/!--声明接口实现类--bean idsomeServiceImpl classorg.example.service.impl.SomeServiceImpl/
/beans在web.xml文件中配置监听器 由于dubbo需要监听器监控其服务动态
?xml version1.0 encodingUTF-8?
web-app xmlnshttp://xmlns.jcp.org/xml/ns/javaeexmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsdversion4.0!--声明dubbo配置文件所在位置--context-paramparam-namecontextConfigLocation/param-nameparam-valueclasspath:dubbo-direct-provider.xml/param-value/context-param!--配置监听器--listenerlistener-classorg.springframework.web.context.ContextLoaderListener/listener-class/listener/web-app修改pom.xml文件中的打包类型为jar包之后执行 maven 的clean和install,将服务提供者打包到maven仓库 由于没有使用注册中心打包到仓库是为了让服务消费者能够从仓库中依赖当前的服务提供者的接口
packagingjar/packaging打包完成之后将打包类型还原成war包因为我们需要启动服务提供者为消费者提供服务。
packagingwar/packaging创建服务消费者
通过maven创建一个webapp应用dubbo-direct-consumer 结构如下图 pom文件中加入dubbo依赖
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdorg.example/groupIdartifactIddubbo-direct-consumer/artifactIdversion1.0-SNAPSHOT/versionpackagingwar/packagingpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!-- spring-webmvc --dependencygroupIdorg.springframework/groupIdartifactIdspring-webmvc/artifactIdversion5.2.15.RELEASE/version/dependency!-- spring-context --dependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.2.15.RELEASE/version/dependency!-- dubbo --dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo/artifactIdversion2.7.3/version/dependency!--添加服务提供者依赖--dependencygroupIdorg.example/groupIdartifactIddubbo-direct-provider/artifactIdversion1.0-SNAPSHOT/version/dependency/dependencies
/project创建SomeController.java
package org.example.web;import org.example.service.SomeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;Controller
public class SomeController {Autowiredprivate SomeService someService;RequestMapping(/hello)public String hello(Model model) {String word someService.hello(word0000);// String word 测试;model.addAttribute(word, word);return hello;}
}
在resources下创建服务消费者的dubbo配置文件 dubbo-direct-consumer.xml 配置如下
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instance xmlns:dubbohttp://dubbo.apache.org/schema/dubboxsi:schemaLocationhttp://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!--配置dubbo应用名称--dubbo:application namedubbo-direct-consumer/!--配置dubbo服务--!--id:远程服务接口的bean idinterface:远程服务接口的全名registry:由于没有使用注册中心所以值依旧是N/Aurl:dubbo服务路径由于使用的是dubbo协议所以值为dubbo://localhost:20880--dubbo:reference idsomeService interfaceorg.example.service.SomeService registryN/A urldubbo://localhost:20880 /
/beans由于我们要使用jsp页面输出测试值需要配置springmvc.xml 在resources下创建springmvc.xml 配置文件
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:mvchttp://www.springframework.org/schema/mvcxsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd!--配置组件扫描--context:component-scan base-packageorg.example.web/!--配置注解驱动--mvc:annotation-driven/!--配置视图解析器--bean classorg.springframework.web.servlet.view.InternalResourceViewResolverproperty nameprefix value//property namesuffix value.jsp//bean
/beans在web.xml文件中配置servlet映射
?xml version1.0 encodingUTF-8?
web-app xmlnshttp://xmlns.jcp.org/xml/ns/javaeexmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsdversion4.0!--配置servlet映射--servletservlet-namedispatcherServlet/servlet-nameservlet-classorg.springframework.web.servlet.DispatcherServlet/servlet-class!--配置容器启动加载配置文件--init-paramparam-namecontextConfigLocation/param-nameparam-valueclasspath:dubbo-direct-consumer.xml,classpath:springmvc.xml/param-value/init-paramload-on-startup1/load-on-startup/servletservlet-mappingservlet-namedispatcherServlet/servlet-nameurl-pattern//url-pattern/servlet-mapping
/web-app创建hello.jsp文件 在webapp下创建 hello.jsp
%--Created by IntelliJ IDEA.User: ghqDate: 2021/6/19Time: 13:41To change this template use File | Settings | File Templates.
--%
% page contentTypetext/html;charsetUTF-8 languagejava %
html
headtitleTitle/title
/head
body
h1${word}/h1
/body
/html
配置tomcat 启动服务
注意事项 配置tomcat时,两个服务的HTTP port和JMX port不能一样否则端口会被占用。 启动时注意启动顺序先启动服务提供者再启动服务消费者
dubbo-direct-provider dubbo-direct-consumer 启动服务消费者之后出现如下所示表明调用成功 dubbo直连案例
使用dubbo最基本的项目结构
接口工程业务接口和实体类服务提供者工程业务接口的实现类服务消费者工程消费业务接口
代码实现
新建一个maven java工程用于提供业务接口和实体类 结构如下图所示 在dubbo-interface中创建一个接口和一个实体类用于定义接口和相关实体类 接口为SomeService.java 实体类为User.java
package com.guo.service;import com.guo.pojo.User;public interface SomeService {public String hello(String msg);public User userInfo();}
package com.guo.pojo;import java.io.Serializable;public class User implements Serializable {private Integer id;private String name;private Integer age;public Integer getId() {return id;}public void setId(Integer id) {this.id id;}public String getName() {return name;}public void setName(String name) {this.name name;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age age;}Overridepublic String toString() {return User{ id id , name name \ , age age };}
}
创建一个服务提供者工程dubbo-provider 项目结构如下 pom.xml文件中加入相关依赖
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.guo/groupIdartifactIddubbo-provider/artifactIdversion1.0-SNAPSHOT/versionpackagingwar/packagingpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!--dubbo依赖--dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo/artifactIdversion2.7.3/version/dependency!--webmvc依赖--dependencygroupIdorg.springframework/groupIdartifactIdspring-webmvc/artifactIdversion5.2.15.RELEASE/version/dependency!--spring -context依赖--dependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.2.15.RELEASE/version/dependency!--接口jar包--dependencygroupIdcom.guo/groupIdartifactIddubbo-interface/artifactIdversion1.0-SNAPSHOT/version/dependency/dependencies
/project
在当前工程中实现业务接口 SomeServiceImpl.java 代码如下
package com.guo.service;import com.guo.pojo.User;public class SomeServiceImpl implements SomeService {Overridepublic String hello(String msg) {return msg;}Overridepublic User userInfo() {User user new User();user.setId(1);user.setName(张三);user.setAge(30);return user;}
}
在resource下新建dubbo服务提供者配置文件 dubbo-provider.xml
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://dubbo.apache.org/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbohttp://dubbo.apache.org/schema/dubbo/dubbo.xsd!--dubbo应用名--dubbo:application namedubbo-provider/!--声明dubbo使用协议和端口号--dubbo:protocol namedubbo port20880/!--暴露公有接口--dubbo:service interfacecom.guo.service.SomeServicerefsomeServiceImplregistryN/A/!--声明接口实现类--bean idsomeServiceImpl classcom.guo.service.SomeServiceImpl/
/beans在web.xml配置文件中配置监听器 web.xml
?xml version1.0 encodingUTF-8?
web-app xmlnshttp://xmlns.jcp.org/xml/ns/javaeexmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsdversion4.0!--配置文件位置声明--context-paramparam-namecontextConfigLocation/param-nameparam-valueclasspath:dubbo-provider.xml/param-value/context-param!--配置监听器--listenerlistener-classorg.springframework.web.context.ContextLoaderListener/listener-class/listener
/web-app创建服务消费者工程 结构如下 在pom.xml文件中加入依赖 pom.xml
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.guo/groupIdartifactIddubbo-consumer/artifactIdversion1.0-SNAPSHOT/versionpackagingwar/packagingpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependenciesdependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo/artifactIdversion2.7.3/version/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-webmvc/artifactIdversion5.2.15.RELEASE/version/dependencydependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.2.15.RELEASE/version/dependencydependencygroupIdcom.guo/groupIdartifactIddubbo-interface/artifactIdversion1.0-SNAPSHOT/version/dependency/dependencies
/project
在消费者工程中创建SomeController.java,用于消费服务给页面返回用户数据 SomeController.java
package com.guo.web;import com.guo.pojo.User;
import com.guo.service.SomeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;Controller
public class SomeController {Autowiredprivate SomeService someService;RequestMapping(/hello)public String hello(Model model) {String hello someService.hello(dubbo的hello测试);model.addAttribute(hello, hello);return hello;}RequestMapping(/user)public String userInfo(Model model) {User user someService.userInfo();model.addAttribute(user, user);return user;}
}
配置消费者工程的dubbo配置文件 dubbo-consumer.xml
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://dubbo.apache.org/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbohttp://dubbo.apache.org/schema/dubbo/dubbo.xsd!--声明dubbo应用--dubbo:application namedubbo-consumer/!--声明dubbo调用接口--dubbo:reference idsomeServiceinterfacecom.guo.service.SomeServiceurldubbo://localhost:20880registryN/A/
/beans在springmvc.xml文件中配置视图解析器 springmvc.xml
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:mvchttp://www.springframework.org/schema/mvcxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/mvchttps://www.springframework.org/schema/mvc/spring-mvc.xsd!--配置组件扫描--context:component-scan base-packagecom.guo.web/!--配置注解驱动--mvc:annotation-driven/!--配置试图解析器--bean classorg.springframework.web.servlet.view.InternalResourceViewResolverproperty nameprefix value//property namesuffix value.jsp//bean
/beans配置web.xml文件 web.xml
?xml version1.0 encodingUTF-8?
web-app xmlnshttp://xmlns.jcp.org/xml/ns/javaeexmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsdversion4.0!--配置servlet--servletservlet-namedispatcherServlet/servlet-nameservlet-classorg.springframework.web.servlet.DispatcherServlet/servlet-classinit-paramparam-namecontextConfigLocation/param-nameparam-valueclasspath:dubbo-consumer.xml,classpath:springmvc.xml/param-value/init-param/servletservlet-mappingservlet-namedispatcherServlet/servlet-nameurl-pattern//url-pattern/servlet-mapping
/web-app部署工程先启动服务提供者再启动服务消费者工程 得到如图所示
zookeeper注册中心
本案例使用zookeeper作为注册中心
zookeeper注册中心简介
Zookeeper 是 Apache Hadoop 的子项目是一个树型的目录服务支持变更推送适合作为 Dubbo 服务的注册中心工业强度较高可用于生产环境并推荐使用 。
zookeeper树形结构图如下 结合dubbo的流程说明:
服务提供者启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的 URL 地址服务消费者启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者 URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址监控中心启动时: 订阅 /dubbo/com.foo.BarService 目录下的所有提供者和消费者 URL 地址。
zookeeper结合dubbo实现的功能
当提供者出现断电等异常停机时注册中心能自动删除提供者信息当注册中心重启时能自动恢复注册数据以及订阅请求当会话过期时能自动恢复注册数据以及订阅请求当设置 dubbo:registry check“false” / 时记录失败注册和订阅请求后台定时重试可通过 dubbo:registry username“admin” password“1234” / 设置 zookeeper 登录信息可通过 dubbo:registry group“dubbo” / 设置 zookeeper 的根节点不配置将使用默认的根节点。支持 * 号通配符 dubbo:reference group version /可订阅服务的所有分组和所有版本的提供者
dubbo中使用zookeeper注册中心 在使用zookeeper时需要安装zookeeper: zookeeper安装包下载https://zookeeper.apache.org/ 注意zookeeper的linux安装包和windows安装包为同一个。 解压下载的安装包进入conf 目录复制zoo_sample.cfg并改名为zoo.cfg 使用编辑器打开zoo.cfg配置文件原始内容如下
# The number of milliseconds of each tick
tickTime2000
# The number of ticks that the initial
# synchronization phase can take
initLimit10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
dataDir\temp\data
# the port at which the clients will connect
clientPort2181
admin.serverPort8888
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns60
#
# Be sure to read the maintenance section of the
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount3
# Purge task interval in hours
# Set to 0 to disable auto purge feature
#autopurge.purgeInterval1修改如下内容 新增端口配置 由于zookeeper 3.5以后的版本启动时会占用8080端口在实际的开发中8080端口我们通常用作tomcat的服务端口需要将zookeeper占用的此端口修改为其他端口如修改为8888端口 在zoo.cfg配置文件中加入如下配置 admin.serverPort8888 将dataDir\temp\data修改为自定义的路径 比如 dataDirD:\apache-zookeeper-3.5.9-bin\data 增加日志文件路径 dataLogDirD:\apache-zookeeper-3.5.9-bin\log 在apache-zookeeper-3.5.9-bin根目录下新建data和log这两个文件夹 如图所示 修改后的配置文件如下
# The number of milliseconds of each tick
tickTime2000
# The number of ticks that the initial
# synchronization phase can take
initLimit10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
dataDirD:\apache-zookeeper-3.5.9-bin\data
dataLogDirD:\apache-zookeeper-3.5.9-bin\log
# the port at which the clients will connect
clientPort2181
admin.serverPort8888
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns60
#
# Be sure to read the maintenance section of the
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount3
# Purge task interval in hours
# Set to 0 to disable auto purge feature
#autopurge.purgeInterval1修改完成之后进入bin目录点击zkServer.cmd启动服务 启动完毕之后启动客户端zkCli.cmd检测是否启动成功 客户端显示Welcome to ZooKeeper! 说明启动成功启动成功的客户端显示如下 至此zookeeper的成功安装成功启动
注zookeeper的服务端口号为2181
后面的zookeeper配置会用到此端口号用于将服务注册到zookeeper.
dubbozookeeper案例重要
重点案例生产环境下使用的dubbo模式
新建公用的接口工程此工程为普通maven的jar工程,结构如下 在工程中新建一个接口类和一个实体类 接口类SomeService.java 实体类User.java 由于接口中的方法和参数有可能需要用到实体对象一般会选择将业务所需要的实体类放在接口工程中同时可以提供给其他业务实现工程使用。 代码如下 接口类SomeService.java
package com.guo.service;import com.guo.pojo.User;public interface SomeService {public String hello(String msg);public User userInfo();}
实体类User.java
package com.guo.pojo;import java.io.Serializable;public class User implements Serializable {private Integer id;private String name;private Integer age;public Integer getId() {return id;}public void setId(Integer id) {this.id id;}public String getName() {return name;}public void setName(String name) {this.name name;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age age;}Overridepublic String toString() {return User{ id id , name name \ , age age };}
}
新建服务提供者工程用于实现接口工程中的业务功能。 结构如图所示 在当前工程的pom.xml中引入所需依赖
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.guo/groupIdartifactIddubbo-zk-provider/artifactIdversion1.0-SNAPSHOT/versionpackagingwar/packagingpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!--dubbo依赖--dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo/artifactIdversion2.7.3/version/dependency!--spring-context依赖--dependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.2.15.RELEASE/version/dependency!--spring-webmvc依赖--dependencygroupIdorg.springframework/groupIdartifactIdspring-webmvc/artifactIdversion5.2.15.RELEASE/version/dependency!--zookeeper注册中心客户端依赖--dependencygroupIdorg.apache.curator/groupIdartifactIdcurator-framework/artifactIdversion5.1.0/version/dependencydependencygroupIdorg.apache.curator/groupIdartifactIdcurator-recipes/artifactIdversion5.1.0/version/dependency!--接口工程jar包--dependencygroupIdcom.guo/groupIdartifactIddubbo-interface/artifactIdversion1.0-SNAPSHOT/version/dependency/dependencies
/project
zookeeper客户端说明
Dubbo 支持 zkclient 和 curator 两种 Zookeeper 客户端实现从 2.2.0 版本开始缺省为 zkclient 实现以提升 zookeeper 客户端的健壮性。zkclient 是 Datameer 开源的一个 Zookeeper 客户端实现。注意:在2.7.x的版本中已经移除了zkclient的实现,如果要使用zkclient客户端,需要自行拓展由于接口工程和业务实现提供者工程为两个工程所以需要引入接口工程java包 !--接口工程jar包--dependencygroupIdcom.guo/groupIdartifactIddubbo-interface/artifactIdversion1.0-SNAPSHOT/version/dependency本案例使用的dubbo版本2.7.3,所以使用curator客户端
创建接口业务实现类SomeServiceImpl.java
package com.guo.service;import com.guo.pojo.User;public class SomeServiceImpl implements SomeService {Overridepublic String hello(String msg) {return msg;}Overridepublic User userInfo() {User user new User();user.setId(1);user.setName(张三);user.setAge(25);return user;}
}
在resources下新建dubbo配置文件dubbo-zk-provider.xml
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://dubbo.apache.org/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbohttp://dubbo.apache.org/schema/dubbo/dubbo.xsd!--声明dubbo服务提供者--dubbo:application namedubbo-zk-provider/!--配置dubbo协议以及端口号--dubbo:protocol namedubbo port20880/!--配置注册中心--dubbo:registry addresszookeeper://localhost:2181 clientcurator/!--配置需要暴露的接口--dubbo:service interfacecom.guo.service.SomeService refsomeService/!--配置接口实现类--bean idsomeService classcom.guo.service.SomeServiceImpl/
/beans在web.xml文件中配置监听器 web.xml
?xml version1.0 encodingUTF-8?
web-app xmlnshttp://xmlns.jcp.org/xml/ns/javaeexmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsdversion4.0display-nameArchetype Created Web Application/display-name!--加载配置文件--context-paramparam-namecontextConfigLocation/param-nameparam-valueclasspath:dubbo-zk-provider.xml/param-value/context-param!--配置监听器--listenerlistener-classorg.springframework.web.context.ContextLoaderListener/listener-class/listener
/web-app创建服务消费者工程结构如图所示 在pom.xml文件中引入依赖 pom.xml
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.guo/groupIdartifactIddubbo-zk-consumer/artifactIdversion1.0-SNAPSHOT/versionpackagingwar/packagingpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!--dubbo依赖--dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo/artifactIdversion2.7.3/version/dependency!--spring-webmvc依赖--dependencygroupIdorg.springframework/groupIdartifactIdspring-webmvc/artifactIdversion5.2.15.RELEASE/version/dependency!--spring-context依赖--dependencygroupIdorg.springframework/groupIdartifactIdspring-context/artifactIdversion5.2.15.RELEASE/version/dependency!--zookeeper注册中心客户端依赖--dependencygroupIdorg.apache.curator/groupIdartifactIdcurator-framework/artifactIdversion5.1.0/version/dependencydependencygroupIdorg.apache.curator/groupIdartifactIdcurator-recipes/artifactIdversion5.1.0/version/dependency!--业务接口依赖--dependencygroupIdcom.guo/groupIdartifactIddubbo-interface/artifactIdversion1.0-SNAPSHOT/version/dependency/dependencies
/project
创建消费者controller,用于调用服务提供者的业务实现 SomeController.java
package com.guo.web;import com.guo.pojo.User;
import com.guo.service.SomeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;Controller
public class SomeController {Autowiredprivate SomeService someService;RequestMapping(/hello)public String hello(Model model) {String hello someService.hello(zk-dubbo-测试);model.addAttribute(hello, hello);return hello;}RequestMapping(/user)public String getUser(Model model) {User user someService.userInfo();model.addAttribute(user, user);return user;}
}
在resources下创建dubbo配置文件和springmvc配置文件 dubbo-zk-consumer.xml springmvc.xml 在dubbo-zk-consumer.xml中的配置如下
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://dubbo.apache.org/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbohttp://dubbo.apache.org/schema/dubbo/dubbo.xsd!--配置服务消费者--dubbo:application namedubbo-zk-consumer/!--配置注册中心--dubbo:registry addresszookeeper://localhost:2181 clientcurator/!--配置服务接口--dubbo:reference idsomeService interfacecom.guo.service.SomeService/
/beans在springmvc.xml中的配置如下
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/contextxmlns:mvchttp://www.springframework.org/schema/mvcxsi:schemaLocationhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/mvchttps://www.springframework.org/schema/mvc/spring-mvc.xsd!--配置组件扫描--context:component-scan base-packagecom.guo.web/!--配置注解驱动--mvc:annotation-driven/!--配置试图解析器--bean classorg.springframework.web.servlet.view.InternalResourceViewResolverproperty nameprefix value//property namesuffix value.jsp//bean
/beans配置web.xml 在web.xml中配置servlet路劲映射 web.xml
?xml version1.0 encodingUTF-8?
web-app xmlnshttp://xmlns.jcp.org/xml/ns/javaeexmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://xmlns.jcp.org/xml/ns/javaeehttp://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsdversion4.0servletservlet-namedispatcherServlet/servlet-nameservlet-classorg.springframework.web.servlet.DispatcherServlet/servlet-classinit-paramparam-namecontextConfigLocation/param-nameparam-valueclasspath:dubbo-zk-consumer.xml,classpath:springmvc.xml/param-value/init-paramload-on-startup1/load-on-startup/servletservlet-mappingservlet-namedispatcherServlet/servlet-nameurl-pattern//url-pattern/servlet-mapping
/web-app创建jsp文件用于视图展现显示我们的测试数据 hello.jsp user.jsp hello.jsp内容如下
%--Created by IntelliJ IDEA.User: ghqDate: 2021/6/20Time: 0:13To change this template use File | Settings | File Templates.
--%
% page contentTypetext/html;charsetUTF-8 languagejava %
html
headtitleTitle/title
/head
body
h1${hello}/h1
/body
/html
uer.jsp内容如下
%--Created by IntelliJ IDEA.User: ghqDate: 2021/6/20Time: 0:13To change this template use File | Settings | File Templates.
--%
% page contentTypetext/html;charsetUTF-8 languagejava %
html
headtitleTitle/title
/head
body
h1${user.id}/h1
h1${user.name}/h1
h1${user.age}/h1
/body
/html
至此整个dubbo-zookeeper项目案例整合完毕只需配置tomcat启动服务
注意:
在启动项目之前先启动zookeeper服务端启动项目的时候需要先启动服务提供者工程再启动服务消费者工程更多的dubbo配置请参考dubbo官网的 [参考手册] dubbo官网https://dubbo.apache.org/zh/ 参考手册https://dubbo.apache.org/zh/docs/v2.7/user/references/
