秒杀项目异步下单的流程一:
浏览器发送请求,首先请求到服务时,会先执行参数校验,如果校验失败直接返回给前端,如果校验成功则执行下单方法
其中的校验方法主要是利用redis的缓存机制,即所有参加校验的数据都存入redis中,因为这些是热点数据,需要频繁访问,利用vo的校验,和库存的校验就需要存入redis中,首先就是redis要在项目开始的时候进行初始化,为了是将所有的用户存入redis中,这样不用频繁访问数据库获取用户信息,还有将将获取所有的秒杀商品对象即voList结合,然后遍历voList集合,将每个vo转为json字符串存入redis中(需要定义redis的key,这里的redis使用hash的数据结构进行存储,避免key值太多,造成hash冲突),然后获取每个vo对象中的库存信息,然后同样定义一个key存入redis中,(由于使用的是hash结构存储,那么最外层的key就是一个标识,表示存的是库存还是秒杀商品,里层的key用秒杀商品id存储,value就是存vo对象或库存),
这样初始化redis之后,所有的热点数据都存入redis中了,校验时,比如校验秒杀商品是否存在,需要根据页面传的秒杀商品id去redis中查询有没有对应的商品信息,如果有,需要判断这个商品是否在活动范围之内(用时间进行判断),需要判断用户是否已经下过单(使用redis的setnx指令对应的代码,表示没有就存,有就不存),最后判断库存是否足够(使用redis去缓存中查使用increment机制,进行原子性递增(-1)),当校验成功后,需要下单,这时候就要利用rocketMQ发送异步下单,到消息中间件上,无论后面的消费者执行下单成功与否,消息中间件都会响应给浏览器,可以响应正在排队中,或其他,,,,
当将消息发送到消息中间件上以后,会与namesever建立长连接,然后将消息存入到中间件的bucket中,bucket中有一个topic专门存入一些主题消息,一个topic中可以存入4个sequence消息队列,然后消费者也就是需要下单的业务会订阅这个消息中间件,消费者其实就是一个监听器,用来监听消息中间件上的消息,然后从上面获取消息,获取指定tag的消息,也就是一个对象(这个对象封装了下单需要的秒杀商品id和用户id),然后消费者获取这两个id,然后调用下单的方法,将这两个参数传进入然后获取下单id,但是并不能保证下单一定成功,需要进行try-catch
然后在try里面要发送下单成功的消息到消息中间件中(目的是需要告诉浏览器刚才的请求是否发送成功),将获取的下单id和uuid(uuid是从前端页面传过来的id)封装成一个对象作为发送rocketMQ异步请求的消息发送至消息中心
消息中心获取到这个消息以后会存入到bucket中.这时候为了让浏览器可以随时获取发送请求之后响应这里使用一个与浏览器进行长连接的一个协议即为:WebSocket协议,因此需要新建一个websocket服务作为与浏览器进行长连接的一个服务,(前端会发送一个请求与WebSocket建立长连接)它既是消费者也是生产者,它会作为消费者从消息中心上将秒杀成功或者失败的消息获取下来,然后获取消息中的参数:uuid(非常重要),下单id 然后通过webSocketServer的clients将uuid作为参数获取指定的客户端,也就是所谓的session.如果session不为空,则创建一个result对象,将下单成功的消息对象封装进入result对象中,然后通过session.getBasicRemote().sentText()方法将result对象传进去,即可以给浏览器发送请求,且这个连接是长连接,主要是通过uuid获取哪个用户的发送的请求,然后通过WebSocket找到这用户然后将相应给他,这就是mq异步下单的大致流程.....
RocketMQ异步下单流程二:
主要是针对创建订单失败和成功的情况,当秒杀服务中创建订单的监听器在接收到注册中心中的消息以后,需要去执行创建订单的业务,(扣减库存,创建基础订单 和秒杀订单)同时也会发送消息到注册中心,告知消息中心秒杀成功,如果创建订单失败,还用还要在catch中往消息中心发送秒杀失败的消息,(同时需要redis库存回补,清除用户下单标记和本地标记)
如果秒杀成功,即下单成功,还需要在发送一个延迟消息到消息中心(用来检查订单是够超时未支付)
秒杀服务中新创建一个订单成功后延迟消息的监听器(主要用来监听订单是否超时未支付),如果监听到消息,则表示订单需要支付的时间已过期,这时,需要判断订单是否已支付(通过查询订单),如果已支付则不用做任何操作,如果未支付,需要将订单的支付状态改为超时未支付状态,同时还需要进行mysql数据库中的库存回补,然后将库存同步到redis库存中,还用清除本地标记(比如:当前库存为0时,由于可能秒杀服务器有多个,只清除本次的这台服务器有可能造成库存回补了,其他用户在其他服务器上进行下单时会显示库存不足,这就是由于本地标识存在,没有清除,导致库存不足)因此为了能够清除所有服务器的本地标识,使用消息中间件的广播消息这个机制去发送消息,这样所有的服务器都会收到清除本地标识的消息,这样创建一个清除本地 标识的监听器进行监听,当收到消息时,则调用controller去清除本地标识(将map缓存中的true改为false)
当秒杀服务创建订单失败后,有创建订单的监听器根据创建订单失败的异常信息作为消息发送到消息中心中,这时候需要在webSocket服务中创建一个秒杀失败的监听器,专门用来监听失败消息,如果监听到消息,则会将消息中的异常信息封装进result对象中,然后根据uuid找到对应的客户端,然后通过session.getBassicRemote.sentText()将result传到前端页面,用户就可以知道下单失败了
