哪个网站做简历免费下载,深圳公司名称大全,长沙做网站咨询公司,具体c2c网站建设实例开启消息确认机制#xff1a; 在发布消息时#xff0c;可以设置deliveryMode为2#xff08;持久化#xff09;#xff0c;以确保消息不会因为RabbitMQ的崩溃而丢失。 使队列持久化#xff1a; 通过设置durable为true#xff0c;可以确保队列在RabbitMQ重启后依然存在。… 开启消息确认机制 在发布消息时可以设置deliveryMode为2持久化以确保消息不会因为RabbitMQ的崩溃而丢失。 使队列持久化 通过设置durable为true可以确保队列在RabbitMQ重启后依然存在。 使消费者确认机制 启用手动确认模式并在消费完消息后手动确认。 以下是使用Java和Spring AMQP的示例代码
Bean
public Queue myQueue() {return QueueBuilder.durable(myQueue).build();
}Bean
public DirectExchange myExchange() {return new DirectExchange(myExchange);
}Bean
public Binding myBinding() {return BindingBuilder.bind(myQueue()).to(myExchange()).with(myRoutingKey);
}Bean
public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {SimpleMessageListenerContainer container new SimpleMessageListenerContainer();container.setConnectionFactory(connectionFactory);container.setQueueNames(myQueue);container.setMessageListener(listenerAdapter);container.setAcknowledgeMode(AcknowledgeMode.MANUAL); // 手动确认模式return container;
}Bean
public MessageListenerAdapter listenerAdapter(MyConsumer myConsumer) {return new MessageListenerAdapter(myConsumer, handleMessage);
}public class MyConsumer {public void handleMessage(Message message) {// 处理消息// ...// 确认消息channel.basicAck(envelope.getDeliveryTag(), false);}
}
在发送消息时
rabbitTemplate.convertAndSend(myExchange, myRoutingKey, message, message - {message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT); // 设置消息持久化return message;
});
确保你的消费者在处理完消息后调用basicAck来确认消息这样即使消费者崩溃未确认的消息也会被重新传递给另一个消费者。如果你希望在消费者异常时自动重新将消息放回队列可以在handleMessage方法中捕获异常并在异常处理逻辑中调用basicNack或basicReject方法并设置重回队列的参数。
