15、RabbitMQ 实战 - 消息应答与持久化

一:消息应答

1、 介绍;

  涉及到的程序:

  boolean autoAck=false;

  channel.basicConsume(QUENE_NAME,autoAck,consumer);

2、 autoAck=true;

  自动确认模式。

  一旦rabbitMq将消息发送给消费者,就从内存中删除。

  缺点:如果这个时候消费者挂掉,就会丢失正在处理的消息。

3、 autoAck=false;

  手动模式。

  如果一个消费者挂掉,就会交给其他的消费者。

  rabbitMq支持消息应答,消费者发送一个消息应答,告诉rabbitMq这个消息已经处理结束,然后这时rabbitMq就会删除内存中的消息。

4、 默认;

  默认是打开的,为false。

二:持久化

1、 出现的缘由;

  如果rabbitMq挂了,消息就会丢失。

  rabbitMq支持持久化。

  

2、 涉及的程序;

  //创建队列声明

  channel.queueDeclare(QUENE_NAME,false,false,false,null);

  其中,第二个参数是durable,是否持久化。

3、 注意点;

  将第二个参数改成true,直接运行程序是会报错的。

  原因如下:

    因为刚才在运行程序的时候已经定义了一个队列,然后又定义了一个相同的队列,并且参数不同。这个是不被rabbitMq所允许的。

  做法:

    换一个队列的名字,或者去管理平台上删除已经存在的队列。