消费者
//生产上一般不会开启自动ACK，因为要保证消息的准确消费
channel.basicConsume(queueName, false, consumer);

生产者
channel.confirmSelect();


//添加publisher消息监听
channel.addConfirmListener(new ConfirmListener() {
    @Override
    public void handleAck(long deliveryTag, boolean multiple) throws IOException {
        //消息投递成功处理
        System.out.println("【ACK confirm】deliveryTag:" + deliveryTag + ",multiple:" + multiple);
    }

    @Override
    public void handleNack(long deliveryTag, boolean multiple) throws IOException {
        //消息丢失处理
        System.out.println("【NACK confirm】deliveryTag:" + deliveryTag + ",multiple:" + multiple);
    }
});
channel.basicPublish(normalExchange, normalRoutingKey, true, properties, msg.getBytes());