【业务功能篇98】微服务-springcloud-springboot-电商订单模块-接口幂等性处理-订单提交防重检查-Fegin调用远程服务的时候会出现请求Header丢失的问题及解决方案

左手的ㄟ右手 2024-03-08 08:19 19阅读 0赞

## 订单模块 ##

## 一、资源整合 ##

我们需要把相关的静态资源拷贝到nginx，然后动态模板文件拷贝到order项目的templates目录下，然后调整资源的路径。在网关中设置对应的路由即可。

## 二、整合SpringSession ##

结合官网，导入对应的依赖，然后添加对应的配置信息，redis配置信息，Cookie的配置一级域名和二级域名。

## 三、订单中心 ##

订单中心涉及到的模块

![image.png][]

订单的状态：

1.  待付款:提交订单，订单预下单
2.  已付款/待发货：完成支付，订单系统需要记录支付时间，支付流水号便于对账，订单下放到wms系统，仓库进行调拨，配货，分拣，出库等操作
3.  待收款/已发货:仓库将商品出库，订单进入物流环节
4.  已完成:用户确认收货，订单交易完成，后续支付侧进行结算，如果订单存在问题就进入售后状态
5.  已取消:付款之前取消订单。
6.  售后中：用户在付款后申请退款，或商家发货后用户申请退换货。

订单流程：

![image.png][image.png 1]

## 四、认证拦截 ##

订单服务中的所有的请求都必须是在认证的状态下处理的，所有我们需要添加一个校验是否认证的拦截器

package com.msb.mall.order.interceptor;
    
    import com.msb.common.constant.AuthConstant;
    import com.msb.common.vo.MemberVO;
    import org.springframework.web.servlet.HandlerInterceptor;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import javax.servlet.http.HttpSession;
    
    public class AuthInterceptor implements HandlerInterceptor {
        
    
        public static ThreadLocal threadLocal = new ThreadLocal();
    
        @Override
        public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        
            // 通过HttpSession获取当前登录的用户信息
            HttpSession session = request.getSession();
            Object attribute = session.getAttribute(AuthConstant.AUTH_SESSION_REDIS);
            if(attribute != null){
        
                MemberVO memberVO = (MemberVO) attribute;
                threadLocal.set(memberVO);
                return true;
            }
            // 如果 attribute == null 说明没有登录，那么我们就需要重定向到登录页面
            session.setAttribute(AuthConstant.AUTH_SESSION_MSG,"请先登录");
            response.sendRedirect("http://auth.msb.com/login.html");
            return false;
        }
    }

然后注册该拦截器即可

@Configuration
    public class MyWebInterceptorConfig implements WebMvcConfigurer {
        @Override
        public void addInterceptors(InterceptorRegistry registry) {
            registry.addInterceptor(new AuthInterceptor()).addPathPatterns("/**");
        }
    
    }

## 五、订单确认页 ##

### 1.订单确认页VO抽取 ###

public class OrderConfirmVo {
        
    
        // 订单的收货人 及 收货地址信息
        @Getter @Setter
        List<MemberAddressVo> address;
        // 购物车中选中的商品信息
        @Getter @Setter
        List<OrderItemVo> items;
        // 支付方式
        // 发票信息
        // 优惠信息
    
        //Integer countNum;
    
        public Integer getCountNum(){
        
            int count = 0;
            if(items != null){
        
                for (OrderItemVo item : items) {
        
                    count += item.getCount();
                }
            }
            return count;
        }
    
        // BigDecimal total ;// 总的金额
        public BigDecimal getTotal(){
        
            BigDecimal sum = new BigDecimal(0);
            if(items != null ){
        
                for (OrderItemVo item : items) {
        
                    BigDecimal totalPrice = item.getPrice().multiply(new BigDecimal(item.getCount()));
                    sum = sum.add(totalPrice);
                }
            }
            return sum;
        }
        // BigDecimal payTotal;// 需要支付的总金额
        public BigDecimal getPayTotal(){
        
            return getTotal();
        }
    }

### 2.确认页数据获取 ###

通过Fegin远程调用对应的服务，获取会员的数据和购物车中的商品信息。

@Override
        public OrderConfirmVo confirmOrder() {
        
            OrderConfirmVo vo = new OrderConfirmVo();
            MemberVO memberVO = (MemberVO) AuthInterceptor.threadLocal.get();
            // 获取到 RequestContextHolder 的相关信息
            RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
            CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> {
        
                // 同步主线程中的 RequestContextHolder
                RequestContextHolder.setRequestAttributes(requestAttributes);
                // 1.查询当前登录用户对应的会员的地址信息
                Long id = memberVO.getId();
                List<MemberAddressVo> addresses = memberFeginService.getAddress(id);
                vo.setAddress(addresses);
            }, executor);
            CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> {
        
                RequestContextHolder.setRequestAttributes(requestAttributes);
                // 2.查询购物车中选中的商品信息
                List<OrderItemVo> userCartItems = cartFeginService.getUserCartItems();
                vo.setItems(userCartItems);
            }, executor);
            try {
        
                CompletableFuture.allOf(future1,future2).get();
            } catch (Exception e) {
        
                e.printStackTrace();
            }
            // 3.计算订单的总金额和需要支付的总金额 VO自动计算
            return vo;
        }

在Fegin调用远程服务的时候会出现请求Header丢失的问题。

![image.png][image.png 2]

![image.png][image.png 3]

首先我们创建 `RequestInterceptor`的实现来绑定Header信息，同时在异步处理的时候我们需要从主线程中获取Request信息，然后绑定在子线程中。

1.添加对应的RequestInterceptor配置类绑定Header信息

