如何使用Hystrix实现服务请求缓存?

标签: Java

保留所有版权,请引用而不是转载本文(原文地址 https://yeecode.top/blog/132/ )。

概述

Hystrix支持在方法层面增加缓存,这样,当下次在请求该方法时,如果存在缓存,则可以直接走缓存而不用执行方法。

环境配置

通过Hystrix就可以方便地实现这一操作。接下来,我们给出简单的示例。

首先,准备SpringBoot项目,然后在其中引入适用于SpringBoot的hystrix包:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    <version>2.2.7.RELEASE</version>
</dependency>

注意,如果这时候启动提示如下的错误,则基本是SpringBoot版本与hystrix版本不匹配导致的。因为hystrix是基于SpringCloud的,而SpringCloud和SpringBoot存在版本对应关系。如果对应不一致,则可能导致出现下面的错误。

java.lang.NoSuchMethodError: 'void org.springframework.boot.builder.SpringApplicationBuilder.<init>(java.lang.Object[])'

这里我们给出一个可用的对应版本,即SpringBoot的2.3.5.RELEASE和spring-cloud-starter-netflix-hystrix的2.2.7.RELEASE。它们这一对是肯定没有问题的。

然后,我们需要在SpringBoot的主类上增加@EnableHystrix注解,以启用Hystrix。如下所示。

@SpringBootApplication
@EnableHystrix
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

环境配置就是这么简单,接下来我们就可以写业务代码了。

功能实现

缓存时,默认会将所有的入参共同作为缓存的键,也就是说下次调用时只有全部入参完全一致才会走缓存。另外,我们也可以使用@CacheKey注解来指定缓存的键。此外,我们还可以指定一个方法,以该方法的返回值作为缓存的键。这种通过方法指定键的方式具有最高的优先级。要注意的是,这个方法必须和原方法在同一个类中,且入参与原方法完全一致、返回值必须为String。

为了能够清除缓存,我们还可以指定一个缓存清理方法。当调用该方法时,指定方法的缓存将会被清理。

我们先给出请求缓存的示例代码:

@CacheResult(cacheKeyMethod = "getUserCacheKey")
@HystrixCommand(
        commandKey = "CacheService_queryUserNameById",
        commandProperties = {
                // 启用请求缓存功能(默认也是启用的)
                @HystrixProperty(name = HystrixPropertiesManager.REQUEST_CACHE_ENABLED, value = "true"),
        }
)
String queryUserNameById(int i) {
    System.out.println("正在查询用户名,用户编号为" + i);
    return "易哥" + i;
}

@CacheRemove(commandKey = "CacheService_queryUserNameById",
        cacheKeyMethod = "getUserCacheKey")
@HystrixCommand
void clearUserResult(int i) {
    System.out.println("入参" + i + "对应的缓存已清空 ");
}

String getUserCacheKey(int i) {
    return "CACHE_KEY_" + i;
}

在介绍上述示例代码的同时,我们顺便详细介绍两个注解。注解的介绍参考《高性能架构之道(第二版)》这本书,本文的示例代码也来自这本书。大家如果想要系统学习Hystrix的话,建议读下该书。

了解了以上内容后,我们就可以通过下面的代码对上述方法进行调用:

StringBuilder stringBuilder = new StringBuilder();
HystrixRequestContext context = HystrixRequestContext.initializeContext();
for (int i = 1; i <= 3; i++) {
    stringBuilder.append(cacheService.queryUserNameById(303)).append("\r\n");
    stringBuilder.append(cacheService.queryUserNameById(316)).append("\r\n");
    stringBuilder.append(cacheService.queryUserNameById(808)).append("\r\n");
    cacheService.clearUserResult(808);
}
context.close();
return stringBuilder.toString();

控制台上可以看到如下的输出:

正在查询用户名,用户编号为303
正在查询用户名,用户编号为316
正在查询用户名,用户编号为808
入参808对应的缓存已清空 
正在查询用户名,用户编号为808
入参808对应的缓存已清空 
正在查询用户名,用户编号为808
入参808对应的缓存已清空 

可见,缓存和清理功能均可正常生效。

参数详解

以上实现的是最简单的缓存示例,也仅仅使用了最简单的参数,而其他参数都是用的默认值。但是这个作为示例是可以的,真正使用时,大家还是要对Hystrix的各个参数有详细的了解,至少也要知道大体的含义和默认值。否则,后续使用中,可能会遇到不少百思不得其解的地方。

总之,Hystrix要比这个强大的多。大家还是要好好学一下。

下面是我对@HystrixCommand参数的介绍,主要是摘抄参考了《高性能架构之道(第二版)》这本书。上面的示例也是参考的书里的。下面的参数我这里列的不是很全,如果要细致学习的话,十分建议大家去看下这本书。

好了,以上就是Hystrix实现请求方法缓存的简单示例。

可以访问个人知乎阅读更多文章:易哥(https://www.zhihu.com/people/yeecode),欢迎关注。

作者书籍推荐