Spring rabbitmq消息机制--手动确认

梦里梦外; 2024-04-17 20:33 65阅读 0赞

首先我们在Spring.xml中配置相关的消费者

在配置的时候可以指定是手动确认还是自动的确认，比如:

<rabbit:queue id="chatqueue2" durable="true" auto-delete="false" exclusive="false" name="chatqueue2" />  
        <rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual" >
            <rabbit:listener queues="chatqueue2" ref="receiveConfirmListener" />
        </rabbit:listener-container>

这个地方acknowledge=“manual”标识的是消息确认机制为手动的确认

那么我们在消费者中就需要手动的确认消息是否收到

消费者如下定义:

import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
    import org.springframework.stereotype.Service;
    
    import com.rabbitmq.client.Channel;
    
    @Service("receiveConfirmListener")
    public class ReceiveConfirmListener implements ChannelAwareMessageListener {
    
    	@Override
    	public void onMessage(Message message, Channel channel) throws Exception {
    		System.out.println("---------");
    		channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
    	
    	}
    
    }

这个里面有一个channel.basicAck 这个就是手动确认的函数

如果我们不在消费者中调用这个函数，那么rabbitmq就会一直的推送消息给消费者

也是就是说上面的输出语句会被重复的执行

![format_png][]

如果执行了这个手动确认之后，rabbitmq就不会向这个消费者推送消息了

channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);

函数的第二个参数boolean标识的是如果为true标识所有的消费者都已经收到了这个消息，如果为false标识仅仅是当前的消费这个收到的这个消息

如果是是一个消费者，自然是true和false都是一样的

希望对你有所帮助

[format_png]: https://imgconvert.csdnimg.cn/aHR0cDovL3JlYWQ4Njg2LmNvbS9XeldlYi91cGxvYWQvMjAxOTA4MzExNzMxMTlfaW1hZ2UucG5n?x-oss-process=image/format,png