一文带你了解微服务架构中的“发件箱模式”

什么是“发件箱模式”

在微服务架构中，通常使用异步消息作为不同服务之间的通信方式。而“发件箱模式”是其中一种常用的异步消息通信方式。

“发件箱模式”即将消息发送到一个消息队列（比如Kafka），然后由消息队列异步地将消息推送给接受方服务。发送方不用等待接收方处理完消息才能进行下一步操作，而是直接返回。这样可以提高整个系统的响应速度以及抗高并发的能力，还可以保证消息的可靠性。

如何使用“发件箱模式”

下面以订单服务和发货服务为例，讲解如何使用“发件箱模式”。

发送方（订单服务）

当订单服务需要发货时，可以将发货请求封装成一个消息，放入消息队列中。

@Component
public class OrderService {

  @Autowired
  private KafkaTemplate kafkaTemplate;

  public void deliverGoods(String orderId) {
    // 封装消息信息
    OrderMessage message = new OrderMessage();
    message.setOrderId(orderId);
    message.setDeliverTime(new Date());

    // 发送消息
    kafkaTemplate.send("deliver-goods", message);
  }
}

在这个例子中，订单服务将发货请求异步的放入名为“deliver-goods”的消息队列中。

接收方（发货服务）

发货服务需要监听“deliver-goods”队列，当有消息时取出消息并处理发货请求。

@Component
public class DeliverService {

  @KafkaListener(topics = "deliver-goods")
  public void receive(OrderMessage message) {
    // 处理发货请求
    System.out.println("Order " + message.getOrderId() + " delivered at " + message.getDeliverTime());
  }
}

通过@KafkaListener注解监听“deliver-goods”队列，当收到消息时执行receive方法进行发货处理。