版式设计模板网站,营销网络建设将给三夫户外带来哪些有益的影响?,淘宝客模板wordpress,苏州高端网站设计定制在微服务的开发中#xff0c;我们经常需要服务之间的调用#xff0c;并且为了提高效率使用异步的方式进行服务之间的调用#xff0c;在这种异步的调用情况下会有一个严重的问题#xff0c;丢失上文下 通过以上图片可以看出异步丢失上下文的原因是不在同一个线程#xff0c…在微服务的开发中我们经常需要服务之间的调用并且为了提高效率使用异步的方式进行服务之间的调用在这种异步的调用情况下会有一个严重的问题丢失上文下 通过以上图片可以看出异步丢失上下文的原因是不在同一个线程所有数据不能共享Wie了解决这个问题我们就需要把之前线程的请求头上下文在次存放到其他线程的请求头上下文就行具体实现如下 案例feign异步获取订单明细的案例代码
/*** 获取订单明细的vo* return*/Overridepublic OrderConfirmVo orderConfirm() {MemberResponseVo member OrderInterceptor.threadLocal.get();OrderConfirmVo orderConfirmVo new OrderConfirmVo();System.out.println(主线程 Thread.currentThread().getId());//获取主线程的请求头信息RequestAttributes requestAttributes RequestContextHolder.getRequestAttributes();//考虑到效率问题 使用异步编排CompletableFutureVoid getAddress CompletableFuture.runAsync(() - {//子线程中设置添加主线程的请求头信息 信息共享 否则远程调用异步处理丢失请求头信息RequestContextHolder.setRequestAttributes(requestAttributes);System.out.println(address Thread.currentThread().getId());//远程获取地址信息ListMemberAddressVo address memberFeignService.getAddress(member.getId());orderConfirmVo.setAddress(address);}, executor);CompletableFutureVoid getItem CompletableFuture.runAsync(() - {//子线程中设置添加主线程的请求头信息 信息共享 否则远程调用异步处理丢失请求头信息RequestContextHolder.setRequestAttributes(requestAttributes);System.out.println(item Thread.currentThread().getId());//远程获取购物项ListOrderItemVo currentUserCartItems cartFeignService.getCurrentUserCartItems();orderConfirmVo.setItems(currentUserCartItems);}, executor).thenRunAsync(()-{ListOrderItemVo items orderConfirmVo.getItems();//获取所有商品的idListString collect items.stream().map(item - item.getSkuId()).collect(Collectors.toList());ListLong skuIds collect.stream().map(item - {return Long.parseLong(item);}).collect(Collectors.toList());RListSkuHasStockVo skusHasStock wmsFeignService.getSkusHasStock(skuIds);ListSkuHasStockVo data skusHasStock.getData(new TypeReferenceListSkuHasStockVo() {});if(data! null){MapLong, Boolean collect1 data.stream().collect(Collectors.toMap(SkuHasStockVo::getSkuId, SkuHasStockVo::getHasStock));orderConfirmVo.setStocks(collect1);}},executor);//异步编排完成之后执行后续操作try {CompletableFuture.allOf(getAddress,getItem).get();} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}orderConfirmVo.setIntegration(member.getIntegration());orderConfirmVo.setPayPrice(orderConfirmVo.getPayPrice());orderConfirmVo.setTotal(orderConfirmVo.getTotal());//TODO 放重处理 生成token令牌储存在redisString token UUID.randomUUID().toString().replace(-, );orderConfirmVo.setOrderToken(token);redisTemplate.opsForValue().set(OrderConstant.ORDER_TOKENmember.getId(),token);return orderConfirmVo;}
