一文搞懂RabbitMQ的ack與nack

connection = factory.newConnection();      final Channel channel = connection.createChannel();channel.queueDeclare("隊列名", true, false, false, null);
//第二個參數(shù)設(shè)為true為自動應答，false為手動ackchannel.basicConsume("隊列名", true, new DefaultConsumer(channel){    @Override        public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {       try {          Thread.sleep(10000);          System.out.println(new String(body, "UTF-8"));        //模擬異常        int i = 1/0;        //手動ack        //channel.basicAck(envelope.getDeliveryTag(), false);       } catch (Exception e) {                //重新放入隊列        //channel.basicNack(envelope.getDeliveryTag(), false, true);        //拋棄此條消息        //channel.basicNack(envelope.getDeliveryTag(), false, false);        e.printStackTrace();
      }finally {              }                    }});