Spring Cloud ConfigClient构建
学习spring cloud config client,构建简单的许可证服务,通过Eureka服务发现来查询ConfigServer服务,并使用客户端弹性模式来保证服务能够快速失败,记录构建中所遇到的问题和学习总结。
1.MySQL的时区错误问题
当配置完后,在获取数据库数据时报错:The server time zone value 'Öйú±ê׼ʱ¼ä' is unrecognized or represents more than one time zone
。
解决办法:
- 1.设置时区
set global time_zone='+8:00'
。 - 2.在配置的
spring.datasource.url
项后添加时区属性jdbc:mysql://127.0.0.1:3306/test?serverTimezone=Asia/Shanghai
2.客户端弹性模式
当服务崩溃时,很容易检测到该服务已经不在了,因此应用程序可以绕开它,但是当服务运行缓慢时,检测到此服务并绕开它时非常困难的。主要是因为:
- 服务的降级可以以间歇性问题开始,并形成不可逆转的势头(降级可能只发生在很小的爆发中)。故障的第一个迹象可能是一小部分用户抱怨某个问题,直到
突然之间应用程序容器耗尽了线程池并彻底崩溃; - 对远程服务的调用通常是同步的,并且不会缩短长时间运行的调用(服务调用者没有超时的概念来阻止服务调用的永久挂起)。
- 应用程序经常被设计为处理远程资源的彻底故障,而不是部分降级。通常,只要服务没有彻底失败,应用程序将继续调用该服务,并且不会采取快速失败
措施。
客户端弹性模式的重点在于,当远程服务发生错误或者表现不佳时保护远程资源(另一个微服务调用和数据库查询)的客户端免于崩溃,目标是让客户端“快速失败”,而不消耗诸如数据库连接和线程池之类的宝贵资源,并且可以防止远程服务的问题向客户端的消费者进行上游传播。
2.1 断路器模式
模仿电路断路器的客户端弹性模式,当远程服务被调用时,断路器将监视此调用,若调用时间太长,断路器将会介入并中断调用。此外,断路器将监视所以对远程资源的调用,如果对某一远程资源的调用失败次数足够多,那么断路器实现就会出现并采取快速失败,阻止将来调用失败的远程资源。
需要在项目的pom.xml
文件中导入Spring Hystrix
依赖项:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
<version>1.4.6.RELEASE</version>
</dependency>
使用@EnableCircuitBreaker
注解标注服务的引导类,开启断路器;使用方法级注解@HystrixCommand
,使被标记的调用拥有断路器功能,它将动态生成一个代理,该代理将包装此方法,并通过专门用于处理远程调用的线程池来管理对该方法的所有调用。
2.2 后备模式
当远程服务调用失败时,服务消费者将执行替代代码路径,并尝试通过其他方式执行操作,而不是生成一个异常。通常涉及从另一数据源查找数据或将用户的请求进行排队以供处理。要使用Hystrix是实现一个后备策略,需要完成:
- 定义一个待执行的后备方法,此方法必须与由
@HystrixCommand
注解保护的原始方法位于同一个类中; - 通过在
@HystrixCommand
注解中添加一个名为fallbackMethod
的属性,此属性包含上述的后备方法名;
2.3舱壁模式
在基于微服务的应用程序中,开发人员通常需要调用多个微服务来完成特定的任务。在不使用舱壁模式的情况下,这些调用默认使用同一批线程来执行调用,这些线程时为了处理整个JAVA容器的请求而预留的。
在存在大量请求的情况下,一个服务出现性能问题会导致JAVA容器的所有线程被刷爆并等待处理工作,同时阻塞新请求,最终导致JAVA容器崩溃。
舱壁模式将远程资源调用隔离在它们自己的线程池中,以便可以控制单个表现不佳的服务,而不会使该容器崩溃。如果一个服务响应缓慢,那么这种服务调用的线程池就会饱和并停止处理请求,而对其他服务的服务调用则不会变得饱和。
-
在
@HystrixCommand
注解中引入一个新的属性threadPoolKey
,建立一个新的线程池; -
定制线程池,使用
@HystrixCommand
注解上的threadPoolProperties
属性。此属性使用HystrixProperty对象数组,用于控制线程池的行为;-
@HystrixProperty
(name="coreSize",value="30")设置线程池大小; -
@HystrixProperty
(name="maxQueueSize",value="10")设置同步队列大小;
-