共计 4214 个字符，预计需要花费 11 分钟才能阅读完成。
丸趣 TV 小编给大家分享一下 Spring Cloud 中 Hystrix 缓存与合并请求的示例分析，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！
缓存与合并请求缓存注解
在 6.3 章节中，讲述了 Hystrix 的缓存功能，在 Spring Cloud 中，同样支持使用缓存，并且可以通过注解来实现。根据前面章节可知，缓存与合并请求功能，需要先初始化请求上下文才能实现。新建一个 javax.servlet.Filter，用于创建与销毁 Hystrix 的请求上下文，请见代码清单 6 -9。
代码清单 6 -19：
codes\06\6.4\spring-hystrix-invoker\src\main\java\org\crazyit\cloud\HystrixFilter.java
@WebFilter(urlPatterns = /* , filterName = hystrixFilter)
public class HystrixFilter implements Filter { public void init(FilterConfig filterConfig) throws ServletException { }
public void doFilter(ServletRequest request, ServletResponse response,
FilterChain chain) throws IOException, ServletException {
HystrixRequestContext context = HystrixRequestContext
.initializeContext();
try { chain.doFilter(request, response);
} finally { context.shutdown();
}
}
public void destroy() { }
}编写服务方法，使用 @CacheResult 注解进行修饰，请见代码清单 6 -20。
代码清单 6 -20：CacheService.java
@Component
public class CacheService {
@CacheResult
@HystrixCommand
public Person getPerson(Integer id) {
System.out.println( 执行 getPerson 方法
Person p = new Person();
p.setId(id);
p.setName( angus
return p;
}
}注意服务方法中，被调用一次就会进行一次控制台输出。在控制器的方法中，调用多次 getPerson 方法，控制器代码请见代码清单 6 -21。
代码清单 6 -21：
codes\06\6.4\spring-hystrix-invoker\src\main\java\org\crazyit\cloud\InvokerController.java
@RequestMapping(value = /cache1/{personId} , method = RequestMethod.GET,
produces = MediaType.APPLICATION_JSON_VALUE)
public Person testCacheResult(@PathVariable Integer personId) {
// 调用多次服务
for(int i = 0; i 3; i++) { Person p = cacheService.getPerson(personId);
System.out.println(控制器调用服务 + i);
}
return new Person();
}控制器中调用了多次服务方法，也就是用户发送请求后，会执行多次服务方法，启动“服务调用者”，访问以下地址：http://localhost:9000/cache1/1，控制台输出如下：
执行 getPerson 方法
控制器调用服务 0
控制器调用服务 1
控制器调用服务 2根据输出结果可知，在一次用户请求的过程中，服务方法只执行了一次，缓存生效。缓存的注解主要有以下 3 个：
@CacheResult：该注解修饰方法，表示被修饰的方法返回结果将会被缓存，需要与 @HystrixCommand 一起使用。
@CacheRemove：用于修饰方法让缓存失效，需要与 @CacheResult 的缓存 key 关联。
@CacheKey：用于修饰方法参数，表示该参数作为缓存的 key。
前面的例子使用了 @CacheResult 注解，下面的代码片断，结合 @CacheResult 与 @CacheRemove 一起使用：
@CacheResult()
@HystrixCommand(commandKey = removeKey)
public String cacheMethod(String name) {
return hello
}
@CacheRemove(commandKey = removeKey)
@HystrixCommand
public String updateMethod(String name) {
return update
}以上代码片断中的 cacheMethod 方法，使用的缓存 key 为“removeKey”，方法 updateMethod 被调用后，将会删除 key 为“updateMethod”的缓存。关于 3 个缓存注解更深入的使用，本小节不再赘述，读者可以自行测试。
合并请求注解
在 Spring Cloud 中，同样支持合并请求，在一次 HTTP 请求的过程中，收集一段时间内的相同请求，放到一个批处理命令中执行。实现合并请求，同样需要先初始化请求上下文，具体请参见 6.4.4 中的 Filter。接下来，编写服务类，请见代码清单 6 -22。
代码清单 6 -22：CollapseService.java
public class CollapseService {
// 配置收集 1 秒内的请求
@HystrixCollapser(batchMethod = getPersons , collapserProperties =
{
@HystrixProperty(name = timerDelayInMilliseconds , value = 1000)
}
)
public Future Person getSinglePerson(Integer id) {
System.out.println( 执行单个获取的方法
return null;
}
@HystrixCommand
public List Person getPersons(List Integer ids) { System.out.println( 收集请求，参数数量： + ids.size());
List Person ps = new ArrayList Person
for (Integer id : ids) { Person p = new Person();
p.setId(id);
p.setName( crazyit
ps.add(p);
}
return ps;
}
}代码清单中，最后真实执行的方法为“getPersons”，getSinglePerson 方法使用了 @HystrixCollapser 注解来修饰，会收集 1 秒内调用 getSinglePerson 的请求，放到 getPersons 方法中进行批处理。控制器中调用多次 getSinglePerson 方法，如代码清单 6 -23 所示。
代码清单 6 -23：
codes\06\6.4\spring-hystrix-invoker\src\main\java\org\crazyit\cloud\InvokerController.java
@RequestMapping(value = /collapse , method = RequestMethod.GET,
produces = MediaType.APPLICATION_JSON_VALUE)
public String testCollapse() throws Exception {
// 连续执行 3 次请求
Future Person f1 = collapseService.getSinglePerson(1);
Future Person f2 = collapseService.getSinglePerson(2);
Future Person f3 = collapseService.getSinglePerson(3);
Person p1 = f1.get();
Person p2 = f2.get();
Person p3 = f3.get();
System.out.println(p1.getId() + --- + p1.getName());
System.out.println(p2.getId() + --- + p2.getName());
System.out.println(p3.getId() + --- + p3.getName());
return
}异步执行了 3 次 getSinglePerson 方法，启动“服务调用者”，访问以下地址：http://localhost:9000/collapse，控制台输出如下：
收集请求，参数数量：3
1---crazyit
2---crazyit
3---crazyit根据输出结果可知，最终只执行了 getPersons 方法。相对于直接使用 Hystrix，Spring Cloud 中合并请求较为简单，合并处理器已经由 @HystrixCollapser 注解帮我们实现，我们仅关心真正命令的执行即可。
以上是“Spring Cloud 中 Hystrix 缓存与合并请求的示例分析”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注丸趣 TV 行业资讯频道！
