@Component
public class MessageConfirmCallback implements
《一线大厂Java面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》
【docs.qq.com/doc/DSmxTbFJ1cmN1R2dB】 完整内容开源分享
RabbitTemplate.ConfirmCallback , RabbitTemplate.ReturnCallback{
@Autowired
private RabbitTemplate rabbitTemplate;
@PostConstruct
public void initRabbitTemplate(){
rabbitTemplate.setConfirmCallback(this::/confirm/i);
rabbitTemplate.setReturnCallback(this::returnedMessage);
}
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
if (ack) {
System.out.println(“投递成功”);
} else {
System.out.println(“投递失败”);
}
}
@Override
public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
System.out.println(“交换机至消息队列出错：”);
System.out.println(“交换机：”+exchange);
System.out.println(“路由键：”+routingKey);
System.out.println(“错误状态码：”+replyCode);
System.out.println(“错误原因：”+replyText);
System.out.println(“发送消息内容：”+message.toString());
}
}
2. 消费者确认（ACK）
-
是消费端收到消息的一种确认机制
-
三种类型
-
自动确认：acknowledge=“none”
-
手动确认：acknowledge=“manual”
-
根据异常情况确认：acknowledge=“auto”
-
其中自动确认是指，当消息一旦被Consumer接收到，则自动确认收到，并将相应 message 从 RabbitMQ 的消息缓存中移除。但是在实际业务处理中，很可能消息接收到，业务处理出现异常，那么 该消息丢失
-
配置手动确认
spring.rabbitmq.listener.simple.acknowledge-mode=manual
路由模式开启手动签收spring.rabbitmq.listener.direct.acknowledge-mode=manual
是否支持重试spring.rabbitmq.listener.direct.retry.enabled=true
@Component
@RabbitListener(queues = “routing_queue1”)
public class AckConsumerListerner {
@RabbitHandler
public void ququeListernerHandler(String msg, Message message, Channel channel) throws IOException {
System.out.println(“收到的消息”);
MessageProperties messageProperties = message.getMessageProperties();
long deliveryTag = messageProperties.getDeliveryTag();
try {
if (msg.contains(“哈哈”)) {
throw new RuntimeException(“不允许哈哈笑”);
}
channel.basicAck(deliveryTag,false);
} catch (IOException e) {
e.printStackTrace();
channel.basicNack(deliveryTag,false,true);
}
}
}
消费端限流
场景
-
A系统中需要维护相关的业务功能，导致大量的消息都会在MQ中累积，A系统成功启动后，消费者会一次性将MQ中累积的大量的消息拉到自己的服务，导致服务在短时间内会处理大量的业务，可能会导致系统服务的崩溃
-
当大量用户请求过来的时候，消费端限流也非常必要；
代码实现
设置消费端限流，每次拉取消息多少条，默认是250条spring.rabbitmq.listener.direct.prefetch=1
复制代码
TTL(消息存活时间)Time To Live
- 当消息到达存活时间后，还没有被消费，会被自动清除
-
实现
-
设置队列的时候设置Arguments，添加x-message-ttl = 5000 (毫秒)
死信队列
