@Component
public class LoginUserInterceptor implements HandlerInterceptor {
    public static ThreadLocal<MemberResVo> loginUser = new ThreadLocal<>();
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {

        //獲取登錄用戶的鍵
        MemberResVo attribute = (MemberResVo) request.getSession().getAttribute(AuthServerConstant.LONG_USER);
        if (attribute!=null){
            loginUser.set(attribute);
            return true;
        }else {
            request.getSession().setAttribute("msg","請先進(jìn)行登錄！");
            response.sendRedirect("http://auth.gulimall.com/login.html");
            return false;
        }
    }
}

import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
@Configuration
public class GuliFeignConfig {
    //fegin過濾器
    @Bean("requestInterceptor")
    public RequestInterceptor requestInterceptor() {
        return new RequestInterceptor() {
            public void apply(RequestTemplate template) {
                //上下文環(huán)境保持器,拿到剛進(jìn)來這個(gè)請求包含的數(shù)據(jù)，而不會因?yàn)檫h(yuǎn)程數(shù)據(jù)請求頭被清除
                ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
                HttpServletRequest request = attributes.getRequest();//老的請求
                if (request != null) {
                    //同步老的請求頭中的數(shù)據(jù)，這里是獲取cookie
                    String cookie = request.getHeader("Cookie");
                    template.header("Cookie", cookie);
                }
            }
        };
    }
}

RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes()

@Service("orderService")
public class OrderServiceImpl extends ServiceImpl<OrderDao, OrderEntity>
implements OrderService {
    @Autowired
    MemberFeignService memberFeignService;
    @Autowired
    CartFeginService cartFeginService;
    @Autowired
    ThreadPoolExecutor executor;
    @Autowired
    WmsFeignService wmsFeignService;

    /**
     * 訂單確認(rèn)頁返回的數(shù)據(jù)
     * @return
     */
    @Override
    public OrderConfirmVo confirmOrder() throws ExecutionException, InterruptedException {
        OrderConfirmVo confirmVo = new OrderConfirmVo();
        MemberResVo memberResVo = LoginUserInterceptor.loginUser.get();
        //從主線程中獲得所有request數(shù)據(jù)
        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
        CompletableFuture<Void> getAddressFuture = CompletableFuture.runAsync(() -> {
            //1、遠(yuǎn)程查詢所有地址列表
            RequestContextHolder.setRequestAttributes(requestAttributes);
            List<MemberAddressVo> address = memberFeignService.getAddress(memberResVo.getId());
            confirmVo.setAddress(address);
        }, executor);

        //2、遠(yuǎn)程查詢購物車所選的購物項(xiàng),獲得所有購物項(xiàng)數(shù)據(jù)
        CompletableFuture<Void> cartFuture = CompletableFuture.runAsync(() -> {
            //放入子線程中request數(shù)據(jù)
            RequestContextHolder.setRequestAttributes(requestAttributes);
            List<OrderItemVo> items = cartFeginService.getCurrentUserCartItems();
            confirmVo.setItem(items);
        }, executor).thenRunAsync(()->{
            RequestContextHolder.setRequestAttributes(requestAttributes);
            List<OrderItemVo> items = confirmVo.getItem();
            List<Long> collect = items.stream().map(item -> item.getSkuId()).collect(Collectors.toList());
            //遠(yuǎn)程調(diào)用查詢是否有庫存
            R hasStock = wmsFeignService.getSkusHasStock(collect);
            //形成一個(gè)List集合，獲取所有物品是否有貨的情況
            List<SkuStockVo> data = hasStock.getData(new TypeReference<List<SkuStockVo>>() {
            });
            if (data!=null){
                //收集起來，Map<Long,Boolean> stocks;
                Map<Long, Boolean> map = data.stream().collect(Collectors.toMap(SkuStockVo::getSkuId, SkuStockVo::getHasStock));
                confirmVo.setStocks(map);
            }
        },executor);
        //feign遠(yuǎn)程調(diào)用在調(diào)用之前會調(diào)用很多攔截器，因此遠(yuǎn)程調(diào)用會丟失很多請求頭

        //3、查詢用戶積分
        Integer integration = memberResVo.getIntegration();
        confirmVo.setIntegration(integration);
        //其他數(shù)據(jù)自動(dòng)計(jì)算

        CompletableFuture.allOf(getAddressFuture,cartFuture).get();
        return confirmVo;
    }

}