hystrix缓存的作用是
- 1.减少重复的请求数,降低依赖服务的返回数据始终保持一致。
- 2.==在同一个用户请求的上下文中,相同依赖服务的返回数据始终保持一致==。
- 3.请求缓存在run()和construct()执行之前生效,所以可以有效减少不必要的线程开销。
1 通过HystrixCommand类实现
1.1 开启缓存功能
继承HystrixCommand或HystrixObservableCommand,覆盖getCacheKey()方法,指定缓存的key,开启缓存配置。
import com.netflix.hystrix.HystrixCommand; import com.netflix.hystrix.HystrixCommandGroupKey; import com.netflix.hystrix.HystrixCommandKey; import com.netflix.hystrix.HystrixRequestCache; import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategyDefault; import com.szss.demo.orders.vo.UserVO; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.client.RestTemplate; public class UserCacheCommand extends HystrixCommand<UserVO> { private static final Logger LOGGER = LoggerFactory.getLogger(UserCacheCommand.class); private static final HystrixCommandKey GETTER_KEY= HystrixCommandKey.Factory.asKey("CommandKey"); private RestTemplate restTemplate; private String username; public UserCacheCommand(RestTemplate restTemplate, String username) { super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("userCacheCommand")).andCommandKey(GETTER_KEY)); this.restTemplate = restTemplate; this.username = username; } @Override protected UserVO run() throws Exception { LOGGER.info("thread:" + Thread.currentThread().getName()); return restTemplate.getForObject("http://users-service/user/name/{username}", UserVO.class, username); } @Override protected UserVO getFallback() { UserVO user = new UserVO(); user.setId(-1L); user.setUsername("调用失败"); return user; } @Override protected String getCacheKey() { return username; } public static void flushCache(String username){ HystrixRequestCache.getInstance(GETTER_KEY, HystrixConcurrencyStrategyDefault.getInstance()).clear(username); } }
1.2 配置HystrixRequestContextServletFilter
通过servlet的Filter配置hystrix的上下文。
import com.netflix.hystrix.strategy.concurrency.HystrixRequestContext; import javax.servlet.*; import javax.servlet.annotation.WebFilter; import java.io.IOException; @WebFilter(filterName = "hystrixRequestContextServletFilter",urlPatterns = "/*",asyncSupported = true) public class HystrixRequestContextServletFilter implements Filter { public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { HystrixRequestContext context = HystrixRequestContext.initializeContext(); try { chain.doFilter(request, response); } finally { context.shutdown(); } } @Override public void init(FilterConfig filterConfig) throws ServletException { } @Override public void destroy() { } }
在不同context中的缓存是不共享的,还有这个request内部一个ThreadLocal,所以request只能限于当前线程。
1.3 清除失效缓存
继承HystrixCommand或HystrixObservableCommand,在更新接口调用完成后,清空缓存。
import com.netflix.hystrix.HystrixCommand; import com.netflix.hystrix.HystrixCommandGroupKey; import com.netflix.hystrix.HystrixCommandKey; import com.szss.demo.orders.vo.UserVO; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.http.HttpEntity; import org.springframework.web.client.RestTemplate; public class UserUpdateCacheCommand extends HystrixCommand<UserVO> { private static final Logger LOGGER = LoggerFactory.getLogger(UserUpdateCacheCommand.class); private static final HystrixCommandKey GETTER_KEY = HystrixCommandKey.Factory.asKey("CommandKey"); private RestTemplate restTemplate; private UserVO user; public UserUpdateCacheCommand(RestTemplate restTemplate, UserVO user) { super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("userUpdateCacheCommand"))); this.restTemplate = restTemplate; this.user = user; } @Override protected UserVO run() throws Exception { LOGGER.info("thread:" + Thread.currentThread().getName()); HttpEntity<UserVO> u = new HttpEntity<UserVO>(user); UserVO userVO=restTemplate.postForObject("http://users-service/user",u,UserVO.class); UserCacheCommand.flushCache(user.getUsername()); return userVO; } // @Override // protected UserVO getFallback() { // UserVO user = new UserVO(); // user.setId(-1L); // user.setUsername("调用失败"); // return user; // } @Override protected String getCacheKey() { return user.getUsername(); } }
2 使用@CacheResult、@CacheRemove和@CacheKey标注来实现缓存
2.1 使用@CacheResult实现缓存功能
@CacheResult(cacheKeyMethod = "getCacheKey") @HystrixCommand(commandKey = "findUserById", groupKey = "UserService", threadPoolKey = "userServiceThreadPool") public UserVO findById(Long id) { ResponseEntity<UserVO> user = restTemplate.getForEntity("http://users-service/user?id={id}", UserVO.class, id); return user.getBody(); } public String getCacheKey(Long id) { return String.valueOf(id); }
@CacheResult注解中的cacheKeyMethod用来标示缓存key(cacheKey)的生成函数。函数的名称可任意取名,入参和标注@CacheResult的方法是一致的,返回类型是String。
2.2 使用@CacheResult和@CacheKey实现缓存功能
@CacheResult @HystrixCommand(commandKey = "findUserById", groupKey = "UserService", threadPoolKey = "userServiceThreadPool") public UserVO findById2(@CacheKey("id") Long id) { ResponseEntity<UserVO> user = restTemplate.getForEntity("http://users-service/user?id={id}", UserVO.class, id); return user.getBody(); }
标注@HystrixCommand注解的方法,使用@CacheKey标注需要指定的参数作为缓存key。
2.3 使用@CacheRemove清空缓存
@CacheRemove(commandKey = "findUserById") @HystrixCommand(commandKey = "updateUser",groupKey = "UserService",threadPoolKey = "userServiceThreadPool") public void updateUser(@CacheKey("id")UserVO user){ restTemplate.postForObject("http://users-service/user",user,UserVO.class); }
@CacheRemove必须指定commandKey,否则程序无法找到缓存位置。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持小牛知识库。
本文向大家介绍详解Mybatis的缓存,包括了详解Mybatis的缓存的使用技巧和注意事项,需要的朋友参考一下 Mybatis的缓存 mybatis是一个查询数据库的封装框架,主要是封装提供灵活的增删改sql,开发中,service层能够通过mybatis组件查询和修改数据库中表的数据;作为查询工具,mybatis有使用缓存,这里讲一下mybatis的缓存相关源码。 缓存 在计算机里面,任何信息都
本文向大家介绍Android WebView 缓存详解,包括了Android WebView 缓存详解的使用技巧和注意事项,需要的朋友参考一下 Android WebView 缓存详解 一. 两种缓存类型: 页面缓存:加载一个网页时的html、JS、CSS等页面或者资源数据,这些缓存资源是由于浏览器 的行为而产生,开发者只能通过配置HTTP响应头影响浏览器的行为才能间接地影响到这些缓存数据。 而
本文向大家介绍详解Java的MyBatis框架中的缓存与缓存的使用改进,包括了详解Java的MyBatis框架中的缓存与缓存的使用改进的使用技巧和注意事项,需要的朋友参考一下 一级缓存与二级缓存 MyBatis将数据缓存设计成两级结构,分为一级缓存、二级缓存: 一级缓存是Session会话级别的缓存,位于表示一次数据库会话的SqlSession对象之中,又被称之为本地缓存。一级缓存是MyBatis
本文向大家介绍使用C++扩展Python的功能详解,包括了使用C++扩展Python的功能详解的使用技巧和注意事项,需要的朋友参考一下 本文主要研究的是使用C++扩展Python的功能的相关问题,具体如下。 环境 VS2005Python2.5.4Windows7(32位) 简介 长话短说,这里说的扩展Python功能与直接用其它语言写一个动态链接库,然后让Python来调用有点不一样(虽然本质是
本文向大家介绍Spring Boot 基于注解的 Redis 缓存使用详解,包括了Spring Boot 基于注解的 Redis 缓存使用详解的使用技巧和注意事项,需要的朋友参考一下 看文本之前,请先确定你看过上一篇文章《Spring Boot Redis 集成配置》并保证 Redis 集成后正常可用,因为本文是基于上文继续增加的代码。 一、创建 Caching 配置类 RedisKeys.Jav
本文向大家介绍MyBatis缓存功能原理及实例解析,包括了MyBatis缓存功能原理及实例解析的使用技巧和注意事项,需要的朋友参考一下 缓存 1、简介 查询 : 连接数据库,耗资源! 一次查询的结果,给他暂存在一个可以直接取到的地方!--->内存 : 缓存 我们再次查询相同数据的时候,直接走缓存,就不用走数据库了 什么是缓存: 存在内存中的临时数据 将用户经常查询的数据放在缓存(内存)中,用户去查