示例流程

网关发送消息之后，如何接收后端服务的秒杀结果，又如何给APP返回响应呢？

网关接收后端服务秒杀结果，实现方式不只一种，这里给个简单方案。

public class RequestHandler {
  // ID生成器
  @Inject
  private IdGenerator idGenerator;
  // 消息队列生产者
  @Inject
  private Producer producer;
  // 保存秒杀结果的Map
  @Inject
  private Map<Long, Result> results;
  // 保存mutex的Map
  private Map<Long, Object> mutexes = new ConcurrentHashMap<>();
  // 这个网关实例的ID
  @Inject
  private long myId;
  @Inject
  private long timeout;
  // 在这里处理APP的秒杀请求
  public Response onRequest(Request request) {
    // 获取一个进程内唯一的UUID作为请求id
    Long uuid = idGenerator.next();
    try {
      Message msg = composeMsg(request, uuid, myId);
      // 生成一个mutex，用于等待和通知
      Object mutex = new Object();
      mutexes.put(uuid, mutex)
      // 发消息
      producer.send(msg);
      // 等待后端处理
      synchronized(mutex) {
        mutex.wait(timeout);
      }
      // 查询秒杀结果
      Result result = results.remove(uuid);
      // 检查秒杀结果并返回响应
      if(null != result && result.success()){
        return Response.success();
      }
    } catch (Throwable ignored) {}
    finally {
      mutexes.remove(uuid);
    }
    // 返回秒杀失败
    return Response.fail();
  }
  // 在这里处理后端服务返回的秒杀结果
  public void onResult(Result result) {
    Object mutex = mutexes.get(result.uuid());
    if(null != mutex) { // 如果查询不到，说明已经超时了，丢弃result即可。
      // 登记秒杀结果
      results.put(result.uuid(), result);
      // 唤醒处理APP请求的线程
      synchronized(mutex) {
        mutex.notify();
      }
    }
  }
}

网关在收到APP秒杀请求后，直接给MQ发消息。

消息的内容，并不一定是APP请求的Request，只要包含足够字段：比如用户ID、设备ID、请求时间等。

还需包含这个请求ID和网关ID。

• 如果发消息失败，可直接给APP返回秒杀失败结果
• 成功发送消息后，线程就阻塞等待秒杀结果。这不可无限等待，需设等待超时时间。

等待结束后，去存放秒杀结果的Map中查询是否有返回的秒杀结果

• 有就构建Response，给APP返回秒杀结果
• 没有，按秒杀失败处理

给APP返回结果的，只能是处理APP请求的那个线程。

这是处理APP请求的线程，接下来我们来看一下，网关如何来接收从后端秒杀服务返回的秒杀结果。

可用RPC返回秒杀结果：网关节点是RPC服务端，后端服务为客户端。

网关发的消息包含网关ID，后端服务可通过网关ID找到对应网关实例，秒杀结果需包含请求ID，这请求ID也是从消息中获取。

网关收到后端服务秒杀结果后，用请求ID为Key，把结果存到秒杀结果的Map，然后通知对应的处理APP请求的线程，结束等待。

处理APP请求的线程，在结束等待后，会去秒杀结果Map中查询结果，然后再给APP返回响应。

处理过程流程图

这并非性能最优方案，处理APP请求的线程需要同步等待秒杀结果，可考虑使用异步方式。

1、秒杀的理解:

APP–发送秒杀请求–》网关（也是RPC服务端，和配置中心保持长连接，比如nacos，将其路由和配置信息定时的发送给配置中心，配置中心对其进行管理，定时的清除宕机的网关路由信息，如超过一定时间没有接收到网关的心跳包）–》将其APP请求做一定的封装，增加网关id和网关实例中唯一的请求id发送给消息队列，为了保证消息不丢失，网关对其发送消息出现的异常进行处理，如超时异常，直接返回秒杀失败，网关发送消息的这个过程中可能涉及到分布式事务，使用消息队列的分布式事务进行处理，然后网关需要等待一段时间，等待秒杀服务端使用RPC调用网关实例的接收秒杀结果，为此创建一个新对象，将其请求id做为key，新对象做为value放入CurrentMap中，调用新对象的超时wait方法进行等待秒杀结果–发送封装的APP请求，包含网关id和请求id–》消息队列接收APP请求消息，为了保证消息不丢失，开启Sync_Flush参数将消息保存到磁盘，并且为了防止一台机器磁盘出问题，集群需要2台机器都有消息才确认请求–从消息队列中拉取消息–》秒杀服务端，为了低延迟执行风控、预占库存，拿到消息中网关id，从本地路由中查询网关id的实例信息，如果获取不到调用网关实例时，需先从配置中心获取到网关的路由信息，秒杀服务端也需和配置中心保持长连接，定时的从配置中心拉取网关的路由信息，保存到本地，使用RPC调用网关实例的接收秒杀结果的方法，为了保证消息不丢失，先执行消费逻辑，再响应消息队列，如果根据网关id获取不到网关实例，或者确认消息队列超时或出现异常，秒杀服务端回滚事务，此过程也涉及到分布式事务，为了防止消费重复消息，接口的幂等性，将请求id和网关id做为唯一键。也为了防止消息积压，消息队列中的主题队列和消费组中的消费者一一对应，保证消息被快速消费。

2、秒杀异步，APP发送请求给网关，网关接收请求后将请求做一定的封装（包括请求id，网关id，账户id），然后发送到消息队列中，响应APP请求，无需等待后需的流程，然后秒杀成功以否直接返回，后续流程处理完使用短信的形式告知用户是否秒杀成功，不知道这样做法是否可行。

3、最近在撸rocketmq的源码，搞了namesrv、logging、logappend模块，想成为commiter，立个flag，等后续JMQ出来，撸其源码，也想成为commiter，道阻且长，持续进化。

解答：技术上都没什么问题。

从业务角度，有一些不同的看法。

对于秒杀这种场景，宏观上的设计应该是倾向于利用有限的资源处理短时间内海量的请求，保证服务不宕机。有少量请求处理出错（注意是后端错误，用户不可见）或消息丢失，是可以接受的。

毕竟秒杀拼的就是运气，某个用户秒杀请求在处理的时候丢失，和处理成功但没秒到，对于用户来说都是运气不好而已。

基于这样的设计理念，很多保证数据可靠性的做法都可以牺牲掉，用于换取系统更大的吞吐量比较划算。