搭建一个网站需要哪些技术,兰州吸引用户的网站设计,网站制作需要哪些东西,贵州网站制作设计公司哪家好本文已收录于专栏 《中间件合集》 目录 概念说明什么是HystrixHystrix解决的问题 提供服务工作流程代码实现HystrixSDKMyHystrixCommand注解MyHystrixProperty注解MyAspect注解解释器 发送请求端引入Hystrix的依赖调用代码 接收请求端执行效果发送请求端 总结提升 概念说明
什…本文已收录于专栏 《中间件合集》 目录 概念说明什么是HystrixHystrix解决的问题 提供服务工作流程代码实现HystrixSDKMyHystrixCommand注解MyHystrixProperty注解MyAspect注解解释器 发送请求端引入Hystrix的依赖调用代码 接收请求端执行效果发送请求端 总结提升 概念说明
什么是Hystrix Spring Cloud Hystrix 是基于 Netflix 公司的开源组件 Hystrix 实现的它提供了熔断器功能能够有效地阻止分布式微服务系统中出现联动故障以提高微服务系统的弹性。Spring Cloud Hystrix 具有服务降级、服务熔断、线程隔离、请求缓存、请求合并以及实时故障监控等强大功能。
Hystrix解决的问题 所有服务都需要请求服务T当B服务有大量的请求导致服务T所属的服务器CPU太高无法立即处理请求导致服务瘫痪。瘫痪之后就会导致所有的请求推挤在服务U然后一直向上堆积。这时候当服务A去访问服务T或者服务U的时候也请求不同。导致整个体统都瘫痪了。我们把这个情况成为灾难性的雪崩效应。Hystrix 就能很好的解决这一问题。
提供服务
Spring Cloud Hystrix提供了一系列强大的功能来处理分布式系统中的延迟和容错问题。下面是对这些功能的详细说明
「 服务降级Fallback」当一个服务发生故障或超时时Hystrix可以提供一个备用的响应或执行一些预定义的逻辑从而避免对整个系统的影响。通过定义降级逻辑例如返回默认值、执行备用方法或从缓存中获取数据可以保证系统的可用性。「 服务熔断Circuit Breaker」Hystrix可以根据一定的条件自动开启或关闭服务的熔断。当服务调用失败率达到一定阈值时Hystrix会自动开启熔断之后的请求将直接返回降级的响应避免对后端服务的继续调用从而保护后端服务免受进一步的压力。一段时间后Hystrix会尝试恢复对服务的调用如果调用成功则关闭熔断否则继续开启熔断。「 线程隔离Thread Isolation」Hystrix通过使用线程池隔离不同的服务调用可以防止一个服务的故障导致整个系统的故障。每个服务都运行在独立的线程池中从而提供了更好的资源隔离和保护。这样可以避免由于一个服务的延迟或故障导致其他服务的阻塞。「 请求缓存Request Caching」Hystrix可以缓存相同的请求结果以避免重复的调用。当多个请求需要调用同一个服务时Hystrix会先从缓存中查找结果如果存在则直接返回而不需要再次调用服务。这样可以减少对后端服务的请求次数提高系统的性能和吞吐量。「请求合并Request Collapsing 」Hystrix可以将多个相同类型的请求合并为一个批量请求从而减少网络开销和提高系统的性能。当多个请求需要调用同一个服务时Hystrix会将这些请求合并为一个批量请求并一次性发送给后端服务然后将结果拆分返回给各个请求。这样可以减少网络通信的次数提高系统的效率。「 实时故障监控Real-time Monitoring」Hystrix提供了实时监控和指标收集功能可以通过Hystrix Dashboard或Turbine来查看服务的健康状况、请求的响应时间、错误率等指标。这样可以帮助开发人员快速发现和解决问题保证系统的稳定性和可靠性。 通过使用Spring Cloud Hystrix我们可以更好地处理分布式系统中的故障和延迟问题提高系统的可靠性和容错性。
工作流程 当在5秒内A服务向B服务发送了10个请求并且满足错误率达到50%。那么断路器开启进行熔断机制在30秒内不在请求B服务直接请求我们定义的托底方法。这些参数例如5s、10个请求、错误率都是可以在代码中进行配置的。根据不同的需求填写不同的参数。
代码实现
HystrixSDK
sdk是每个请求的发送端需要引入的服务使用sdk中的一些注解来完成具体的服务
MyHystrixCommand注解
package com.example.hystrixdemo.utils;import com.netflix.hystrix.contrib.javanica.annotation.HystrixException;
import com.netflix.hystrix.contrib.javanica.annotation.ObservableExecutionMode;import java.lang.annotation.*;Target({ElementType.METHOD})
Retention(RetentionPolicy.RUNTIME)
Inherited //表示注解可以被子类继承
public interface MyHystrixCommand {String groupKey() default ;String commandKey() default ;String threadPoolKey() default ;String fallbackMethod() default ;MyHystrixProperty[] commandProperties() default {};MyHystrixProperty[] threadPoolProperties() default {};Class? extends Throwable[] ignoreExceptions() default {};ObservableExecutionMode observableExecutionMode() default ObservableExecutionMode.EAGER;HystrixException[] raiseHystrixExceptions() default {};String defaultFallback() default ;}
MyHystrixProperty注解
package com.example.hystrixdemo.utils;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;Target({ElementType.METHOD})
Retention(RetentionPolicy.RUNTIME)
public interface MyHystrixProperty {String name();String value();
}
MyAspect注解解释器
package com.example.hystrixdemo.utils;import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.Calendar;
import java.util.Date;/*** BelongsProject: hystrixDemo* BelongsPackage: com.example.hystrixdemo.utils* Author: Wuzilong* Description: 注解解释器* CreateTime: 2023-09-21 10:50* Version: 1.0*/
Aspect
Component
public class MyAspect {Integer requestNum 0;Date newTime null;Date newDelayTimenull;Boolean isDelayTime false;AfterThrowing(pointcut execution(* com.example..*.*(..)),throwing ex)public Object afterThrowing(JoinPoint joinPoint,Exception ex) throws InvocationTargetException, IllegalAccessException, NoSuchMethodException {try {MethodSignature methodSignature (MethodSignature) joinPoint.getSignature();Method method1 methodSignature.getMethod();if (method1.isAnnotationPresent(MyHystrixCommand.class)) {MyHystrixCommand annotation method1.getAnnotation(MyHystrixCommand.class);MyHystrixProperty[] myHystrixProperties annotation.commandProperties();if (myHystrixProperties.length 0) {Method method2 joinPoint.getTarget().getClass().getMethod(annotation.fallbackMethod());return method2.invoke(joinPoint.getTarget());} else {if (newDelayTime ! null new Date().compareTo(newDelayTime)0) {isDelayTimefalse;newTime null;newDelayTimenull;}if (isDelayTime) {Method method2 joinPoint.getTarget().getClass().getMethod(annotation.fallbackMethod());method2.invoke(joinPoint.getTarget());} else {String numValue null;String timeValue null;String errorRateValue null;String delayTimeValue null;for (MyHystrixProperty property : myHystrixProperties) {if (property.name().equals(requestNum)) {numValue property.value();} else if (property.name().equals(requestTime)) {timeValue property.value();} else if (property.name().equals(requestErrorRate)) {errorRateValue property.value();} else if (property.name().equals(requestDelayTime)) {delayTimeValue property.value();}}requestNum;if (newTimenull){// 创建Calendar对象并设置为当前时间Calendar calendar Calendar.getInstance();calendar.setTime(new Date());// 将Calendar对象的毫秒数加上任意值这里假设增加1000毫秒calendar.add(Calendar.MILLISECOND, Integer.valueOf(timeValue));newTimecalendar.getTime();}if (new Date().compareTo(newTime) 0){if (requestNum Integer.valueOf(numValue)) {double i Double.valueOf(numValue) / requestNum * 100;if (i Integer.valueOf(errorRateValue)) {isDelayTime true;if (newDelayTimenull){// 创建Calendar对象并设置为当前时间Calendar calendar Calendar.getInstance();calendar.setTime(new Date());// 将Calendar对象的毫秒数加上任意值这里假设增加1000毫秒calendar.add(Calendar.MILLISECOND, Integer.valueOf(delayTimeValue));newDelayTimecalendar.getTime();}requestNum 0;Method method2 joinPoint.getTarget().getClass().getMethod(annotation.fallbackMethod());return method2.invoke(joinPoint.getTarget());}}}}}}} catch (Exception e) {System.out.println(通过异常进入到AOP中调用了托底方法);}return null;}
} 声明两个注解分别用来设置服务降级和熔断操作的。MyHystrixCommand注解中会指定降级的方法。其中也包括MyHystrixProperty注解来指定熔断操作开启的一些参数例如请求的时间、请求的次数、请求错误率等等。MyAspect类去识别两个注解处理对应的业务逻辑。
发送请求端
引入Hystrix的依赖 dependencygroupIdcom.example/groupIdartifactIdhystrixDemo/artifactIdversion1.0-SNAPSHOT/version/dependency调用代码
package com.example.useraservice.service;import com.example.hystrixdemo.utils.MyHystrixCommand;
import com.example.hystrixdemo.utils.MyHystrixProperty;
import com.example.openfeigndemo.config.FeignConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** BelongsProject: UserAService* BelongsPackage: com.example.useraservice.service* Author: Wuzilong* Description: 描述什么人干什么事儿* CreateTime: 2023-07-26 08:40* Version: 1.0*/
Service
public class UserA {Autowiredprivate FeignConfig feignConfig;MyHystrixCommand(fallbackMethod errorMsg,commandProperties {MyHystrixProperty(name requestNum, value 3), //请求次数MyHystrixProperty(name requestTime, value 10000), //请求的单位时间MyHystrixProperty(name requestErrorRate, value 50), //错误率MyHystrixProperty(name requestDelayTime, value 20000) //熔断持续时间})public String userA(){System.out.println(进入A服务的方法了,去访问B服务。);IUserBService iUserBService(IUserBService)feignConfig.getAgentObject();String returnContext iUserBService.getServiceBInfo();System.out.println(B服务返回的内容是returnContext);return A服务调用B服务;}public String errorMsg() {System.out.println(你有异常啦);return 你有异常了;}
}
package com.example.useraservice.controller;import com.example.useraservice.service.UserA;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;/*** BelongsProject: UserAService* BelongsPackage: com.example.useraservice.controller* Author: Wuzilong* Description: 描述什么人干什么事儿* CreateTime: 2023-07-26 15:44* Version: 1.0*/
RestController
RequestMapping(/serviceA)
public class UserAController {Autowiredprivate UserA userA;RequestMapping(valueserviceAInfo,method RequestMethod.GET)public void getServiceAInfo(){try{userA.userA();}catch (Exception e){System.out.println(通过异常进入到AOP中已调用了托底方法);}}
}接收请求端
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.net.InetAddress;
import java.net.UnknownHostException;/*** BelongsProject: ServiceB* BelongsPackage: com.example.serviceb.Controller* Author: Wuzilong* Description: B服务* CreateTime: 2023-06-07 19:08* Version: 1.0*/
RestController
RequestMapping(/B)
public class ServiceBController {Value(${server.port})private String serverPort;GetMapping(/receiveMessage)public String receiveMessage() throws UnknownHostException {System.out.println(B我被调用了);//返回的内容是ip地址和端口号return InetAddress.getLocalHost().getHostAddress():serverPort;}
}执行效果
发送请求端 B服务没有启动所以在请求的过程中或报错由于配置了hystrix所以在报错的时候会进行降级或者熔断操作。
总结提升 Hystrix是一个强大的工具可以帮助开发人员处理分布式系统中的故障和延迟问题提高系统的可用性和性能。它的各种功能和特点使得开发人员能够更好地控制和管理系统的运行状态提供更好的用户体验。 此文章对你有用的话记得留言点赞收藏哦
