2. 同步与异步通信机制：同步RPC调用与异步消息队列（MQ）的原理、适用场景、优缺点对比

在ERP系统中，模块间通信机制的选择直接影响系统的响应速度、数据一致性以及可扩展性。同步RPC（Remote Procedure Call）与异步消息队列（MQ）是两种最核心的通信范式。理解它们的原理、适用场景及权衡，是设计高可用、高吞吐ERP架构的基础。

2.1 同步RPC调用机制

同步RPC调用是指调用方发起远程过程调用后，阻塞等待被调用方返回结果，期间调用方线程挂起，直到收到响应或超时。在ERP中，典型的同步RPC场景包括：查询库存可用量、校验客户信用额度、实时计算订单价格。

2.1.1 同步RPC调用流程（SVG）

2.1.2 同步RPC的优缺点

2.2 异步消息队列（MQ）机制

异步消息队列通过中间件解耦生产者和消费者。生产者发送消息后立即返回，不等待消费者处理；消费者从队列中拉取或由队列推送消息进行消费。在ERP中，典型异步场景包括：批量成本核算、财务凭证过账、库存同步、报表生成、审批流程流转。

2.2.1 异步MQ通信流程（SVG）

2.2.2 异步MQ的优缺点

2.3 同步RPC vs 异步MQ：核心对比

2.4 ERP工程选型建议

• 强一致性+低延迟场景（如库存扣减、价格计算）：优先选择同步RPC，配合超时熔断和线程池隔离。
• 高吞吐+松耦合场景（如财务分摊、凭证过账、日志同步）：优先选择异步MQ，配合幂等消费和死信处理。
• 混合架构：ERP中常见“同步接收请求，异步处理业务”模式。例如：用户提交分摊请求时，同步RPC返回“已接收”，后台MQ异步执行分摊计算。
• 事务边界：同步RPC适合本地事务或XA事务；异步MQ适合Saga模式或TCC补偿事务。

2.5 代码示例：同步RPC vs 异步MQ（伪代码）

// ========== 同步RPC调用（Java Feign风格） ==========
// 调用方：订单服务
public OrderResult createOrder(OrderRequest req) {
    // 同步调用库存服务，阻塞等待
    InventoryResponse invResp = inventoryClient.checkStock(req.getSkuId(), req.getQty());
    if (!invResp.isAvailable()) {
        throw new BusinessException("库存不足");
    }
    // 继续执行订单创建...
    return orderRepository.save(req);
}

// ========== 异步MQ调用（Spring Cloud Stream风格） ==========
// 生产者：分摊请求服务
public void submitAllocationRequest(AllocationRequest req) {
    // 发送消息后立即返回
    messageSource.output().send(MessageBuilder.withPayload(req).build());
    // 不等待结果，前端轮询或WebSocket通知
}

// 消费者：分摊计算服务
@StreamListener(AllocationSink.INPUT)
public void handleAllocation(AllocationRequest req) {
    try {
        // 执行耗时分摊逻辑
        allocationService.calculate(req);
        // 手动ACK（框架自动处理）
    } catch (Exception e) {
        // 重试或发送到死信队列
        log.error("分摊处理失败，消息ID: {}", req.getMessageId());
    }
}