package com.msb.mall.order.config;
    
    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 MallFeginConfig {
        
    
        @Bean
        public RequestInterceptor requestInterceptor(){
        
            return new RequestInterceptor() {
        
                @Override
                public void apply(RequestTemplate requestTemplate) {
        
                    System.out.println("RequestInterceptor："+Thread.currentThread().getName());
                    ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
                    HttpServletRequest request = requestAttributes.getRequest();
                    String cookie = request.getHeader("Cookie");
                    requestTemplate.header("Cookie",cookie);
                }
            };
        }
    }

2.主线程中获取Request信息，然后绑定在子线程中。  
![image.png][image.png 4]

然后在订单确认页中渲染数据的展示

![image.png][image.png 5]

![image.png][image.png 6]

![image.png][image.png 7]

最后的页面效果

![image.png][image.png 8]

## 六、接口幂等性处理 ##

幂等性： 多次调用方法或者接口不会改变业务状态，可以保证重复调用的结果和单次调用的结果一致。

### 1.天然的幂等行为 ###

以SQL语句为例：

select * from t_user where id = 1;
    update t_user set age = 18 where id = 2;
    delete from t_user where id = 1
    insert into (userid,username)values(1,'波哥') ; # userid 唯一主键

不具备幂等行为的

update t_user set age = age + 1 where id = 1;
    insert into (userid,username)values(1,'波哥'); # userid 不是主键 可以重复

### 2.**需要使用幂等的场景** ###

需要使用幂等的场景 ：

*  前端重复提交
 *  接口超时重试
 *  消息队列重复消费

### 3.解决方案 ###

1.  **token机制** ：①客户端请求获取token，服务端生成一个唯一ID作为token存在redis中；②客户端第二次请求时携带token，服务端校验token成功则执行业务操作并删除token，服务端校验token失败则表示重复操作。
2.  **基于mysql** ：①新建去重表；②服务端将客户端请求时提交的部分信息放入表中，其中有唯一索引字段；③成功插入则没有重复请求，插入失败则重复请求。
3.  **基于redis** ：①客户端请求服务端拿本次请求的标识字段；②服务端将标识字段以setnx方式存入redis并设置过期时间；③设置成功则说明非重复操作，设置失败则表示重复操作。
4.  状态机、悲观锁、乐观锁等。

## 七、提交订单 ##

### 1.防重提交 ###

在订单提交的时候我们通过防重Token来保证请求的幂等性

![image.png][image.png 9]

### 2.生成Token ###

我们在获取订单结算页数据的service中我们需要生成对应的Token，并且保存到Redis中同时绑定到页面。

![image.png][image.png 10]

页面中的处理

![image.png][image.png 11]

### 3.提交订单 ###

然后在提交订单的逻辑中我们先创建对应的VO

@Data
    public class OrderSubmitVO {
        
    
        // 收获地址的id
        private Long addrId;
    
        // 支付方式
        private Integer payType;
    
        // 防重Token
        private String orderToken;
    
        // 买家备注
        private String note;
    }

然后在订单确认页中创建对应的form表单

![image.png][image.png 12]

然后把数据提交到后端服务中。

![image.png][image.png 13]

### 4.防重检查 ###

订单数据提交到后端服务，我们在下订单前需要做防重提交的校验。

try{
        
                lock.lock();//加锁
                String redisToken = redisTemplate.opsForValue().get(key);
                if(redisToken != null && redisToken.equals(vo.getOrderToken())){
        
                    // 表示是第一次提交
                    // 需要删除Token
                    redisTemplate.delete(key);
                }else{
        
                    // 表示是重复提交
                    return responseVO;
                }
            }finally {
        
                lock.unlock(); //释放锁
            }

上面我们是通过Lock加锁的方式来实现Redis中的查询和删除操作的原子性，我们同时可以使用Redis中脚本来实现原子性处理。

// 获取当前登录的用户信息
            MemberVO memberVO = (MemberVO) AuthInterceptor.threadLocal.get();
            // 1.验证是否重复提交  保证Redis中的token 的查询和删除是一个原子性操作
            String key = OrderConstant.ORDER_TOKEN_PREFIX+":"+memberVO.getId();
            String script = "if redis.call('get',KEYS[1])==ARGV[1] then return redis.call('del',KEYS[1]) else return 0";
            Long result = redisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class)
                    , Arrays.asList(key)
                    , vo.getOrderToken());
            if(result == 0){
                // 表示验证失败 说明是重复提交
                return responseVO;
            }

[image.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/72fc75bcf57741049a36dd77b78a2f66.png
[image.png 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/b3c09f1654c3403aa950f04043b83f80.png
[image.png 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/00afb114a08a48ccb4a4dbfa7a6f703b.png
[image.png 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/27f585a77fa641f89ebff309decfcb02.png
[image.png 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/45d94c7888914f34af76526b8020e37c.png
[image.png 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/07848432b27a4771873872c94c27e297.png
[image.png 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/a944e45b9ee04867a37f5d7ebc1a8a5e.png
[image.png 7]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/d92d4da6969c4f839c62422330eeabb6.png
[image.png 8]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/baefd59875594de09492a842387888ba.png
[image.png 9]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/0ce7b5d7dc2f471aa4d1322552aac2b9.png
[image.png 10]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/c383064e50bd414aaeb706e23a6629a2.png
[image.png 11]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/d3fd72c3a91a4986b9ab271a19c06a7d.png
[image.png 12]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/2b8055b56a21480aaf3c5b5995432075.png
[image.png 13]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/08/db5f9d3fb1c844f08ad0db1b03caf1ff.png