消息驱动架构在业务系统中的应用实践-源码库

消息驱动架构在业务系统中的应用实践：从订单系统改造看异步解耦

最近我们团队刚完成了一个核心订单系统的重构，将原来的同步调用架构改造成了消息驱动模式。在这个过程中，我深刻体会到了消息队列带来的解耦优势，也踩了不少坑。今天就跟大家分享我们的实践经验。

为什么选择消息驱动架构？

我们原来的订单系统采用传统的同步RPC调用，订单创建后需要同步调用库存服务、积分服务、通知服务等。随着业务增长，这种强耦合的架构暴露出很多问题：

一个服务宕机导致整个链路失败
高峰期系统响应时间急剧上升
新增业务功能需要修改多个服务

经过技术选型，我们最终选择了RabbitMQ作为消息中间件，主要看中其成熟稳定和丰富的功能特性。

核心改造步骤

1. 消息队列环境搭建

首先我们需要搭建RabbitMQ集群，这里我推荐使用Docker快速部署：

# 拉取RabbitMQ镜像
docker pull rabbitmq:3.9-management

# 运行RabbitMQ容器
docker run -d --name rabbitmq 
  -p 5672:5672 
  -p 15672:15672 
  -e RABBITMQ_DEFAULT_USER=admin 
  -e RABBITMQ_DEFAULT_PASS=password 
  rabbitmq:3.9-management

踩坑提示：生产环境一定要配置持久化和集群，我们曾经因为单点故障丢失过消息。

2. 订单服务消息发送实现

订单创建成功后，我们不再同步调用下游服务，而是发送消息到交换机：

@Service
public class OrderMessageProducer {
    
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
    public void sendOrderCreatedEvent(Order order) {
        try {
            OrderEvent event = new OrderEvent();
            event.setOrderId(order.getId());
            event.setUserId(order.getUserId());
            event.setAmount(order.getAmount());
            
            // 发送到订单交换机
            rabbitTemplate.convertAndSend(
                "order.exchange",
                "order.created",
                event
            );
            log.info("订单创建事件发送成功，订单ID：{}", order.getId());
        } catch (Exception e) {
            log.error("订单事件发送失败", e);
            // 这里我们实现了本地消息表来保证可靠性
        }
    }
}

3. 消费者服务实现

各个下游服务只需要监听自己关心的消息：

@Component
public class InventoryConsumer {
    
    @RabbitListener(queues = "inventory.deduct.queue")
    public void handleOrderCreated(OrderEvent event) {
        log.info("收到库存扣减消息，订单ID：{}", event.getOrderId());
        
        try {
            // 扣减库存逻辑
            inventoryService.deduct(event.getOrderId(), event.getSkuList());
        } catch (Exception e) {
            log.error("库存扣减失败", e);
            // 重试机制：我们配置了死信队列处理失败消息
            throw new RuntimeException(e);
        }
    }
}