如何在消费者端接收并处理这些订单销量更新消息？

在消费者端处理这些订单销量更新消息，通常是通过监听RabbitMQ队列来实现的。在Spring AMQP中，可以创建一个消费者类，利用`@RabbitListener`注解来监听特定的队列。下面是一个简单的消费者示例：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class SalesUpdateConsumer {

    @RabbitListener(queues = "sales_updates")
    public void processOrderIncrease(String payload, Message message) {
        try {
            // 解析消息内容，获取订单ID和增量
            String[] parts = payload.split(": ");
            Long orderId = Long.parseLong(parts[0]);
            int amount = Integer.parseInt(parts[1]);

            // 根据解析出的数据更新数据库
            orderRepository.updateQty(orderId, amount);

            // 消费确认，移除消息（可选，避免死信）
            message.ack();
        } catch (NumberFormatException e) {
            // 错误处理，如无法转换数据
            log.error("Error processing order update message: {}", payload, e);
            message.nack();
        }
    }
}

在这个例子中，`processOrderIncrease`方法会在接收到队列中的每条消息时被触发。它先尝试解析消息内容，然后使用`orderRepository`（这里假定已经存在，用于操作数据库）更新订单销量。最后，调用`message.ack()`来确认消息已经被成功处理，如果处理过程中有错误，则使用`message.nack()`拒绝并记录异常，以便进一步处理。