ZooKeeper安装
- 下载文件 apache-zookeeper-3.5.6-bin.tar.gz
- 安装到 /opt 目录下
/opt/zooKeeper/apache-zooKeeper-3.5.6-bin/
dataDir=/opt/zookeeper/zkdata
- 启动、查看状态
./opt/zookeeper/apache-zookeeper-3.5.6-bin/bin/zkServer.sh start
./opt/zookeeper/apache-zookeeper-3.5.6-bin/bin/zkServer.sh status
dubbo使用
概述
描述
dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。
主要核心部件
Remoting: 网络通信框架,实现了 sync-over-async 和 request-response 消息机制
RPC: 一个远程过程调用的抽象,支持负载均衡、容灾和集群功能
Registry: 服务目录框架用于服务的注册和服务事件发布和订阅
基础使用
-
导入基本坐标
-
添加提供者模块
-
导入坐标
- 导入dubbo坐标
- 导入与zookeeper通信的客户端(2个)
-
改为war项目,以便于可以独立启动
- 加入Tomcat插件
-
- 添加dubbo约束
- 配置名称,一般与项目名称一样(唯一)
- 配置zookeeper注册中心地址,默认端口:2181
- 配置dubbo包扫描
- 因为是web项目,所以添加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: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"></context:component-scan> <dubbo:application name="dubbo-service"></dubbo:application> <dubbo:registry address="zookeeper://192.168.100.6:2181"></dubbo:registry> <dubbo:annotation package="com.itheima.service"></dubbo:annotation> </beans>
-
-
添加消费者模块
-
在注入接口时,会报错,即创建一个接口
-
导入坐标
- 导入dubbo坐标
- 导入与zookeeper通信的客户端(2个)
-
配置SpringMVC配置文件web.xml
-
Reference注解远程注入,注入接口时
-
配置springmvc.xml
- web.xml
<!-- 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>
- springmvc.xml
-
-
启动测试
相关配置
注:出现端口冲突,修改 springmvc.xml
<dubbo:application name="dubbo-web">
<dubbo:parameter key="qos.port" value="33333"></dubbo:parameter>
</dubbo:application>
dubbo配置
<!--dubbo的配置-->
<!--1.配置项目的名称,唯一-->
<dubbo:application name="dubbo-service"/>
<!--2.配置注册中心的地址-->
<dubbo:registry address="zookeeper://192.168.138.11:2181"/>
<!--3.扫描指定包,加上@Service注解的类会被发布为服务-->
<dubbo:annotation package="com.itheima.service.impl"/>
<!--配置端口-->
<!-- <dubbo:protocol port="20880"/>-->
<!-- 注册 协议和port 端口默认是20880 -->
<dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>
<!--元数据配置 -->
<dubbo:Metadata-report address="zookeeper://192.168.138.11:2181"/>
# DEBUG < INFO < WARN < ERROR < FATAL
# Global logging configuration
log4j.rootLogger=info, stdout,file
# My logging configuration...
#log4j.logger.com.tocersoft.school=DEBUG
#log4j.logger.net.sf.hibernate.cache=debug
## Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p %d %C: %m%n
log4j.appender.file=org.apache.log4j.FileAppender
log4j.appender.file.File=../logs/iask.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %l %m%n
高级使用
监测
dubbo- admin 概述
- dubbo-admin管理平台,是图形化的服务管理页面
- 从注册中心中获取到所有的提供者 /消费者进行配置管理
- 路由规则、动态配置、服务降级、访问控制、权重调整、负载均衡等管理功能
- dubbo- admin是一个前后端分离的项目。前端使用vue,后端使用springboot
- 安装dubbo-admin其实就是部署该项目
安装
# centers in dubbo2.7
admin.registry.address=zookeeper://192.168.138.11:2181
admin.config-center=zookeeper://192.168.138.11:2181
admin.Metadata-report.address=zookeeper://192.168.138.11:2181
- 在 dubbo-admin-develop 目录执行打包命令
mvn clean package
- 后端启动
\dubbo-admin-develop\dubbo-admin-distribution\target>java -jar dubbo-admin-0.3.0-SNAPSHOT.jar
- 前端页面启动
\dubbo-admin-develop\dubbo-admin-ui 目录下执行
命令:npm run dev
//要多次敲击回车键,如果失败可多次尝试
使用
- 浏览器输入 http://localhost:8081/ 用户名密码都是 root
- 配置服务端口
<!--配置端口-->
<dubbo:protocol port="20880"/>
- 元数据
<!-- 元数据配置 -->
<dubbo:Metadata-report address="zookeeper://192.168.149.135:2181" />
序列化
概述
- dubbo 内部已经将序列化和反序列化的过程内部封装了
- 我们只需要在定义pojo类时实现serializable接口即可
- 一般会定义一 个公共的pojo模块,让生产者和消费者都依赖该模块。
步骤
- 创建Module,pojo User类
public class User implements Serializable {
private int id;
private String username;
private String password;
}
<dependency>
<groupId>com.itheima</groupId>
<artifactId>dubbo-pojo</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
-
启动测试
-
踩坑
-
程序包com.xxx.xxx不存
安装 interface,service,web,最后启动测试
-
User对象未实现seriali zable接口,错误信息
-
public class User implements Serializable
地址缓存
注册中心挂了,服务是否可以正常访问?
超时与重试
超时
- 服务消费者在调用服务提供者的时候发生了阻塞、等待的情形,这个时候,服务消费者会直等待下去。
- 在某个峰值时刻,大量的请求都在同时请求服务消费者,会造成线程的大量堆积,势必会造成雪崩。
- dubbo利用超时机制来解决这个问题,设置-个超时时间, 在这个时间段内,无法完成服务访问,则自动断开连接。
- 使用timeout属性配置超时时间,默认值1000,单位毫秒
//timeout 超时时间 单位毫秒 retries 重试次数,默认为2,调用1次,重复2次,合计3次
@Service(timeout = 3000,retries=0)
重试
- 设置了超时时间,在这个时间段内,无法完成服务访问,则自动断开连接。
- 如果出现网络抖动,则这一-次请求就会失败。
- dubbo提供重试机制来避免类似问题的发生。
- 通过retries属性来设置重试次数。默认为2次
//timeout 超时时间 单位毫秒 retries 重试次数,默认为2,调用1次,重复2次,合计3次
@Service(timeout = 3000,retries=2)
多版本
概述
步骤
1、生产者配置
@Service(version="v2.0")
public class UserServiceImp12 implements UserService {...}
2、消费者配置
@Reference(version="v2.0")//远程注入
private UserService userService;
3、测试需要更改消费者配置
- UserServiceImpl
@Service(timeout = 3000,version="v2.0")
- applicationContext.xml
<!--配置端口-->
<dubbo:protocol port="20882"/>
- pom.xml
<build>
<plugins>
<!--tomcat插件-->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.1</version>
<configuration>
<port>9002</port>
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>
负载均衡
负载均衡策略(4种)
- Random:按权重随机,默认值。按权重设置随机概率
- RoundRobin: 按权重轮询
- LeastActive: 最少活跃调用数,相同活跃数的随机
- ConsistentHash:一 致性Hash,相同参数的请求总是发到同一提供者
步骤
1、服务提供者配置
@Service(weight = 100)
public class UserServiceImp12 implements UserService {...}
2、application.xml 配置parameter key
3、消费者配置
//@Reference(loadbalance = "roundrobin")
//@Reference(loadbalance = "leastactive")
//@Reference(loadbalance = "consistenthash")
@Reference(loadbalance = "random")//默认 按权重随机
private UserService userService;
集群容错
集群容错模式
- Failover Cluster:失败重试。默认值。当出现失败,重试其它服务器,默认重试2次,使用retries配置。一般用于读操作
- Failfast Cluster :快速失败,发起-次调用,失败立即报错。通常用于写操作
- Failsafe Cluster:失败安全,出现异常时,直接忽略。返回一个空结果
- Failback Cluster:失败自动恢复,后台记录失败请求,定时重发
- Forking Cluster :并行调用多个服务器,只要一个成功即返回
- broadcast Cluster: 广播调用所有提供者,逐个调用,任意一台报错则报错
步骤
1、消费者配置
@Reference(cluster = "failover")//远程注入
private UserService userService;
服务降级
概述
服务降级:当服务器压力剧增的情况下,根据实际业务情况及流量,对一些服务和页面有策略的不处理或换种简单的方式处理,从而释放服务器资源以保证核心交易正常运作或高效运作
服务降级方式:
mock= force:return null:表示消费方对该服务的方法调用都直接返回null值,不发起远程调用。用来屏蔽不重要服务不可用时对调用方的影响
mock=fail:return null:表示消费方对该服务的方法调用在失败后,再返回null值,不抛异常。用来容忍不重要服务不稳定时对调用方的影响
步骤
1、消费方配置
//远程注入
@Reference(mock =“ force :return null")//不再调用userService的服务
private UserService userService;
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。