1.问题:项目瓶颈,通过rabbitMq来异步上传图片,由于并发上传的图片过多导致阿里OSS异常,
解决方法:通过prefetchCount限制图片上传OSS的并发数量
2.定义消费者
@Component
@AllArgsConstructor
@Slf4j
public class ReceiveFaceImageEvent {private final UPloadService uploadService;/*** 采用 prefetchCount限制消费并发数*/@RabbitHandler@RabbitListener(queues = "faceImageQueue",//指定了应该使用哪个RabbitListenerContainerFactory来创建消息监听容器containerFactory = "limitRabbitListenerContainerFactory",//这设置了并发消费者的数量范围。在这个例子中，它设置了两个并发消费者，这意味着同时有两个线程可以处理来自该队列的消息。//(concurrency 控制特定监听器的并发消费者数量，而 setMaxConcurrentConsumers 控制通过工厂创建的所有监听器的并发消费者数量的上限。两者并不直接冲突，但 concurrency 会覆盖工厂级别的设置（对于设置了concurrency的监听器而言）)concurrency = "2-2")public void handler(MqMessage mqMessage){FaceImageInput input= (FaceImageInput) mqMessage.getObj();uploadService.uploadImage(input.getFaceImageUrl());}
}
3.创建RabbitMQ消息监听容器的工厂类。
@Configuration
public class RabbitAutoConfiguration {@Bean("limitRabbitListenerContainerFactory")public SimpleRabbitListenerContainerFactory limitRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();factory.setConnectionFactory(connectionFactory);//设置最大消费者 (设置此监听容器工厂创建的监听容器的最大并发消费者数量为5。这意味着在任何时候，都将有最多5个消费者线程并发地从RabbitMQ队列中拉取消息。)factory.setMaxConcurrentConsumers(5);//设置预取,计数为30。(预取是RabbitMQ消费者从队列中预先拉取但尚未处理的消息数量。当消费者处理消息的速度跟不上从队列中拉取消息的速度时，这个设置可以帮助减少消费者的空闲时间。但是，如果设置得太高，可能会导致消费者处理不过来，从而增加消息的延迟。)factory.setPrefetchCount(30);//设置了消息确认模式为自动确认(当消息被消费者处理完成后，RabbitMQ将自动认为该消息已被成功处理，并从队列中删除)factory.setAcknowledgeMode(AcknowledgeMode.AUTO);return factory;}}
