RabbitMQ的自动应答和消息持久化
在rabbitmq中,channel.basicConsume(String queuename, boolean autoAck, Consumer consumer),
autoAck 这个参数为true,表示自动应答,为false,表示手动应答
如果选择手动应答,必须加上这一行代码,在消费者消费完消息后手动应答,
channel.basicAck(envelope.getDeliveryTag(), false);
====== 持久化
boolean druable = false;
channel.queueDeclare(QUEUE_NAME, durable, false, false, null);
durable 表示是否持久化,true表示持久化,false表示不持久化。
转载于:https://my.oschina.net/hcy8888/blog/1808694