基于requestcache请求通达信专业接口,缓存技术优化批量商品数据查询接口
Hystrixcommand执行时8大步骤第三步，就是检查Requestcache是否有通达信专业接口,缓存。
有一个概念，叫做RequestContext请求上下文，一般来说，在一个web应用中，如果我们用到了Hystrix，我们会在一个filter里面，对每一个请求都施加一个请求上下文。就是说，每一次请求，就是一次请求上下文。然后在这次请求上下文中，我们会去执行N多代码，调用N多依赖服务，有的依赖服务可能还会调用好几次。
在一次请求上下文中，如果有多个command，参数都是一样的，调用的接口也是一样的，而结果可以认为也是一样的。那么这个时候，我们可以让第一个command执行返回的结果通达信专业接口,缓存在内存中，然后这个请求上下文后续的其它对这个依赖的调用全部从内存中取出通达信专业接口,缓存结果就可以了。
这样的话，好处在于不用在一次请求上下文中反复多次执行一样的command，避免重复执行网络请求，提升整个请求的性能。
举个栗子。比如说我们在一次请求上下文中，请求获取productId为1的数据，第一次通达信专业接口,缓存中没有，那么会从商品服务中获取数据，返回最新数据结果，同时将数据通达信专业接口,缓存在内存中。后续同一次请求上下文中，如果还有获取productId为1的数据的请求，直接从通达信专业接口,缓存中取就好了。
HystrixCommand和HystrixObservableCommand都可以指定一个通达信专业接口,缓存key，然后Hystrix会自动进行通达信专业接口,缓存，接着在同一个requestcontext内，再次访问的话，就会直接取用通达信专业接口,缓存。
下面，我们结合一个具体的业务场景，来看一下如何使用requestcache请求通达信专业接口,缓存技术。以下代码只作为一个基本的Demo而已。
现在，假设我们要做一个批量查询商品数据的接口，在这个里面，我们是用HystrixCommand一次性批量查询多个商品id的数据。但是这里有个问题，如果说Nginx在本地通达信专业接口,缓存失效了，重新获取一批通达信专业接口,缓存，传递过来的productIds都没有进行去重，比如productIds=1,1,1,2,那么可能说，商品id出现了重复，如果按照我们之前的业务逻辑，可能就会重复对productId=1的商品查询三次，productId=2的商品查询两次。
我们对批量查询商品数据的接口，可以用requestcache做一个优化，就是说一次请求，就是一次requestcontext，对相同的商品查询只执行一次，其余重复的都走requestcache。
实现Hystrix请求上下文过滤器并注册
定义HystrixRequestContextFilter类，实现Filter接口。
/**
* Hystrix 请求上下文过滤器
*/
public class HystrixRequestContextFilter implements Filter {
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) {
HystrixRequestContext context = HystrixRequestContext.initializeContext();
try {
filterChain.doFilter(servletRequest, servletResponse);
} catch (IOException | ServletException e) {
e.printStackTrace();
} finally {
context.shutdown();
}
}
@Override
public void destroy() {
}
}
然后将该filter对象注册到SpringBootApplication中。
@SpringBootApplication
public class EshopApplication {
public static void main(String[] args) {
SpringApplication.run(EshopApplication.class, args);
}
@Bean
public FilterRegistrationBean filterRegistrationBean() {
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new HystrixRequestContextFilter());
filterRegistrationBean.addUrlPatterns('/*');
return filterRegistrationBean;
}
}
command重写getCacheKey()方法
在GetProductInfoCommand中，重写getCacheKey()方法，这样的话，每一次请求的结果，都会放在Hystrix请求上下文中。下一次同一个productId的数据请求，直接取通达信专业接口,缓存，无须再调用run()方法。
public class GetProductInfoCommand extends HystrixCommand {
private Long productId;
private static final HystrixCommandKey KEY = HystrixCommandKey.Factory.asKey('GetProductInfoCommand');
public GetProductInfoCommand(Long productId) {
super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey('ProductInfoService'))
.andCommandKey(KEY));
this.productId = productId;
}
@Override
protected ProductInfo run() {
String url = 'http://localhost:8081/getProductInfo?productId=' + productId;
String response = HttpClientUtils.sendGetRequest(url);
System.out.println('调用接口查询商品数据，productId=' + productId);
return JSONObject.parseObject(response, ProductInfo.class);
}
/**
* 每次请求的结果，都会放在Hystrix绑定的请求上下文上
*
* @return cacheKey 通达信专业接口,缓存key
*/
@Override
public String getCacheKey() {
return 'product_info_' + productId;
}
/**
* 将某个商品id的通达信专业接口,缓存清空
*
* @param productId 商品id
*/
public static void flushCache(Long productId) {
HystrixRequestCache.getInstance(KEY,
HystrixConcurrencyStrategyDefault.getInstance()).clear('product_info_' + productId);
}
}
这里写了一个flushCache()方法，用于我们开发手动删除通达信专业接口,缓存。
controller调用command查询商品信息
在一次web请求上下文中，传入商品id列表，查询多条商品数据信息。对于每个productId，都创建一个command。
如果id列表没有去重，那么重复的id，第二次查询的时候就会直接走通达信专业接口,缓存。
@Controller
public class CacheController {
/**
* 一次性批量查询多条商品数据的请求
*
* @param productIds 以,分隔的商品id列表
* @return 响应状态
*/
@RequestMapping('/getProductInfos')
@ResponseBody
public String getProductInfos(String productIds) {
for (String productId : productIds.split(',')) {
// 对每个productId，都创建一个command
GetProductInfoCommand getProductInfoCommand = new GetProductInfoCommand(Long.valueOf(productId));
ProductInfo productInfo = getProductInfoCommand.execute();
System.out.println('是否是从通达信专业接口,缓存中取的结果：' + getProductInfoCommand.isResponseFromCache());
}
return 'success';
}
}
发起请求
调用接口，查询多个商品的信息。
在控制台，我们可以看到以下结果。
调用接口查询商品数据，productId=1
是否是从通达信专业接口,缓存中取的结果：false
是否是从通达信专业接口,缓存中取的结果：true
是否是从通达信专业接口,缓存中取的结果：true
调用接口查询商品数据，productId=2
是否是从通达信专业接口,缓存中取的结果：false
是否是从通达信专业接口,缓存中取的结果：true
调用接口查询商品数据，productId=5
是否是从通达信专业接口,缓存中取的结果：false
第一次查询productId=1的数据，会调用接口进行查询，不是从通达信专业接口,缓存中取结果。而随后再出现查询productId=1的请求，就直接取通达信专业接口,缓存了，这样的话，效率明显高很多。
删除通达信专业接口,缓存
我们写一个UpdateProductInfoCommand，在更新商品信息之后，手动调用之前写的flushCache()，手动将通达信专业接口,缓存删除。
这样，以后查询该商品的请求，第一次就会走接口调用去查询最新的商品信息。
文章为作者独立观点，不代表 股票程序化软件自动交易接口观点
股民评论
量化策略优化2022-12-30
周四三大指数午后走势继续分化，沪指低位震荡，创业板指有所回落，多只高位股尾盘跳水。板块方面，医药股震荡走高，酒店板块全天强势，信创概念股持续活跃；旅游板块继续调整，地产、煤炭等权重板块集体低迷，教育板块午后走弱。总体来看，两市股票跌多涨少，超3200只股票飘绿，今日成交6147亿元。截至收盘，沪指报30770点，跌0.44%；深成指报109941点，跌0.13%；创指报23438点，涨0.48%。